带主题模式的SpringKafka列斯汀，分配所有主题的所有分区
我有@KafkaListener使用topicPattern与正则表达式，工作正常（foo。*），但现在我想将侦听器分配给所有匹配主题的所有分区。
https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#tip-assign-all-parts并没有真正帮助我，因为我不知道主题名称。
共有1个答案
使用模式时不能手动分配分区；模式只支持组管理（Kafka执行任务）。
如果您的应用程序只有一个实例，Kafka将为匹配主题分配所有分区。如果有多个实例，并且您希望它们都分配给所有分区，它们必须具有唯一的group.ids。
-
我怎样才能暗示SpringKafka把每一个话题传播给一个不同的消费者呢？ 干杯
-
我有以下用例： 我有两个Kafka主题，一个是用来处理传入消息流的，另一个是用来存储记录的，作为应用程序初始状态的引导。 有没有办法做到以下几点： 当应用程序启动时，读取Kafka主题中的所有消息，并将该主题中用于将应用程序引导至初始状态的所有存储在内存中 只有在读取了所有消息后，才允许处理流主题中的 因为在应用程序运行时，状态主题上可能会有其他记录，以便在不必重新启动应用程序的情况下将它们合并到
-
我在使用Mosquitto作为MQTT代理。
-
我有一个具有多个订阅和资源的Azure环境。我的要求是拥有这样一种功能：如果我传递用户名或SPN名称，它将为我提供所有azure资源（从管理组到azure资源），该用户/SPN可以访问这些资源，以及该资源的访问权限（读卡器/数据读卡器等）。 主要的问题是-我也想要PIM角色分配。有办法得到它吗？ 探讨的选择 https://docs.microsoft.com/en-us/rest/api/aut
-
我在linux服务器上运行了一个Spring启动应用程序，它听了三个主题，起初，它运行得很好，但是几分钟后，我发现“（重新）加入组...”日志，然后只有两个主题被听了，另一个不能听，没有错误或警告日志可以找到，我不知道如何解决这个问题，只是不知道发生了什么 在第一，我想也许我的消费者配置是不正确的，我设置max.poll.interval.ms:5000，max.poll.records:50。
-
我有一个KafkaStream应用程序，以前工作得很好。现在无论我用新的应用程序id重新启动它多少次，它都不会开始消耗主题，我收到了这个日志： 当我将“日志级别”设置为“调试”时，应用程序会生成以下日志： 没有分配任务，如日志所示： 这是日志中显示领导和成员信息的部分： 我有很多应用程序正在运行，他们现在都经历了这种情况。我试着制作新的连接器，但仍然没有成功。但我可以通过kafka console