我正在使用kafka queue 0.8.2，并实现了标准的轮询和推送调用。现在我们来看看pollbyindex方法，它需要实现简单的使用者。是否有人知道一些自定义库已经处理了这样的方法，因为实现简单消费者可能需要大量的工作：）升级到0.9以使用consumerapi尚未为我提供选项。
wbgh16ku1#
好 啊。因此，创建simpleconsumer并不容易。所以，我去实现另一个命令的解决方案，该命令创建不同的组，每次我排队的结果存储在zookeeper，然后分配偏移量我需要的主题。这样默认的流队列就不会被破坏，它会在zookeeper上产生很小的负载，但没有什么意义。每次查询之后，我都会小心地从zookeeper中删除组，以保持它的干净。1天的编码更多更少。随着新版本0.9和更新，我们将有consumerapi有自己的呼吁也为这种情况。在此之前，开发人员需要做更多的工作。
1条答案
按热度按时间wbgh16ku1#
好 啊。因此，创建simpleconsumer并不容易。所以，我去实现另一个命令的解决方案，该命令创建不同的组，每次我排队的结果存储在zookeeper，然后分配偏移量我需要的主题。这样默认的流队列就不会被破坏，它会在zookeeper上产生很小的负载，但没有什么意义。
每次查询之后，我都会小心地从zookeeper中删除组，以保持它的干净。
1天的编码更多更少。
随着新版本0.9和更新，我们将有consumerapi有自己的呼吁也为这种情况。在此之前，开发人员需要做更多的工作。