Kafka在spring上播放流，一次ACL的问题：TransactionalIdAuthorizationException
我很难从springboot kafka streams应用程序连接到Confluent cloud上的一个主题，连接失败时只出现了一行错误org。阿帕奇。Kafka。常见的错误。TransactionalIdAuthorizationException:事务Id授权失败
我相信这是因为主题被配置为允许具有指定transactial-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中创建生产者方法）中生成一个transactional-id，它被定义为Application ationId"-"taskId，这与主题ACL上定义的不匹配。
这是正确的吗？如果是，有解决办法吗？
共有1个答案
-
我正在尝试设置一个安全的Kafka集群，但在ACL方面遇到了一些困难。 Kafka流的汇流安全指南（https://docs.Confluent.io/current/Streams/developer-guide/security.html）只说明必须将集群创建ACL交给主体...但它没有说任何关于如何实际处理内部话题的内容。 通过研究和实验，我确定（对于Kafka版本1.0.0): 通配符不能
-
好吧，事情是这样的：我在做一个智力竞赛游戏，我决定给它放一张配乐。它是一个单一的音频文件，我上传到我的自定义域，并通过代码流。我还添加了播放/暂停按钮，这样播放器就可以播放和暂停音乐。音乐在框架1上自动播放，我的游戏的“开始”按钮在那里。但是，如果玩家答错了一个问题，他会回到第一帧。问题是音乐的另一个“实例”开始播放，导致两个音乐在同一时间播放。如果他再答错，就会有三首音乐回放，以此类推....我
-
硬件和软件：Raspberry PI4,IP camera,Raspbian Buster,Gstreamer 1.14.1（来自存储库）。覆盆子和摄像机都在本地网络上。 null 其他信息： > 我的相机在图像上方显示时间（时、分、秒）。回放总是在秒的某个值停止。相机重启时，这个数值随机变化--17、32、55……改变相机中的时间并不能解决问题。 Raspberry上的VLC播放器从该相机播放流
-
使用Spring云流上通道的标准配置，消息重试3次，然后跳过。如果以下消息处理成功完成，则提交偏移量。这意味着在瞬态异常情况下，消息可能会丢失。 是否可以更改此行为，从而使通道卡在失败消息上，直到修复瞬态条件？ 我已经尝试配置重试模板，但您必须指定多次重试，这看起来像是一个无用的参数，因为所需的行为将永远重试。 有人卷入这些麻烦吗？非常感谢。 我还怀疑这会如何干扰max.poll。间隔ms属性。
-
我正在尝试设置一个具有声音的媒体播放器，可以根据需要多次播放和重播。但我在第一次播放音频时出现了以下错误： 我调用该剧的代码是： playSong（）函数是： 我的声音位于res/raw/a.mp3中 当我按下BTN播放按钮时，我会显示BTN停止按钮，但没有播放任何内容。 我希望让用户玩、停、玩等等。我怎样才能做到这一点？ LogCat：
-
我正在使用PolledProcessor提出一个spring云数据流处理器。我遵循了下面的示例https://spring.io/blog/2018/02/27/spring-cloud-stream-2-0-polled-consumers。下面是我的代码。我将带有源管道的流部署到这个处理器（源polled-processor）到scdf，并让源发布一些消息。我确认处理器每秒轮询一次来自scdf