腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1120)
视频
沙龙
1
回答
Spring
Kafka
监听器
线程
名
的
含义
?
java
、
spring
、
logback
、
spring-kafka
当我使用
spring
kafka
时,我注意到我
的
日志是这样
的
: 2021-01-16 17:07:25.795 [org.springframework.
kafka
.KafkaListenerEndpointContainer#0-8-C-1] WARN c.d.j.k.KafkaConsumer [listenerHomework:86] - no message 和我
的
logback编码器 <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}
浏览 130
提问于2021-01-16
得票数 0
1
回答
当自动缩放打开时,
Kafka
正在将协调器标记为已死
kubernetes
、
apache-kafka
、
spring-cloud-stream
、
spring-kafka
我们使用
Kafka
0.10.2运行Kubernetes集群。在集群中,我们有一个由10个副本组成
的
副本集,这些副本运行我们
的
一个服务,这些副本将一个主题作为一个消费者组进行消费。最近我们打开了这个副本集
的
自动缩放功能,因此它可以根据CPU消耗增加或减少pod
的
数量。org.apache.
kafka
.clients.consumer.CommitFailedExce
浏览 1
提问于2018-11-28
得票数 1
2
回答
如何理解春季卡夫卡中
的
消费者和听众
spring
、
apache-kafka
、
spring-kafka
我在多
线程
feature(ConcurrentKafkaListenerContainerFactory),中使用了
spring
,我发现了两种类型
的
线程
名
: 1. #0-1-
kafka
-this 12.0-1-
kafka
-listener-3。那么,我如何理解这两种
线程
呢?他们之间有什么关系?提前感谢!
浏览 4
提问于2017-05-18
得票数 3
回答已采纳
2
回答
Spring
@KafkaListener和并发
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
我正在使用
spring
boot +
spring
@KafkaListener。我期望
的
行为是:我
的
kafka
侦听器在10个
线程
中读取消息。因此,如果其中一个
线程
挂起,其他消息将继续读取和处理消息。@Bean
spring
.
kafka
.listener.concurren
浏览 0
提问于2019-11-16
得票数 6
回答已采纳
1
回答
一个API只定义一次,有没有办法启动
Kafka
监听器
的
多个
线程
?
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
我有一个卡夫卡
监听器
,它处于停止状态。我用一个API调用来启动它,但它会因为一些内部条件而停止。当我多次点击API时,我希望它
的
多个
线程
独立运行。有没有可能发生这种情况?我正在使用
Spring
Kafka
和SpringBoot。
浏览 11
提问于2021-04-21
得票数 1
1
回答
Spring
Kafka
producer默认保证发货吗?
spring-boot
、
spring-kafka
我想知道
spring
boot内部
的
spring
kafka
Producer是否保证交付。 有人知道如果某个随机
监听器
无法接收消息会发生什么情况吗?
spring
kafka
是否会重试发送消息?
浏览 0
提问于2019-05-29
得票数 0
1
回答
如何在
Kafka
listener (
spring
-
kafka
)未初始化
的
情况下启动
spring
应用
spring
、
apache-kafka
、
spring-kafka
我正在开发一个使用
spring
-
kafka
的
Kafka
监听器
的
应用程序。我面临
的
问题是,当
Kafka
listener没有打开(各种原因,比如
Kafka
服务器没有打开或关闭)时,
spring
上下文初始化会失败。如何确保我
的
应用程序是独立
的
。 有谁能帮帮忙。
浏览 44
提问于2017-09-10
得票数 4
回答已采纳
1
回答
春季卡夫卡ConcurrentMessageListenerContainer使用者中
的
线程
名称约定
spring-kafka
我使用
spring
从主题中消费,我们使用
的
是ConcurrentMessageListenerContainer。下面是我
的
application.yml
spring
: listener: consumer: topic: CONSUMER-TOPIC在日志中,我们可以看到
线程
名
被打印为测试-使用者组
浏览 1
提问于2021-10-05
得票数 0
回答已采纳
1
回答
如何重用
Spring
Kafka
代码来设置多个
监听器
?
java
、
spring-boot
、
spring-kafka
如果我
的
应用程序只有一个
监听器
,情况就非常简单: 我将配置
spring
.
kafka
.*,
Spring
Boot会将配置解析为KafkaPropeties,并初始化所有需要
的
bean。但是我有两个
监听器
,假设一个将记录保存到文件,另一个保存到数据库。我希望尽可能多地重用
Spring
Boot约定。 我想配置file.
kafka
.*和db.
kafka
.*,将这些配置解析为2个KafkaProperties beans:
浏览 59
提问于2020-12-19
得票数 1
3
回答
spring
boot
kafka
中基于消费者记录密钥
的
多消费者
java
、
apache-kafka
、
spring-kafka
我想根据消费者记录密钥列出
kafka
主题。现在我有了消费者,并且基于我正在处理记录
的
条件 containerFactory = "kafkaListenerStringContainerFactory
浏览 4
提问于2020-01-09
得票数 0
1
回答
如何在springboot中为每个主题动态创建单独
的
Kafka
监听器
?
spring
、
spring-mvc
、
spring-boot
、
kafka-consumer-api
、
spring-kafka
我是
Spring
和
Kafka
的
新手。我正在做一个使用SpringBoot-
kafka
的
用例,允许用户在运行时创建
kafka
主题。
spring
应用程序期望在运行时以编程方式订阅这些主题。到目前为止,我所知道
的
是,
Kafka
listener是设计时,因此在启动之前需要指定主题。有没有办法在SpringBoot-
Kafka
集成中动态订阅
kafka
主题?已引用此 我计划实现的当前方法是,不要使用
S
浏览 0
提问于2017-01-08
得票数 11
1
回答
Kafka
-在Consumer中反序列化对象
java
、
apache-kafka
、
spring-kafka
我们正在考虑在我们
的
消息传递中使用
Kafka
,我们
的
应用程序是使用
Spring
开发
的
。因此,我们计划使用
spring
-
kafka
。
kafka
: producer: key-serializer: org.springframework.
kafka
.sup
浏览 0
提问于2018-06-29
得票数 5
回答已采纳
1
回答
kafka
向所有具有相同group.id
的
消费者发送消息
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
、
spring-kafka
默认情况下,
Kafka
会将来自某个主题
的
消息发送到所有消费者组。 在我
的
例子中,我有一些需要重新调整
的
微服务。假设我们每一个都有三个实例。 我有一个服务,它为每个微服务提供必要
的
数据。该服务正在发布所需
的
数据,但问题是,在发布消息时,每个微应用程序只有一个实例会被初始化。 我需要找到一种方法将数据发送到每个微服务
的
所有实例。这是必需元数据。我不知道如何获得此行为,也不能更改group.id,因为这样服务将使用相同
的
消息两次。
浏览 71
提问于2019-01-14
得票数 1
1
回答
禁用特定
Spring
Boot测试
的
Kafka
侦听器
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
如何在
Spring
Boot (2.2+)和
Spring
Kafka
(2.4+)应用程序
的
@SpringBootTest测试中禁用@KafkaListener实例?目标是在特定测试中禁用
Kafka
侦听器,以便在不启动嵌入式
Kafka
代理
的
情况下运行此类测试。
浏览 39
提问于2020-01-25
得票数 3
回答已采纳
2
回答
Spring
Kafka
在
监听器
中按条件丢弃消息
spring-boot
、
apache-kafka
、
spring-kafka
在我
的
Spring
Boot/
Kafka
项目中,我有以下
监听器
:} 在
监听器
内部,我需要根据我<em
浏览 3
提问于2018-08-06
得票数 0
回答已采纳
1
回答
Kafka
自动提交对较慢
的
事务不起作用
apache-kafka
、
kafka-consumer-api
、
spring-kafka
使用
Spring
Boot
Kafka
-v 2.2.1.RELEASE (使用
kafka
-clients.jar v 2.3.1) 我正在为我
的
Kafka
代理使用confluent v5.1.2。我有一个基于
spring
的
监听器
类(@KafkaListener),每个消息处理大约需要6-7秒,因为它是一个资源密集型操作。我在这里注意到
的
是,
监听器
从未提交过偏移量,并且延迟永久地保持为"550“。 正因为如
浏览 20
提问于2020-01-23
得票数 0
1
回答
无法让卡夫卡游戏机生产商或消费者工作
amazon-ec2
、
apache-kafka
当我在本地
的
机器上把卡夫卡旋转起来
的
时候,我就能让卡夫卡工作得很好。但是,当我试图让它在AWS实例上工作时,似乎没有什么是正确
的
。我试着旋转我自己
的
服务器,就像我在本地旋转动物园管理员和卡夫卡一样 bin/
kafka
-server-start.sh config
浏览 2
提问于2016-10-20
得票数 2
回答已采纳
1
回答
DLT消息消耗
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-kafka
我们使用
的
是
Spring
kafka
2.7非阻塞重试机制。在
Spring
Kafka
重试机制中,
kafka
监听器
消费来自main topic、Retry Topic和DLT topic
的
消息,我们只希望
监听器
消费来自main和retry topic
的
消息。有没有一种简单
的
设置方法? 因为我们不希望同一个消费者处理DLT消息。DLT也会被另一个进程使用,以发送请求
的
通知。
浏览 1
提问于2021-10-14
得票数 0
1
回答
Stream -有办法定制StreamThread
线程
名
吗?
java
、
spring-boot
、
spring-kafka
、
spring-cloud-stream
我在当前
的
项目中使用Stream (
Kafka
作为绑定程序),StreamThread
的
默认
线程
名
会让我感到困扰,因为它很长。-1 使用这个长
线程
名
,很难看到实际
的
日志消息。想知道是否有方法配置
线程
名
。编辑:通过在
spring
.
kafka
.client-id中添加application.properties来解决这个问题。有了client-id,KafkaStreams将使用用户定
浏览 8
提问于2022-04-27
得票数 0
回答已采纳
2
回答
如何在错误发生时停止使用
kafka
的
消息,并在春季启动一段时间后重新开始使用
spring-boot
、
apache-kafka
、
spring-kafka
我有一个
spring
引导应用程序,我正在使用
kafka
主题
的
消息,并将消息存储在DB中。我有一个处理DB fail
的
要求,如果DB关闭,则不应该提交该消息,并在一段时间后暂停消费消息,然后
监听器
可以再次开始使用消息。做这件事
的
更好
的
方法是什么。i am using
spring
-
kafka
:2.2.8.RELEASE which is internally using
kafka
2.0.1
浏览 9
提问于2020-06-01
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
Springboot+kafka 实践
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
直击Kafka的心脏——控制器
如何做到业务优雅解耦?
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券