Kafka 0.8.2自定義API庫？

Question

我正在使用Kafka隊列0.8.2並且已經實現了標準的輪詢和推送呼叫。現在要轉到需要實現Simple Consumer的pollByIndex方法。

是否有人知道其已經與這樣的方法涉及一些自定義庫自實施簡單的消費可以是一個大量的工作:)

升級到0.9使用ConsumerAPI不是選項還我。

Answer 1

好的。所以創建SimpleConsumer並不容易。所以我去解決方案實施另一個命令創建不同的組，每次我排隊存儲在zookeeper中的結果，然後分配我需要的主題上的偏移量。這種方式默認流媒體隊列不會被破壞，它在zookeeper上創建小負載，但沒有什麼意義。

同樣在每次查詢之後，我會小心地從zookeeper中刪除組以保持其清潔。

1天的編碼更少。

隨着新版本0.9和更新版本，我們將有消費者API，它也有自己的調用這種情況。在此之前，開發人員需要更多的工作。