Kafka生產者保證數據可靠傳輸

Kafka是衆多MQ(Message Queue)中的一種,MQ普遍都會面臨消息丟失的問題,造成消息丟失的原因有很多種,例如: 生產者將消息發送,但是不確保消息到達MQ中 MQ接收到消息,但是消息丟失了 … 本文實驗採用的Kafka是kafka_2.11-1.1.1版本 Kafka發送消息模型 考慮有一個Topic,只有一個分區(num.partitions=1),副本因子是2(replicati

>>阅读原文<<