雲中的卡夫卡消費者

Question

我使用的春季卡夫卡消費者包裹在春季啓動應用程序中，並在關鍵雲代工廠部署爲微服務。我正在部署15個應用程序的實例，其中包括15個kafka分區。由於這些實例中的大多數會逐個啓動，會有多次重新平衡嗎？在雲中部署kafka用戶的推薦方式是什麼？

Answer 1

新的0.11客戶端有一個新的屬性group.initial.rebalance.delay.mssee Notable changes in 0.11.0.0。

引入了一個新配置group.initial.rebalance.delay.ms。此配置指定以毫秒爲單位的時間，即GroupCoordinator將延遲初始消費者重新平衡。當新成員加入該組時，重新平衡將進一步延遲group.initial.rebalance.delay.ms的值，最多可達max.poll.interval.ms。這個的默認值是3秒。在開發和測試期間，可能希望將其設置爲0，以便不延遲測試執行時間。

我們正在爲0.11客戶端添加支持。目前計劃用於Apache Kafka發佈的2.0 Spring，但我們正在考慮1.3版本的2.0功能的子集，並支持0.11。

你可以嘗試使用新的客戶端與較舊的春季卡夫卡;它可能工作，但當然，你不會得到0.11的功能，如交易和Headers。