我在事务API中找不到答案。我认为在引擎盖下看设计可能是不可能的,但我想确认一下:如果消费者和生产者连接到不同的Kafka集群,那么有可能进行Kafka交易吗?这意味着我正在消费的主题和我正在推送的主题是在两个独立的Kafka集群上。
发布于 2019-04-27 01:53:49
您是对的,Kafka事务不能跨多个集群。
消费者和生产者必须使用相同的集群。主要原因是在事务中必须同时提交来自消费者的偏移量和来自生产者的记录。
https://stackoverflow.com/questions/55864382
复制相似问题