问题标签 [producer]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - 是否可以使用 java 将 kafka 消费者接收到的输出写入文件
我有一个用 java 编写的 Kafka Producer 代码，用于编写 kafka 消息。以及接收这些消息的消费者代码。
是否可以将消费者收到的这些消息写入java中的任何文本文件。
c - 缓冲区在程序中被读取为未声明，即使它是
试图从我的另一个问题中解决一些错误。我的编译器正在读取 buff[counter] 作为缓冲区，因此未声明它。缓冲区是作为起始代码的一部分提供给我的，所以我不确定 buffer[counter] 是什么意思。尝试用谷歌搜索它并没有帮助，因为我不知道如何找出 buffer[counter] 的含义，它像 buffer_counter 吗？他们是说 buffer_counter 是缓冲区的计数器吗？任何帮助将不胜感激，特别是如果有人可以解释 [counter] 部分，因为这样我就可以自己修复它。
我的代码开头有这个
还有这个 if(remove_item(&item)) {
触发一个相关的错误，称为“从不兼容的指针类型传递 remove_item 的参数 1”，如此处所示
java - 在 Java EE 7 CDI 应用程序中更新注入的域对象
这可能更像是一个概念问题而不是技术问题，但是我希望您可以就如何继续向我提供一些建议。我们正在开发一个大型 Java EE 7 应用程序，该应用程序无状态地工作并从客户端获取请求。每个请求都包含一个会话 ID，每个会话都包含大量特定于会话的域对象。我们创建了一个 RequestScoped 类，其中包含我们领域对象的所有生产者方法。当请求带有会话 ID 时，我们调用生产者上的 setter 方法来设置生产者 CDI bean 中的会话 ID。现在，如果链上的 RequestScoped 类之一需要域对象之一，它在类的开头有一个 @Inject 定义，以从生产者那里获取域对象。
现在问题来了：假设 Bean A 注入域对象 X 并更改 X 上的一些属性。我是否必须在生产者中调用“更新”方法并将域对象 X 作为参数传递，还是在上下文中自动更新？在请求范围内注入后，CDI 容器会创建一个代理来访问实际的 bean。该代理是否可以像常规参考一样使用？例如，如果我在注入的 bean 上调用一个方法，它会更新代理后面的 bean 吗？
c# - 如何取消 MassTransit 中长时间运行的任务
我使用以下示例作为参考点来创建部署 MassTransit。我的目标是模拟恢复（它适用）缩放（也适用）取消（无法使其工作并需要帮助）继续响应/进度（工作进度 - 可能是我的下一个任务）
（更多描述，因为我被搁置了感谢指导我的家伙）这些是需要的 nuget 包
MassTransit MassTransit.RabbitMQ RabbitMQ.Client TopShelf
这就是我拥有的制作人。它只需要一个字符串来触发一个作业并从该作业中获取响应。
Below is the code for consumer. The consumer just picks up a message and have a Thread of 30 sec to simulate long running jobs.
And these are the messages i send
public interface ISimpleRequest
{
DateTime Timestamp { get; }
string CustomerId { get; }
}
public interface ISimpleResponse
{
string CusomerName { get; }
}
public class SimpleRequest : ISimpleRequest
{
private readonly string _customerId;
private readonly DateTime _timestamp;
public SimpleRequest(string customerId)
{
_customerId = customerId;
_timestamp = DateTime.UtcNow;
}
public DateTime Timestamp
{
get { return _timestamp; }
}
public string CustomerId
{
get { return _customerId; }
}
}
任何提示都会非常有帮助。
jsf - 定义生产者注释值时的焊接异常
我试图从另一个 SO 问题中实施解决方案： https ://stackoverflow.com/a/10059245/1943765但它并非在所有情况下都有效。
当我将此代码放入 CDI bean 时（bean 代码显示在底部）：
一切正常。但是当我尝试为 @HttpParam 注释定义值时（所以，不是默认值） Weld 无法启动：
我得到这个例外：
我使用的代码类似于链接的 SO 问题。
自定义 @HttpParam 注释：
注释值生产者：
使用它的 CDI bean 类似于：
我也在使用带有 Weld Servlet 2.3.1.Final 的 Tomcat 8 服务器。
所以..我做错了什么？：-/
python - 同一消费组中的多个消费者
我在同一组（我的组）中有 1 个生产者和 1 个消费者。
osgi - Karaf - Kafka OSGI 捆绑包 - 生产者问题
我正在尝试在 apache Karaf 版本 4.0.3 中为 Kafka 生产者创建一个简单的包。
这是我的Java代码
我已经在 pom.xml 中明确声明了各自的依赖关系
我也部署了那个 kafka 客户端包。
但是在启动生产者时，我在第一次尝试时看到了以下异常。
然后连续这个...
有没有人遇到过类似的问题？
synchronization - 使用监视器解决消费者/生产者
在使用监视器解决消费者/生产者问题的常见模式中，为什么总是使用 notify/notifyall 语句，即使只有当数组中的元素数量从零变为一或从 n 变为 n-1 时才使用它才有意义。以几乎所有文献中描述的方式，它最终导致相当大比例的通知调用最终产生零效应，这意味着只是浪费资源。或者我在这里错过了一些大事？
activemq - ActiveMQ - 如何处理生产者关闭
以下代码创建消费者并注册到队列：
问题是我们偶尔会收到“Producer is closed”异常：
重新启动应用程序会重新建立连接，并且消息会正确排出。有没有办法检查生产者是否已关闭并刷新连接？
python - 使用 pykafka 在主题的特定分区上发布
如何在pykafka主题的特定分区上发布消息。在下面的一段代码中，测试主题有四个分区，我打算在其中一个分区中写入每条消息，但显然它不是那样工作的。