關於kafka中consumer subscribe與asssign的理解

結論先行 凡是 一、具備相同group.id的consumer;二、將offset提交到kafka保存(不分手動和自動提交) 的consumer共享/共同維護 kafka中該group.id對應的offset。java 那麼就會有下面的影響:apache 一、broker中保存的是該group.id下全部consumer中最新提交的offset。api 二、當有新的consumer啓動的時候,其具
相關文章
相關標籤/搜索