kafka如何保证数据不丢失?

2020-08-25 20:30发布

3条回答
D滴滴
2020-08-25 20:39

消息不丢失:通过request.required.acks属性进行配置,有三个选项:

0代表:不进行消息接收是否成功的确认(默认值);

1代表:当Leader副本接收成功后,返回接收成功确认信息;

-1代表:当Leader和Follower副本都接收成功后,返回接收成功确认信息;acks设置为0时,不和Kafka集群进行消息接受确认,当网络发生异常等情况时,存在消息丢失的可能;想要不丢失消息数据就选:同步、ack=-1的策略。


一周热门 更多>