Kafka 数据丢失和数据重复的原因和解决办法

数据丢失的原因 Kafka 消息发送分同步 (sync)、异步 (async) 两种方式,默认使用同步方式,可通过 producer.type 属性进行配置; 通过 request.required.acks 属性进行配置:值可设为 0, 1, -1(all)    -1 和 all 等同 0 代表:不等待 broker 的 ack,这一操作提供了一个最低的延迟,broker 一接收到还没有写入磁
相关文章
相关标签/搜索