二、kafka消息與同步機制

如上圖所示：Producer根據指定的partition方法（默認round-robin、hash等），將消息發佈到指定topic的partition裏面；kafka集羣接收到Producer發過來的消息後，將其持久化到硬盤，並保留消息指定時長（可配置），而不關注消息是否被消費；Consumer從kafka集羣pull數據，並控制獲取消息的offset。 下面討論以下Kafka如何確保消息在pro

>>阅读原文<<