Kafka相关问题(面试常问)

kafka相关问题算法 kafka在高并发的状况下,如何避免消息丢失和消息重复?api 消息丢失解决方案:网络 首先对kafka进行限速, 其次启用重试机制,重试间隔时间设置长一些,最后Kafka设置acks=all,即须要相应的全部处于ISR的分区都确认收到该消息后,才算发送成功多线程 消息重复解决方案:并发 消息可使用惟一id标识 负载均衡 生产者(ack=all 表明至少成功发送一次) 异步
相关文章
相关标签/搜索