kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

1 kafka稳定性

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

1.1 幂等性

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

幂等性默认是开启的。

1.2 事务

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

实现步骤:

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

 生产者发送消息案例:

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

1.3 控制器

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七) kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

 kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七) 

 

1.4 可靠性保证

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

 kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

1.5 一致性保证

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

 kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

 kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

避免数据丢失

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

 避免数据不一致

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

1.6 消息重复的场景及解决方案

1.6.1 生产者端重复

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

1.6.2 消费者端重复

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

1.7 _consumer_offsets

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)

kafka-稳定性-幂等性、事务、控制器、可靠性保证、一致性保证-小白笔记(七)