2023年1月30日

.net core 下使用 Kafka 批量发送消息，使用事务(四)

摘要： 批量发送消息，使用事务，要么全失败要么全成功 重要提示 必须设置事物ID producerConfig.TransactionalId =Guid.NewGuid().ToString();//必须设置事物id 1 /// <summary> 2 /// 批量发送 3 /// </summary> 阅读全文

posted @ 2023-01-30 21:37 是水饺不是水饺 阅读(90) 评论(0) 推荐(0) 编辑

.net core 下使用 Kafka 生产者批量发送给消息处理，使用事务(四)

摘要： 生产者批量发送消息，使用事务，要么全部失败要么全部成功 重要 说明 事物id必须要设置 producerConfig.TransactionalId =Guid.NewGuid().ToString();//必须设置事物id 1 /// <summary> 2 /// 批量发送 3 /// </su 阅读全文

posted @ 2023-01-30 21:26 是水饺不是水饺 阅读(131) 评论(0) 推荐(0) 编辑

.net core 下使用 Kafka 动态创建分区，创建主题(三)

摘要： Kafka 动态创建分区，创建主题，代码接上一篇 写在api里了 1 using Confluent.Kafka.Admin; 2 using Confluent.Kafka; 3 using KafkaCommom; 4 using Microsoft.AspNetCore.Http; 5 usi 阅读全文

posted @ 2023-01-30 18:00 是水饺不是水饺 阅读(207) 评论(0) 推荐(0) 编辑