java - 当 PROCESSING_GUARANTEE_CONFIG 设置为 EXACTLY_ONCE 时，Kafka 无法重新平衡

Question

我有一个运行良好的 Kafka 流应用程序。但是，当我添加属性时：

properties.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE);

然后我收到以下错误：

Exception in thread "trade-state-decider-a271c9f6-d9d8-488c-b91c-57cdfaf54894-StreamThread-1" org.apache.kafka.streams.errors.StreamsException: stream-thread [trade-state-decider-a271c9f6-d9d8-488c-b91c-57cdfaf54894-StreamThread-1] Failed to rebalance.


Caused by: org.apache.kafka.common.errors.TransactionalIdAuthorizationException: Transactional Id authorization failed.

任何人都知道什么可以解决这个问题？

Answer 1

如错误所示，您的应用程序无权使用事务。使用事务需要您可以通过 ACL 启用的特殊权限。

有关您需要授予什么权限的更多详细信息，请参阅文档：https ://docs.confluent.io/current/kafka/authorization.html#enabling-authorization-for-idempotent-and-transactional-apis