1. 事务的5个API
// 1初始化事务
void initTransactions();
// 2开启事务
void beginTransaction() throws ProducerFencedException;
// 3在事务内提交已经消费的偏移量（主要用于消费者）
void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets,
String consumerGroupId) throws ProducerFencedException;
// 4提交事务
void commitTransaction() throws ProducerFencedException;
// 5放弃事务（类似于回滚事务的操作）
void abortTransaction() throws ProducerFencedException;2. 幂等性和事务性的关系
事务属性实现前提是幂等性，即在配置事务属性transaction id时，必须还得配置幂等性；但是幂等性是可以独立使用的，不需要依赖事务属性。
- 幂等性引入了Porducer ID
- 事务属性引入了Transaction Id属性。
使用场景文章来源：https://www.toymoban.com/news/detail-628970.html
- enable.idempotence = true，transactional.id不设置：只支持幂等性。
- enable.idempotence = true，transactional.id设置：支持事务属性和幂等性
- enable.idempotence = false，transactional.id不设置：没有事务属性和幂等性的kafka
- enable.idempotence = false，transactional.id设置：无法获取到PID，此时会报错
3. 参考
kafka幂等生产者及事务_51CTO博客_kafka事务文章来源地址https://www.toymoban.com/news/detail-628970.html
到了这里，关于kafka-事务的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
