如何在檢查點被禁用時配置特定的Zookeeper路徑來提交偏移量？

Question

如果檢查點未啓用，卡夫卡用戶將定期向Zookeeper提交偏移量。是否可以配置動物園管理員路徑？

Answer 1

不能這樣做。因爲如果kafka使用zookeeper來存儲偏移量，那麼zookeeper路徑在kafka代碼中被硬編碼。

的路徑是這樣的：

/消費者/ {} yourConsumerGroup /偏移/ {yourFancyTopic}/{}的partitionid

不能配置此。