kafka消息與同步機制

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

>>阅读原文<<