腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(760)
视频
沙龙
1
回答
Spring
cloud
Stream
Kafka
:
获取
processor.output
().
send
(
Message
)的
确认
;
apache-kafka
、
spring-cloud-stream
我想知道使用
spring
-
cloud
-
stream
写到
kafka
的
主题是否成功。public boolean writeToKafka(String emails) { return
processor.output
().
send
(
messag
浏览 10
提问于2019-02-20
得票数 1
回答已采纳
1
回答
@StreamListener没有收到
kafka
主题
的
消息
java
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
、
spring-kafka
spring
.
cloud
.
stream
.bindings.input.group=test<dependency> <artifa
浏览 1
提问于2018-04-05
得票数 1
回答已采纳
1
回答
如何正确创建消费者进行集成测试,以验证消息是否被推送到
kafka
?
java
、
spring-boot
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
, "MY_KEY").build(); } 我
的
测试包上有这个消费者:public哦,这是我对
kafka
的
applicaiton.properties配置:
spr
浏览 1
提问于2021-05-28
得票数 0
1
回答
Spring
Cloud
Stream
send
to
Kafka
错误控制处理
java
、
apache-kafka
、
spring-cloud-stream
如何捕获写入
Kafka
主题
的
错误?import org.springframework.
cloud
.
stream
.annotation.EnableBinding;import org.springframework.
cloud
.
stream
.messaging.Processor; import org.spring
浏览 0
提问于2016-11-06
得票数 1
2
回答
Spring
Cloud
Stream
Kafka
批量-手动提交整个批量
spring-kafka
、
spring-cloud-stream
我们使用
spring
cloud
streams Hoxton.SR4来消费来自
Kafka
topic
的
消息。我们已经启用了每次轮询
获取
2000条记录
的
spring
.
cloud
.
stream
.bindings..consumer.batch-mode=true,。我想知道是否有一种方法可以手动
确认
/提交整个批次。
浏览 264
提问于2020-12-10
得票数 0
1
回答
在发送avro消息时
获取
异常,异常是注册Avro模式
的
org.apache.
kafka
.common.errors.SerializationException:错误:
java
、
spring-boot
、
avro
、
spring-cloud-stream
、
confluent-schema-registry
=headers['
kafka
_messageKey']
spring
.
cloud
.
stream
.
kafka
.binder.producer-properties.key.serializer=org.apa
浏览 14
提问于2022-01-21
得票数 0
回答已采纳
1
回答
如何在
spring
云流中嵌入
kafka
创建单元测试
junit
、
apache-kafka
、
spring-cloud
、
spring-kafka
、
spring-cloud-stream
很抱歉这个问题太笼统了,但是有人提供了一些关于如何在嵌入
kafka
的
情况下执行生产者和消费者测试
的
教程或指南。我已经尝试了几个,但有几个版本
的
依赖项,没有一个实际有效=/ 我使用
的
是
spring
cloud
stream
kafka
。
浏览 2
提问于2017-04-11
得票数 5
回答已采纳
1
回答
Spring
Cloud
Stream
Kafka
绑定器无法使用密钥发布到DLQ
apache-kafka
、
spring-cloud-stream
spring
.
cloud
.
stream
.bindings.my-
message
-in.destination=my.
message
.destination
spring
.
cloud
.
stream
.bindings.my-
mes
浏览 30
提问于2019-03-23
得票数 0
回答已采纳
1
回答
StreamBridge不发送
确认
报头
spring-kafka
、
spring-cloud-stream-binder-kafka
KafkaTemplate正在发送
确认
头,但是当我们发送来自StreamBridge
的
消息时,
确认
将被发送。=application/json
spring
.
cloud
.
stream
.function.bindings.sink2=application
浏览 14
提问于2022-11-16
得票数 0
回答已采纳
2
回答
连接多个集群
spring
kafka
java
、
spring-kafka
我想从一个
kafka
集群消费消息并发布到另一个
kafka
集群。想知道如何使用
spring
-
kafka
进行配置吗?
浏览 72
提问于2021-01-08
得票数 2
回答已采纳
1
回答
春云流消费者没有阅读卡夫卡主题
的
信息
spring-boot
、
apache-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在尝试使用
spring
应用程序中
的
kafka
主题。= MessageBuilder.withPayload(log).build(); } pom.xml<groupId>org.springframework.
cloud
</groupId> <artifactId>
spring
-
cl
浏览 4
提问于2021-11-29
得票数 2
2
回答
Spring
Cloud
数据流DLQ配置不起作用
spring-cloud
、
spring-cloud-stream
、
spring-cloud-dataflow
下面是
Stream
的
定义以及我如何部署它 --
spring
.
cloud
.
stream
.bindings.input.consumer.headerMode=test-tran,app.log.
spring
.
cloud
.
stream
.bindings.input.destination
浏览 0
提问于2016-09-16
得票数 0
1
回答
用功能程序设计和流桥对消费者进行调查
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在使用与
kafka
经纪公司
的
春云流进行微服务互传。作为其中
的
一部分,
stream
bridge将用于发送消息,这是很好
的
。application.properties
spring
.
cloud
.
stream
.function.definition
spring
.
cl
浏览 7
提问于2022-03-10
得票数 0
回答已采纳
1
回答
使用StreamBridge实现
Stream
中
的
生产者回调
java
、
spring-cloud
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
、
spring-messaging
我想知道一种使用StreamBridge执行回调
的
方法,我想做一些类似于返回ListenableFuture
的
KafkaTemplate.
send
的
事情。弹簧云流是否可能使用
kafka
绑定发布一些事件,并使用像onSuccess和onFailure这样
的
回调?示例:producer.
send
(record, new callback { ... })
浏览 19
提问于2022-07-07
得票数 0
回答已采纳
1
回答
使用
Kafka
向Dlq
Spring
云流发送消息时出错
java
、
spring-boot
、
apache-kafka
、
spring-cloud-stream
=raw
spring
.
cloud
.
stream
.bindings.
kafka
.binder.defaultBrokerPort=9092
spring
.
cloud
.
stream
.bindings.
kafka
.binder.zkNod
浏览 2
提问于2018-04-13
得票数 0
回答已采纳
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</e
浏览 7
提问于2020-05-14
得票数 1
回答已采纳
1
回答
Kafka
错误处理:
Processor.output
().
send
(
message
,kafkaTimeoutInMS)总是返回true及其异步
error-handling
、
apache-kafka
、
messaging
、
spring-cloud-stream
可能这个问题已经被报告和解决了,.I没有找到解决方案和任何与此相关
的
开放问题,所以创建一个新
的
问题。我正在尝试处理向
kafka
主题发布数据时出现
的
错误。有了
kafka
spring
steam,我们就可以用这个来推动
kafka
if (
processor.output
().
send
(messsage , kafkaTimeoutInMS) && acknowledgmentfailed",
messa
浏览 1
提问于2018-10-12
得票数 1
1
回答
无法使用
spring
云流
kafka
发送自定义标头
spring-boot
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
spring
:
stream
: bindings:
spring
:
stream
: bindings: notifications:</
spring
-
cloud
-<em
浏览 5
提问于2020-10-29
得票数 0
1
回答
StreamBridge绑定,而不是自
Spring
3.1版本以来就不再推荐
的
EnableBinding和输出注释
java
、
spring
、
avro
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
=headers['partitionId']
spring
.
cloud
.
stream
.
kafka
.binder.configuration.security.protocol=SSL
spring
.
cloud
.
stream
.
kafka
.binder
浏览 8
提问于2022-03-08
得票数 1
1
回答
Spring
cloud
stream
kafka
avro反序列化
avro
、
spring-cloud-stream
、
spring-kafka
我正在编写一个使用Avro消息
的
spring
云流接收器应用程序。我试图让应用程序使用这些消息,但是我得到了以下错误。=0,
kafka
_receivedTopic=*****,
kafka
_receivedTimestamp=-1, contentType=avro/bytes}]
spring
.
cloud
.
stream
.bindings.input.destination=user_topic <em
浏览 1
提问于2018-09-19
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简介
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
Spring Cloud Stream简单入门
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
微服务架构开发实战:SpringCloudBus的设计原理
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券