有没有人能在spring boot kafka中给我举个小例子，我们可以在一个监听器类中使用多个主题。
浏览 2提问于2018-09-18得票数 1
@EnableKafkapublic class KafkaConsumerConfigPipelineMessage { private String bootstrapAddress;
priv
浏览 143提问于2021-09-27得票数 0
我正在使用Spring-Kafka框架实现来自Kafka主题的消息消费。我正在尝试理解我为我的卡夫卡监听器创建的ConcurrentKafkaListenerContainerFactory的一些用法。@KafkaListener运行良好，但不出所料，在我的场景中，我有多个独立的侦听器，分别侦听多个主题。我想知道我是否可以在我所有的监听器中重用ConcurrentKafkaListenerContainerFactory，或者我必须为每个@KafkaListener创建
浏览 187提问于2020-04-26得票数 1
回答已采纳
我有一个kafka监听器，它正确地接收数据，但EventData ss = consumerRecord.value()提供ClassCastException。: java.lang.String cannot be cast to com.betstars.betsyncadapter.app.kafka.message.EventData
at com.betstars.betsyncadapter.app.kafka.message.KafkaMessageListenerForEvent
浏览 82提问于2018-02-06得票数 0
默认情况下，Kafka会将来自某个主题的消息发送到所有消费者组。 在我的例子中，我有一些需要重新调整的微服务。假设我们每一个都有三个实例。 我有一个服务，它为每个微服务提供必要的数据。
浏览 71提问于2019-01-14得票数 1
我正在遵循一个简单的指南文档来使用Kafka streams和spring boot (Spring guide) 我很清楚如何传入和传出消息，然后在中间我能够进行一些处理，替换@KafkaListener{KAFKA_CONSUMER_CONCURRENCY:3} destination: my-topic binder: org.apache.kafka.common.serializati
浏览 34提问于2019-01-29得票数 0
我正在使用spring框架来实现一个kafka侦听器。目前我正在读一个话题。但是，根据特定的需求，我被问到一种实现监听器的方法，它将从某个kafka主题中读取特定的分区。请您帮助我了解如何通过spring和java实现这一点。
提前谢谢。
浏览 2提问于2018-06-26得票数 3
回答已采纳
$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2361) ~[spring-kafka-2.7.0.jar$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2220) ~[spring-kafka-2.7.0$ListenerConsumer.invokeRecordListener(Kafk
浏览 33提问于2021-04-28得票数 1
回答已采纳
我想知道spring boot内部的spring kafka Producer是否保证交付。
有人知道如果某个随机监听器无法接收消息会发生什么情况吗？spring kafka是否会重试发送消息？
浏览 0提问于2019-05-29得票数 0
我的理解是，创建是为了与Kafka客户端API交互，后来创建项目是为了“构建与共享消息传递系统相连接的高度可伸缩的事件驱动的微服务”，该项目包括两个绑定程序，其中一个是允许与Kafka交互的绑定器。spring-cloud-stream-binder-kafka-streams需要以下两个依赖项。就是一个例子。'org
浏览 3提问于2021-11-10得票数 0
回答已采纳
2回答
我有两个服务(都是kotlin上的spring boot )。命名为“客户端”和“服务器”由于一些限制，我必须使用同步请求-回复模式与kafka。我的问题是我需要使用多个实体。意味着创建多个ReplyingKafkaTemplate，一个用于"FOO“，第二个用于"BAR”。= "kafkaListenerContainerFactoryForFoo", groupId = "\${spring.kafka.consumer.group-
浏览 16提问于2020-05-26得票数 0
我有一个卡夫卡监听器，它处于停止状态。我用一个API调用来启动它，但它会因为一些内部条件而停止。当我多次点击API时，我希望它的多个线程独立运行。有没有可能发生这种情况？我正在使用Spring Kafka和SpringBoot。
浏览 11提问于2021-04-21得票数 1
我正在开发一个使用spring-kafka的Kafka监听器的应用程序。我面临的问题是，当Kafka listener没有打开(各种原因，比如Kafka服务器没有打开或关闭)时，spring上下文初始化会失败。如何确保我的应用程序是独立的。
有谁能帮帮忙。
浏览 44提问于2017-09-10得票数 4
回答已采纳
我想根据消费者记录密钥列出kafka主题。//do some processing //do some processing有没有可能有多个消费者根据密钥收听同一个话题
浏览 4提问于2020-01-09得票数 0
如果我的应用程序只有一个监听器，情况就非常简单： 我将配置spring.kafka.*，Spring Boot会将配置解析为KafkaPropeties，并初始化所有需要的bean。但是我有两个监听器，假设一个将记录保存到文件，另一个保存到数据库。我希望尽可能多地重用Spring Boot约定。 我想配置file.kafka.*和db.kafka.*，将这些配置解析为2个KafkaProperties beans： @ConfigurationProp
浏览 59提问于2020-12-19得票数 1
. */ return ENCODER.encodeb) throws java.io.IOException { }
@Deprecated public java.lang.CharSequencepublic java.lang.Object get(int field
浏览 8提问于2017-10-20得票数 6
2回答
在尝试使用一个@StreamListener中的多个主题时，我遇到了一个spring引导流的问题。(KafkaTopicUtils.java:39) ~[spring-cloud-stream-binder-kafka-core-1.2.1.RELEASE.jar:1.2.1.RELEASE](KafkaTopicProvisioner.java:107) ~[spring-cloud-stream-binder-kafka-core-1.2.1.RE
浏览 4提问于2017-06-18得票数 5
回答已采纳
1回答
我们有一些使用编写的应用程序，并且有兴趣将后端从Kafka交换到Pulsar。Spring目前没有任何对Kafka的原生支持，但是pulsar似乎提供了使用Kafka API直接与pulsar通信()的能力。我想知道是否有人尝试在Spring cloud消息传递的上下文中使用这个Kafka-clients库的替代品。
浏览 12提问于2019-11-23得票数 3
云服务器
ICP备案
对象存储
云点播
智聆口语评测
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号