我无法从springboot kafka-streams应用程序连接到Confluent云上的主题，连接失败并显示一条错误线org.apache.kafka.common.errors.TransactionalIdAuthorizationException: Transactional Id authorization failed.
我相信这是因为该主题已配置为允许使用指定的事务ID（https://docs.confluent.io/current/kafka/authorization.html#enabling-authorization-for-idempotent-and-transactional-apis）进行交易。我的服务是流应用程序，它在每个StreamThread（在https://github.com/apache/kafka/blob/2.4.1/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java中创建生产者方法）中生成一个事务ID，该事务ID定义为applicationId + "-" + taskId，这与在主题ACL上定义的ID不匹配。
这是正确的吗？如果可以，是否有解决方法？
您只需要使用<application.id>-指定前缀即可使用通配ACL，即，将相应的ACL指定为--resource-pattern-type prefixed
• Kafka Streams Yearly time Window
• 使用带有 selenium 的 pom 框架的页面类的 Pycharm Intellisense
• GENERATE_EEK和GET_METADATA在hdfs透明加密中的作用
• Chartjs with Nextjs - 用于绘制图形的用户输入
• Torrent 流应用程序中的“参数 str 必须是字符串”错误 [关闭]
• 如何安全地存储用于对本地配置服务器进行身份验证的用户名和密码？
• std::pair from temporary：为什么调用复制构造函数而不是移动构造函数？
• 使用 aler9/rtsp-simple-server，能够从文件流式传输 HLS，但不能从 ffmpeg 的标准输入
• 带 azure blob 存储的视频流 Node JS 控制器不工作
• SQLAlchemy 在 Jupyter Notebook 中将百分号加倍