kafka kafka 2.3 版本 生产者和消费者事务 案例

Posted 2021-09-09 九师兄

文章目录

• 1.概述
• 2.不设置
• 3.read_uncommitted
• 4.取消事务
• 4.小结

1.概述

今天想写一个事务的kafka生产者和消费者，然后我在本地开了一个Kafka，kafka版本为kafka_2.11-2.30

这里有一个1.1.0版本的测试结果和这次不相同：【kafka】kafka DefaultRecordBatch. The older message format classes only support conversion from class

[lcc