前言
事务对java开发的同学来说并不陌生，我们使用事务的目的在于避免产生重复数据或者说利用数据存储中间件的事务特性确保数据的精准性，比如大家熟悉的mysql，我们在程序开始时，只需要在程序中添加上事务注解即可
kafka客户端事务，直接使用客户端提供的相关的API即可，和jdbc事务的使用很类似，主要包含下面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;
下面结合实际的代码以及效果演示进行说明
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.p版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/143312.html
