Kafka生产者保证数据可靠传输

Kafka是众多MQ(Message Queue)中的一种,MQ普遍都会面临消息丢失的问题,造成消息丢失的原因有很多种,例如: 生产者将消息发送,但是不确保消息到达MQ中 MQ接收到消息,但是消息丢失了 … 本文实验采用的Kafka是kafka_2.11-1.1.1版本 Kafka发送消息模型 考虑有一个Topic,只有一个分区(num.partitions=1),副本因子是2(replicati

>>阅读原文<<