kafka事务流程

流程 kafka事务使用的5个API // 1. 初始化事务 void initTransactions(); // 2. 开启事务 void beginTransaction() throws ProducerFencedException; // 3. 在事务内提交已经消费的偏移量(主要用于消费
posted @ 2024-06-17 20:48  付同學  阅读(9)  评论(0)  编辑  收藏  举报