客戶端的卡夫卡生產者如何工作？

假設我擁有一個kafka集羣，並且我要求一些客戶端（web應用程序）向卡夫卡發送數據，我如何確保創建生產者的客戶端連接到我的卡夫卡經紀人將執行分區如果客戶端將使用自定義分區器，那麼正確的方法是什麼？客戶端的卡夫卡生產者如何工作？

這是錯的呢？我應該通過我自己的製作者連接到這些應用嗎？或者他們應該創建自己的生產者？ –

AFAIK無法限制Kafka客戶端/集羣使用某個分區程序。但是如果您的製作人隱藏在某個外觀界面的後面，您可能會檢查您的信息的Key是否以正確的方式創建。

例如，您的外觀可接受ProducerRecord s。在這種情況下，您可以訪問key和value字段。

2016-09-20 14:46:13 leshkin

回答