腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Spring-Kafka
将
ConcurrentKafkaListenerContainerFactory
用于
多个
@
Kafkalistener
、
、
、
我正在使用
Spring-Kafka
框架实现来自Kafka主题的消息消费。我正在尝试理解我为我的卡夫卡监听器创建的
ConcurrentKafkaListenerContainerFactory
的一些用法。@
KafkaListener
运行良好,但不出所料,在我的场景中,我有
多个
独立的侦听器,分别侦听
多个
主题。我想知道我是否可以在我所有的监听器中重用
ConcurrentKafkaListenerContainerFactory
,或者我必须为每个@
KafkaListener
创建
浏览 187
提问于2020-04-26
得票数 1
回答已采纳
2
回答
Spring Kafka获得分配的分区
、
、
我
将
spring-kafka
1.3.2与
ConcurrentKafkaListenerContainerFactory
和@
KafkaListener
一起使用。
浏览 4
提问于2018-02-20
得票数 4
1
回答
@
KafkaListener
为每个监听器单独过滤逻辑
、
、
目前,我正在使用RecordFilterStrategy来完成此操作:
ConcurrentKafkaListenerContainerFactory
<String, GenericRecord> kafkaListenerContainerFactoryProject() { return true;
浏览 0
提问于2020-03-20
得票数 2
1
回答
如果设置spring.kafka.listener.ack-mode=time,是否会重试?或者在指定的ack-mode中重试工作?
Spring Kafka - How to Retry with @
KafkaListener
spring-kafka
SeekToCurrentErrorHandler如果设置为spring.kafka.listener.ack-modeAutowiredprivate ConsumerFactory consumerFactory; @
KafkaListener
headerSourceId, syncKafkaFromId.getBy
浏览 78
提问于2019-02-25
得票数 0
回答已采纳
2
回答
application.yml中正确的Springboot -Kafka参数是什么?
、
、
其次,在此块中是否存在由
KafkaListener
内部启动的
多个
线程 @
KafkaListener
(id = "instance1", groupId = "${spring.kafka.consumer.group-id
浏览 55
提问于2021-08-05
得票数 0
回答已采纳
1
回答
使用springboot在KafkaConsumer中反序列化kafka消息
、
、
、
我有一个springboot应用程序,监听卡夫卡消息,并将它们转换为对象 @
KafkaListener
(topics = "test", groupId = "group_id")public void consume(Hostel hostel) throws IOException
浏览 25
提问于2020-03-30
得票数 1
回答已采纳
1
回答
使用RetryListener获取org.springframework.retry.TerminatedRetryException
我正在使用
spring-kafka
2.2.8.RELEASE和@
KafkaListener
注释来创建消费者,下面是我的消费者配置代码。@Bean
ConcurrentKafkaListenerContainerFactory
<String, Object> factory
浏览 29
提问于2020-03-10
得票数 0
回答已采纳
1
回答
Spring Boot向Kafka JsonDeserializer注入ObjectMapper
、
、
、
、
我想把杰克逊的ObjectMapper注入到JsonDeserializer中,
用于
卡夫卡的ConsumerFactory。我已经做了这篇文章中提到的事情: 然而,当我在不同的主题上有
多个
@
KafkaListener
时,
ConcurrentKafkaListenerContainerFactory
使用属性映射来初始化ConsumerFactory而不是传递给
ConcurrentKafkaListenerContainerFactory
.setConsumerFactory()的实例来构造Concurre
浏览 3
提问于2019-03-06
得票数 1
1
回答
使用显式BatchAcknowledgingMessageListener引发异常时,SeekToCurrentBatchLogErrorHandler.handle不是被调用的异常
、
、
使用
Spring-kafka
2.2.7。如果在创建显式SeekToCurrentBatchLogErrorHandler (未加注释的
KafkaListener
)时引发异常,则不调用BatchAcknowledgingMessageListener这是否适
用于
显式BatchAcknowledgingMessageListener?() {
浏览 98
提问于2019-12-24
得票数 0
2
回答
引导代理不
用于
从主题中使用
、
、
pom.xml <groupId>org.springframework.kafka</groupId> } public
ConcurrentKafkaListenerContainerFa
浏览 7
提问于2021-06-08
得票数 1
回答已采纳
3
回答
多个
消费者如何在spring boot Kafka中收听
多个
主题?
、
、
当有
多个
消费者时,我无法收听kafka主题(我的案例2主题)。在下面示例中,我有两个消费者工厂,它将接受两个不同的JSON消息(一个是用户类型,另一个是事件类型)。这两条消息都发布到不同的主题。<String, User> kafkaListenerContainerFactory() { return factory;}@
KafkaListener
(topics = &qu
浏览 0
提问于2018-08-11
得票数 4
回答已采纳
3
回答
如何为@
KafkaListener
编写单元测试?
、
、
我想知道是否可以使用
spring-kafka
和spring-kafka-test为@
KafkaListener
编写单元测试。 @Autowired
ConcurrentK
浏览 3
提问于2018-10-12
得票数 11
1
回答
如何用Spring实现用户线程安全
<String, Object> kafkaListenerContainerFactory() { factory.setConsumerFactory@
KafkaListener
(topics = "TEST_TOPIC1"
浏览 4
提问于2020-02-21
得票数 0
回答已采纳
1
回答
为@
KafkaListener
创建元注释
、
我正在尝试基于@
KafkaListener
注释创建自定义元注释,但是
spring-kafka
抛出了一个错误。ElementType.METHOD, ElementType.ANNOTATION_TYPE})@Documented @AliasFor(annotation =
KafkaListener
.class, attribute = &quo
浏览 0
提问于2017-12-13
得票数 1
1
回答
将
默认容器工厂bean从kafkaListenerContainerFactory更改为我的自定义容器工厂
、
、
、
如果我们键入->代码示例public void listen(String data, Acknowledgment
浏览 2
提问于2020-01-28
得票数 4
2
回答
如何在Spring Kafka中关闭offsets提交,以便在本地存储offsets?
、
我想使用Spring Kafka
将
事件处理到本地数据库中,并将偏移量存储在数据库本身中,如“在Kafka之外存储偏移量”下的https://kafka.apache.org/25/javadoc/index.htmlSpring Kafka (带有
KafkaListener
)似乎总是提交偏移量(因此需要group.id),有没有办法完全禁用提交,允许在没有组的情况下进行侦听?
浏览 46
提问于2020-07-03
得票数 1
回答已采纳
2
回答
在
spring-kafka
中禁用连接和消费者创建
、
、
、
* */ private String url;
ConcurrentKafkaListenerContainerFactory
<String, String>
浏览 42
提问于2019-08-12
得票数 1
1
回答
Spring Kafka -Consumer seek感知方法未调用
、
使用
Spring-kafka
: 1.1.6版本。java.util.Map;import org.springframework.kafka.annotation.
KafkaListener
org.springframework.stereotype.Component; public class Consumer implements ConsumerSeekAware { @
KafkaListener
&
浏览 0
提问于2017-09-20
得票数 5
2
回答
Kafka Kstream和Spring @
KafkaListener
有什么不同?
、
Spring Kafka注解@
KafkaListener
具有相同的功能。例如,我尝试过。在这里,我们也会监听一个主题,并在发布内容时对其进行处理。 所以我很好奇地想知道1.这2个有什么不同?
浏览 5
提问于2018-01-18
得票数 1
1
回答
Kafka:不同主题的不同反序列化器
、
、
、
目前,我正在使用Spring和@
KafkaListener
注释从不同的Kafka主题中获取信息。 所有主题当前都包含Avro格式的消息(我使用的是KafkaAvroDeserializer)。
浏览 5
提问于2022-10-18
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
Kafka消息队列学习进阶(四)-优化(配置/代码/集群
SpringBoot整合Kafka
kafka实战演练,欲走大数据之路的台阶打造,通往的必经之路
SpringBoot Kafka 整合使用
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券