当 PROCESSING_GUARANTEE_CONFIG 设置为 EXACTLY_ONCE 时，Kafka 无法重新平衡答案

【问题标题】：Kafka Failed to rebalance when PROCESSING_GUARANTEE_CONFIG set to EXACTLY_ONCE当 PROCESSING_GUARANTEE_CONFIG 设置为 EXACTLY_ONCE 时，Kafka 无法重新平衡
【发布时间】：2020-05-27 17:29:33
【问题描述】：

我有一个运行良好的 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.

任何人都知道什么可以课程？

【问题讨论】：

标签： java apache-kafka apache-kafka-streams exactly-once

【解决方案1】：

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

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

【讨论】：