腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Kafka
spring
监听器
headers
上
的
spring
验证
java
、
spring
、
apache-kafka
、
spring-kafka
我尝试在@KafkaListener方法
上
使用
spring
验证
注释。我尝试了以下几种方法: @Componentpublic class Consumer { public String consume(@P
浏览 73
提问于2021-11-22
得票数 0
回答已采纳
1
回答
春云探测不同轨迹ID与卡夫卡
的
集成
spring
、
spring-boot
、
spring-cloud
、
spring-cloud-sleuth
我使用
Kafka
实现微服务之间
的
Asyng调用,使用
Spring
进行日志记录。日志记录是正常
的
,但是当有消息从Microservice1到Microservice2时,日志记录
的
消息具有不同
的
跟踪ID。难道他们不需要有相同
的
追踪Id但有不同
的
SpanId吗?有没有特殊
的
配置?
浏览 2
提问于2016-12-02
得票数 4
回答已采纳
2
回答
Spring
云流:标头
kafka
_acknowledgment值为空
spring-boot
、
spring-integration
、
spring-cloud-stream
、
spring-kafka
根据应用程序中消息处理
的
状态,我试图控制对卡夫卡主题
的
偏移提交。如果消息成功,则可以提交偏移量。为此,我正在尝试获取方法中
的
标头,如果是这样,则可以手动确认该消息。: defaultCandidate: true
spring
:
kafka
: brokers:
浏览 0
提问于2018-07-03
得票数 0
回答已采纳
2
回答
无法追踪弹簧云流侦听器与弹簧云侦查
spring
、
trace
、
spring-cloud-stream
、
spring-cloud-sleuth
我有两个非常简单
的
春云流应用程序。Service3,消息生产者,通过绑定器-卡夫卡向消费者Service4发送消息。 我用春云雪橇来追踪它们之间
的
跨度。但是在zipkin服务器中,只有Service3中
的
spans可用。Service4没有span显示。:
spring
-boot-starter-thymeleaf') compile('org.springframework.cloud:
spring
-cloud-starter-sleuth') //:<e
浏览 9
提问于2017-02-22
得票数 0
1
回答
无法使用
spring
云流
kafka
发送自定义标头
spring-boot
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我有两个用Java编写
的
微服务,使用
Spring
。,通过,在它们之间发送消息。我需要发送一个自定义头,但到目前为止没有成功。我在互联网和
Spring
上
已经阅读和尝试了大多数东西。任何帮助都将是wellcome binder:我也尝试过使用
headers
: "EVENT_ID" 以下
浏览 5
提问于2020-10-29
得票数 0
1
回答
Spring
cloud stream
kafka
avro反序列化
avro
、
spring-cloud-stream
、
spring-kafka
我正在编写一个使用Avro消息
的
spring
云流接收器应用程序。我试图让应用程序使用这些消息,但是我得到了以下错误。GenericMessage [payload=byte[304],
headers
={
kafka
_offset=42898134,
kafka
_consumer=org.apache.
kafka
.clients.consumer.KafkaConsumer=0,
kafka
_receivedTopic=*****,
kafka
_rece
浏览 1
提问于2018-09-19
得票数 1
1
回答
Spring
Cloud Bus事件( RemoteApplicationEvent )未发布到
Kafka
apache-kafka
、
spring-cloud-stream
、
spring-cloud-bus
我正在使用
spring
cloud bus将事件发布到
kafka
,以便其他实例可以监听相同
的
事件。事件正在被触发,但未发布到
kafka
。artifactId><dependency> <artifactId>
spring
-cloud-stream-binder-
kafka</em
浏览 3
提问于2019-07-24
得票数 1
1
回答
Spring
Kafka
producer默认保证发货吗?
spring-boot
、
spring-kafka
我想知道
spring
boot内部
的
spring
kafka
Producer是否保证交付。 有人知道如果某个随机
监听器
无法接收消息会发生什么情况吗?
spring
kafka
是否会重试发送消息?
浏览 0
提问于2019-05-29
得票数 0
1
回答
重启
Spring
应用程序后,KafkaListener无法接收消息
java
、
spring-boot
、
apache-kafka
、
docker-compose
、
spring-kafka
我有一个带有
Kafka
应用程序
的
Springboot,我
的
Kafka
集群从docker文件开始。但是,如果
Kafka
集群保持启动,但是
Spring
应用程序重新启动,则无法接收任何消息(函数正常工作)。属性文件:
spring
.
kafka
.bootstrap-servers=localhost:29092,localhost:39092
spring
.
kafka
.listener.a
浏览 8
提问于2022-05-31
得票数 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
2
回答
在
Spring
中如何使用@Configuration属性前缀和虚线属性来映射属性文件?
java
、
spring
、
configurationproperties
我有一组属性如下:
spring
.
kafka
.producer.edwh.properties.enable.idempotence=true
spring
.
kafka
.producer.edwh.transaction-id-prefix=slv
s
浏览 32
提问于2020-03-13
得票数 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
回答
在
Spring
中使用@Gateway -Integration-
Kafka
java
、
spring
、
apache-kafka
、
spring-integration
使用
Spring
-Integration-
Kafka
,我们仍然可以使用@MessagingGateway和@Gateway。= {@GatewayHeader(name = "
kafka
_topic", value ="requestTopic"))}@Bean @ServiceActivator(inputChannel = "requestChannel
浏览 0
提问于2018-03-19
得票数 1
回答已采纳
2
回答
用弹簧云流实现
kafka
的
自动提交
java
、
spring-boot
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
根据
spring
云文档,它应该使用autoCommitOffset 来完成。
spring
.cloud.stream.
kafka
.binder.brokers=${
KAFKA
_BROKER_LIST}
spring
.cloud.stream.default.contentType=application
浏览 7
提问于2020-05-14
得票数 1
回答已采纳
1
回答
Spring
-由于解析错误,未调用
Kafka
使用者
的
侦听器方法
spring-boot
、
spring-kafka
我正在尝试使用
Kafka
-
Spring
(
spring
-boot)实现一个
Kafka
消费者。我使用生产者发送了一条消息,但是
Spring
抛出了一个异常,并且由于这个异常,我
的
侦听器方法没有被调用。下面是我
的
监听器
方法:public class KafkaExchangeApi { priv
浏览 0
提问于2020-09-10
得票数 1
1
回答
kafka
向所有具有相同group.id
的
消费者发送消息
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
、
spring-kafka
默认情况下,
Kafka
会将来自某个主题
的
消息发送到所有消费者组。 在我
的
例子中,我有一些需要重新调整
的
微服务。假设我们每一个都有三个实例。 我有一个服务,它为每个微服务提供必要
的
数据。该服务正在发布所需
的
数据,但问题是,在发布消息时,每个微应用程序只有一个实例会被初始化。 我需要找到一种方法将数据发送到每个微服务
的
所有实例。这是必需元数据。我不知道如何获得此行为,也不能更改group.id,因为这样服务将使用相同
的
消息两次。
浏览 71
提问于2019-01-14
得票数 1
2
回答
无法为
Kafka
连接REST配置SSL
rest
、
ssl
、
apache-kafka
、
apache-kafka-connect
我试图为
Kafka
配置SSL (2.11-2.1.0)。因为我知道keystore中
的
密码是绝对正确
的
,所以我钻研了源代码,并开始调试。最后,我发现无论是普通
的
ssl.*还是前缀
的
listeners.https.ssl.*配置都没有被考虑在内,这使得目前不可能为
Kafka
配置SSL。否则,如果我们有无前缀
的
ssl.属性,它们也不会返回,因为values字段只包含来自同一个WorkerConfig
的
已知属性(values是的结果)。我是不是遗漏了什么,是
浏览 1
提问于2019-03-18
得票数 2
4
回答
春季卡夫卡制作人没有发送给卡夫卡1.0.0 (魔术v1不支持记录标题)
spring
、
spring-boot
、
apache-kafka
、
docker-compose
、
spring-kafka
现在我试着通过
spring
-
kafka
:2.1.0.RELEASE连接卡夫卡o.a.
kafka
.common.utils.AppInfoParser:
Kafka
version : 1.0.0java.lang.I
浏览 0
提问于2017-12-23
得票数 12
回答已采纳
1
回答
Springboot
kafka
消费者没有接踵而至
的
消息已经收到消息。
apache-kafka
、
kafka-consumer-api
、
spring-kafka
、
spring-cloud-stream-binder-kafka
我是卡夫卡
的
新手,我想要帮助他们都是消费者
spring
.cloud.stream.
kafka
.binder.
headers
=type
浏览 0
提问于2021-07-06
得票数 1
回答已采纳
3
回答
如何使用
Spring
cloud stream访问受密码保护
的
confluent模式注册服务器?
apache-kafka
、
avro
、
spring-cloud-stream
、
confluent-schema-registry
、
aiven
我正在使用
spring
cloud stream和使用confluent's schema registry
的
Aiven
的
模式注册表。Aiven
的
模式注册表使用密码保护。"USER_INFO"); props.put("basic.auth.user.info", "avnadmin:schema-reg-password"); 当我只使用vanilla java
的
kafka
驱动时,一切都很好,但是如果我使用
浏览 21
提问于2019-04-16
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Boot:在Azure上的部署
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
Springboot+kafka 实践
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
Github 上 Star 最多的个人 Spring Boot 开源学习项目
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券