卡夫卡高級用戶可以分配給特定的分區嗎？

考慮到卡夫卡的消費者可以配置爲僅從一個分區接收消息，我還沒有看到這方面的配置方法。卡夫卡高級用戶可以分配給特定的分區嗎？

我如何告訴卡夫卡經紀人：

，我是一個消費者本ID，這L組下，訂閱X主題，肯得流PARTITION A？

然後，再掀消費者乙，下L組，其訂閱X主題，願意得到分區B流？

換句話說，如卡夫卡描述的場景，

如何啓動消費者訂閱特定用戶的牆飼料？我可以在用戶登錄時啓動消費者，從主題中消費他/她的分區並將該消息發送給客戶端？

來源

2013-09-28 Ravindranath Akila

提前感謝！ –

看來這不是0.7中實現的功能。

在這個線程看一看：

http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201205.mbox/browser

但是，它計劃在未來的版本：

https://issues.apache.org/jira/browse/KAFKA-345 https://issues.apache.org/jira/browse/KAFKA-909

來源

2013-09-28 15:46:51

這個答案是這樣的，任何有同樣問題的人都會選擇我最終研究的地方。請注意，截至目前，0.8版的Beta 1已可用，我們可以看到這些功能是否將實施。一個低級別的消費者是要走的路（http://people.apache.org/~joestein/kafka-0.7.1-incubating-docs/kafka/api/FetchRequest.html），在很多提供的損失特徵。 –

在kafka 0.8發行版中檢查[Simple consumer API]（https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example）。從他們的文檔你應該去爲簡單的消費者API，當你想要消息的細粒度控制，例如多次消耗相同的偏移量或從特定的分區等。 – user2720864

卡夫卡高級用戶可以分配給特定的分區嗎？

回答

相關問題