我想使用@KafkaListener，并将消费者组建立在附加主题的名称上，但使用的是主题模式。具有单个主题的示例 @KafkaListener( topic= "tenant15",
groupId = "my_group_tenant15") 我想用topicPattern
浏览 86提问于2021-10-05得票数 0
回答已采纳
1回答
我有@KafkaListener： public void onMessage(Message<String目前，我正在从Message读取这个头值，然后根据标头值调用逻辑的其余部分。是否有任何方法来创建三个@KafkaListener，其中每个@KafkaListener将使用由某些标准过滤的消息--对于我的</em
浏览 2提问于2022-06-09得票数 0
回答已采纳
1回答
我正在开发 + spring和java api。面临着非常恼人的问题。我使用了kafka主题模式方法来监听多个客户端的事件。以下是kafka消费者的代码，其中topic名称来自配置文件，后缀具有硬编码值。.*.v1后缀值为- .cqrs.customer topicPattern = "${${service}.topic}" + Constants.suff
浏览 17提问于2020-02-24得票数 0
我试图使用相同的@KafkaListener实现来消费来自Kafka的多个主题，但我希望每个主题都有一个消费者(每个消费者只有一个分区)。为了实现这一点，我创建了一个包含topicPattern="topic1|topic2|topic3"的@KafkaListener、一个包含并发3的ConcurrentKafkaListenerContainerFactory和</e
浏览 2提问于2017-07-28得票数 1
2回答
我使用注释@KafkaListener来使用我的应用程序上的主题。我的问题是，如果我在kafka中创建了一个新的主题，但我的消费者已经在运行，那么消费者似乎不会选择新的主题，即使它与我正在使用的topicPattern相匹配。是否有一种定期“刷新”订阅主题的方法，以便在运行中的使用者上获取新<
浏览 2提问于2017-07-17得票数 3
回答已采纳
我让@KafkaListener使用带有regex的topicPattern (foo.*)，但现在我想将侦听器分配给所有匹配主题的所有分区。https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#tip-assign-all-parts对我没有真正的帮助，因为我不知道主题名称
浏览 170提问于2020-10-07得票数 0
回答已采纳
1回答
我有一个场景，其中有多个Kafka主题(每个主题都有一个分区)和一个消费者组来消费记录。我在消费者组中使用一个模式匹配的消费者，它匹配所有主题，从而消费所有主题中的所有记录。我现在想扩大规模，让多个消费者(在同一个消费者组中)收听所有主题。然而，这似乎不起作用，因为所有记录都只由组中的
浏览 1提问于2020-01-09得票数 2
1回答
我有一个带有@KafkaListener注释的方法public void listen(String message) {System.out.println("Received Message: " + message);
当我不设置并发属性时，Spring是否会创建一个使用者实例，一个kafka侦听器容器，属于在使用者工厂中指定的组如果我将并发性更改为3，那么spring是否会创建3个<
浏览 5提问于2018-01-14得票数 3
回答已采纳
我一直在使用@KafkaListener作为一类Kafka事件消费者，它必须具有唯一的ids，并且每个事件使用者都必须有一个具有非常特殊名称的单独组。toString()}") .... }
该应用程序相当大，因此许多消费者订阅了相同的主题，但总的来说，大约有500-600个<
浏览 10提问于2021-05-31得票数 0
1回答
Kafka多消费者监听多个主题
、、、、
我们正在开发一个应用程序，在该应用程序中，我们希望在Kafka中收听多个主题。所有主题都有一个单独的分区。所有的主题名称都有一个共同的前缀，比如“topicPattern -x”，"test-y“，所以我们可以使用spring。我们想要编写一个使用regexp模式监听所有主题的java spring使用者。我们的想法是，我们可以运行同一消费者(属于同一组)的</e
浏览 2提问于2018-03-22得票数 0
我正在构建一个使用spring引导的web应用程序，现在我有了接收实时通知的要求。我计划使用apache作为消息代理。这样的要求是，有不同角色的用户，根据角色，他们应该收到其他用户正在做的事情的通知。
我确实建立了一个单一的生产者和消费者，作为一个消费者，我可以接收发布到一个主题上的信息，比如topic1。我陷入困境的部分是，我可以让多个用户收听
浏览 3提问于2020-02-10得票数 1
回答已采纳
1回答
嗨，我有一个卡夫卡消费者(使用春季卡夫卡依赖)，听多个主题。假设我有三个主题，分别是topicA、topicB和topicC。在我的应用程序中，我在一个使用者中使用了所有三个主题，如下所示。@KafkaListener(topics = "topicA,topicB,topicC", groupId = "myGroup", concurrency="3")
我的主题有分区，
浏览 1提问于2022-09-14得票数 0
回答已采纳
我使用spring 2.1.7.RELEASE和spring 2.2.7.RELEASE.And，我使用@KafkaListener注释来创建消费者，并且我使用了消费者的所有默认设置。根据apache文档，“max.poll.records”的默认值为500。
在这里，我试图理解，spring是如何处理记录处理的。现在我的问题是，如果我们已经在一个主题A上发布了500条消息，并且有一个消费者(使用@
浏览 2提问于2020-02-21得票数 2
回答已采纳
1回答
主题名称: testTopic邮件总数#在主题:1分区:8消费者团体名称: Consumer1举个例子，这个使用者持有一条消息MSG-1，而我的处理器正在处理该消息(我有意将20毫秒作为线程等待)。所以，没有提交MSG-1回到主题
浏览 0提问于2019-06-14得票数 0
1回答
所有的消费者都在听同一个话题，并且都是同一个消费者群体的一部分。我们使用@KafkaListener注释并使用初始化的containerFactory名称设置它的ConcurrentKafkaListenerContainerFactory属性，并设置它的主题属性。问题
当一个主题在一两天内没有收到任何发布给它的消息时，所有的使用者都会被从使用者组中删除。我找不到发生这种事
浏览 0提问于2021-01-11得票数 0
回答已采纳
1回答
我有批@KafkaListener，如下所示： topicPattern = "ProductTopic", 在这种情况下，最好的方法是什么？我应该使用RetryTopicConfigurer来配置这样的逻辑吗？如何手动定义重试和死信<
浏览 7提问于2022-06-15得票数 0
我使用@KafkaListener来消费来自kafka主题，我有一个应用程序逻辑来处理不同消费者组中的多个消费者的每个记录。 现在我的问题陈述是，-I必须将使用的消息发送到第三方rest端点。如果消息发送到rest-end点失败，则不应提交偏移量，需要根据可配置的次数重试发送消息。在可配置的重试次数后，如果发送消息失败。我需要记录异常的原因并提交偏移量。sprin
浏览 83提问于2019-02-12得票数 2
回答已采纳
我有两个Kafka主题A和B。我希望每次我的消费者启动时，它都会先转到主题A。Topic A包含有关topic B的信息，我将根据该信息从topic B获取数据。所以基本上，我需要先阅读主题A，然后再转到主题B，每次程序重新启动时，我只需要这样做一次。我能想到的东西如下：或者：
@<e
浏览 21提问于2020-05-28得票数 0
回答已采纳
我是新来的春天卡夫卡。我有一个微服务，它发送消息与kafka密钥，这是一个用户定义的对象。假设消息是由密钥myKey发送的。我想在监听程序中创建一个新的扩展密钥，如下所示：
@KafkaListener(groupId = Bindings.CONSUMER_G
浏览 1提问于2019-09-26得票数 2
1回答
我使用的是Kafka和Spring Listener。下面是一段代码。在过去，我们发布了超过10万条消息来测试主题，系统似乎工作得很好。但几天前，我更改了消费者的groupId。在那之后，这个新的消费者尝试从start开始处理所有消息，这需要很多时间。但过了一段时间可能会被(10秒)经纪人踢出消费者。所以结果没有kafka注册来监听消息。@KafkaListener(
topicPattern
浏览 0提问于2020-08-06得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
