带主题模式的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。
-
我有一个XML文件，它用颜色和图案定义了应用程序的UI，但它们似乎都被themes.XML中的主题覆盖了。如何禁用此功能？ 示例： 此按钮： 应该具有黑色背景,因为它在round_button.xml中定义： 然而，它是紫色，颜色来自主题： 如何覆盖此主题？