Kafka 0.8.2 自定义 API 库？
Kafka 0.8.2 custom API libraries?
我正在使用 Kafka queue 0.8.2 并实现了标准轮询和推送调用。现在想转到需要实现简单消费者的 pollByIndex 方法。
有人知道一些自定义库已经处理了这样的方法，因为实现简单消费者可能需要大量工作:)
升级到 0.9 以使用 ConsumerAPI 对我来说还不是选项。
好的。所以创建 SimpleConsumer 并不容易。因此，我寻求实现另一个命令的解决方案，该命令在每次排队等待存储在 zookeeper 中的结果时创建不同的组，然后在主题上分配我需要的偏移量。这样默认的流队列就不会被破坏，它会给 zookeeper 带来很小的负载，但没什么大不了的。
此外，在每次查询后，我都会注意从 zookeeper 中删除组以保持其清洁。
1 天编码更多更少。
对于新版本 0.9 和更高版本，我们将拥有 ConsumerAPI，它也针对这种情况有自己的调用。在那之前，开发方面需要做更多的工作。
我正在使用 Kafka queue 0.8.2 并实现了标准轮询和推送调用。现在想转到需要实现简单消费者的 pollByIndex 方法。
有人知道一些自定义库已经处理了这样的方法，因为实现简单消费者可能需要大量工作:)
升级到 0.9 以使用 ConsumerAPI 对我来说还不是选项。
好的。所以创建 SimpleConsumer 并不容易。因此，我寻求实现另一个命令的解决方案，该命令在每次排队等待存储在 zookeeper 中的结果时创建不同的组，然后在主题上分配我需要的偏移量。这样默认的流队列就不会被破坏，它会给 zookeeper 带来很小的负载，但没什么大不了的。
此外，在每次查询后，我都会注意从 zookeeper 中删除组以保持其清洁。
1 天编码更多更少。
对于新版本 0.9 和更高版本，我们将拥有 ConsumerAPI，它也针对这种情况有自己的调用。在那之前，开发方面需要做更多的工作。