consumer

6热度

4回答

Kafka高级消费者使用Java API从主题获取所有消息（等效于 - from-beginning）

我正在使用Kafka网站的ConsumerGroupExample代码测试Kafka高级消费者。我想检索我在“Kafka服务器配置”中关于“测试”主题的所有现有消息。综观其他博客，auto.offset.reset应设置为“最小”，以能够得到的所有消息： private static ConsumerConfig createConsumerConfig(String a_zookeeper, S

0热度

1回答

Java中的多个生产者单个消费者的软件设计

我有多个生产者，每个生产者都将数据推入自己的阻塞队列。来自每个生产者的数据是独立处理的（因此是单独的队列）。我的单个消费者当前正在轮询每个队列，每个队列都有一个超时。程序工作得很好，但我想优化，我不喜欢“投票”。这是最有效的方法来处理这个问题吗？，我已经使用每个生产者的消费者编写了相同的应用程序，但该配置文件稍差。谢谢。

1热度

1回答

如何配置WSO2 ESB 4.7 JMS消费者代理轮询间隔？

任何人都可以告诉我是否有一个属性允许配置JMS消费者代理轮询队列/主题的频率？

0热度

1回答

MassTransit消费者在使用Windsor集成时从未调用

我似乎无法得到适用于RabbitMQ上的Mass Transit的Castle Windsor集成。一切都很好，直到我将温莎引入到图片中。我引用了Castle.Windsor 3.2和MassTransit.WindsorIntegration 2.9，并将容器配置为在我的应用程序中使用。我通过注册MassTransit消费者： Container.Register(..., Types.From

0热度

2回答

如何在C中实现我自己的信号量？

我正在通过不同的方法解决生产者/消费者问题。我目前正在从事的工作涉及到我自己实现的一个信号量，与Peterson的解决方案配合使用，以保护信号量的down（）和up（）函数调用。问题是，我在C中工作，我可以考虑创建信号量的唯一方法是使用带有函数指针的结构体，用于down（）和up（）。这是正确的想法吗？

0热度

1回答

activeMQ上消费者的选择问题

方案：我发送五万消息到名为JUST.CN的队列。然后每消息1000个消息，我会创建一个消息propertyString“myfilter ='abc'”。现在，我使用相同的选择器创建消费者以使用消息。但是，在30000消息之后，特别是消费速率非常慢。我无法更改activeMQ中的默认配置。核心代码如下： IDestination destination = SessionUtil.GetDest

2热度

3回答

谷歌消费者调查没有出现在我的网站上

我想在我的网站上调查网站访问者。我非常喜欢我在Google消费者调查中看到的演示机制。我无法让调查在我的网站上呈现。 Google消费者调查控制面板中的状态表明它已启用，但没有响应，因为它不会弹出。该脚本是 <script async="" defer="" src="//survey.g.doubleclick.net/async_survey?site=[mysiteid]" </scri

0热度

1回答

ActiveMQ，我如何创建只有一个消费者？

我正在使用Java EE和ActiveMQ。我想实现一个JMS队列，我可以将消息发送到我的QUEUE，并且Consumer + MessageListener应该读取此消息。的代码为我的消费者IST如下： private void initializeActiveMq() throws JMSException { // Create a ConnectionFactory

-1热度

1回答

最佳数据结构？ - 2个线程，1名制片人，1名消费者

什么是用做以下最佳的数据结构： 2个线程： 1产生（写入）的数据结构 1从数据结构中消耗（读取，然后删除）。线程安全生产者和消费者能够访问数据结构simultaenously 高效的大量数据

0热度

2回答

OSGI捆绑服务消费者是否需要创建服务接口的“存根”？

我刚刚接触OSGI技术，并且我没有几个基本查询。以下是我所做的：在名为“com.mypackage.osgi.bundle.service”的包中创建HelloWorld接口。这个接口暴露了一个方法：public String sayHello（String arg）; 在名为“com.mypackage.osgi.bundle.service.impl”的包中创建了一个HelloWorldI