开发者社区> 问答> 正文

怎样解决kafka消息丢失问题?

怎样解决kafka消息丢失问题?

展开
收起
7大帅 2021-12-12 15:32:25 794 0
1 条回答
写回答
取消 提交回答
  • 不要使用 producer.send(msg),而要使用 producer.send(msg, callback)。

    设置 acks = all。

    设置 retries 为一个较大的值。

    设置 unclean.leader.election.enable = false。

    设置 replication.factor >= 3。

    设置 min.insync.replicas > 1。

    确保 replication.factor > min.insync.replicas。

    确保消息消费完成再提交。

    2021-12-12 22:57:13
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载