Spring kafka事务id在开始时是错误的

Question

我使用弹簧kafka 2.2.2.RELEASE

我们的经纪人有严格的授权验证。

这是我们的客户端配置：

• spring.kafka.producter.transaction-id-prefix=test
• 主题：主题
• groupId：组

它应该生成一个事务id："test.group.topic0">

问题：

当我启动应用程序时，会调用KafkaMessageListenerContain#onPartitionsAssigned，并且使用的事务id是"test0"。在这种情况下，kafkaTemplate似乎不在listenerContainer中。

这导致了未经授权的异常，因为此事务id被代理拒绝

问题

这正常吗？

Answer 1

谢谢；这是一个bug；我打开了一期。