腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5372)
视频
沙龙
1
回答
在
Spring
Cloud
Stream
中
使用
嵌入式
Kafka
进行
集成
测试
时
,
如何
立即
验证
消息
是否
被
确认
?
apache-kafka
、
integration-testing
、
spring-cloud-stream
、
spring-kafka-test
、
embedded-kafka
我们
使用
Spring
Cloud
Stream
Kafka
Binder (带项目反应堆
集成
,即Flux streams)和manual offset commits (即autoCommitOffset我们正在尝试编写一个与Embedded
Kafka
from
spring
-
kafka
-test的
集成
测试
,通过手动读取消费者组偏移量,
使用
admin client,
在</
浏览 15
提问于2019-07-01
得票数 1
回答已采纳
1
回答
Spring
Cloud
Stream
Kafka
绑定器autoCommitOnError=false出现意外行为
apache-kafka
、
stream
、
spring-cloud-stream
我
使用
的是
Spring
Boot2.1.1.RELEASE和
Spring
Cloud
Greenwich.RC2,
spring
-
cloud
-
stream
-binder-
kafka
的托管版本是2.1.0RC4
Kafka
主题中有20个分区,Kerberos用于身份
验证
(不确定这
是否
相关)。
Kafka
使用
者为它处理的每个
消息
调用一个web服务,如果we
浏览 29
提问于2019-03-18
得票数 2
1
回答
使用
spring
云流向错误通道发送错误
消息
spring-integration
、
spring-cloud-stream
、
spring-kafka
我正在
使用
spring
-
cloud
-
stream
:1.3.0开发
spring
启动应用程序。messages,
spring
-
cloud
-
stream
-binder-
kafka
:1.3.0.RELEASE.我
使用
spring
集成
dsl来拆分文件
中
的行,并
使用
beanio将行转换为json,要求将成功的json
消息
写入
kaf
浏览 2
提问于2017-10-19
得票数 1
2
回答
针对JmsTemplate的
Spring
Boot2.0
集成
测试
spring-boot
、
testing
、
integration-testing
、
solace
我有一个非常简单的MessageHandler类,多亏了
Spring
Boot,它在运行时只需要以下几行代码和配置: @Component <artifactId>solace-jms-
spring
-boot-parent</artifactId>
浏览 3
提问于2018-09-27
得票数 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的模式注册表
使用
密码保护。vanilla java的
kafka
驱动
时
,一切都很好,但是如果我
使用
Spring
cloud
stream
,我不知道
如何
注入这两个参数。目前,我将"basic.auth.us
浏览 21
提问于2019-04-16
得票数 2
回答已采纳
1
回答
如何
在
Spring
Cloud
Stream
中
使用
useNativeEncoding=true
测试
绑定
spring-kafka
、
spring-cloud-stream
我正在尝试
测试
一个配置了以下绑定的应用程序:
cloud
: bindings: accountSource:正常运行应用程序时,AbstractMessageChannel.interceptorList为空,向代理发送
消息
工作正常。在运行
测试
(
使用
spring
-
cloud
-
stream
-test-support绑定器)
时
,Ab
浏览 0
提问于2019-06-20
得票数 0
1
回答
如何
正确创建消费者
进行
集成
测试
,以
验证
消息
是否
被
推送到
kafka
?
java
、
spring-boot
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
我正在
使用
avro生成一个java类( Heartbeat ),并且我正在
使用
Spring
云
消息
处理器,以便通过此Heartbeat类将
消息
推送到
kafka
。CountDownLatch getLatch() { } return payload;现在,
在
我的实际
测试
类
中
我
如何
从
ka
浏览 1
提问于2021-05-28
得票数 0
2
回答
春云中的动物园管理员数据流保持断开
apache-kafka
、
apache-zookeeper
、
spring-cloud-dataflow
它很好地启动,但是当尝试部署任何流
时
,我会在应用程序日志
中
得到以下错误
spring
.
cloud
.dataflow.applicationProperties.<
浏览 4
提问于2017-03-09
得票数 1
回答已采纳
1
回答
用功能程序设计和流桥对消费者
进行
调查
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在
使用
与
kafka
经纪公司的春云流
进行
微服务互传。作为其中的一部分,
stream
bridge将用于发送
消息
,这是很好的。--但是
在
使用
所述
消息
期间,不需要
立即
使用
该
消息
,而是当满足条件
时
,只需要
使用
。 从文档
中
,我了解到我需要在这方面
使用
Polled Consumers(如果我弄错了就纠正我)。
spring</em
浏览 7
提问于2022-03-10
得票数 0
回答已采纳
2
回答
:下游
消息
的数量与发送到主题的
消息
之和不匹配
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
它定义了一个包含以下部分的拓扑:绿色
中
的数字显示了通过通过流绑定绑定的各个处理器定义的拓扑传递的
消息
数量,以下是各自的属性:@RunWith(SpringRunner.class) properties = "
spring
.
cloud
.
stream
.<em
浏览 1
提问于2020-05-30
得票数 2
回答已采纳
1
回答
使用
Spring
Integration启动
Spring
Boot应用程序
Kafka
用户暂停
java
、
spring
、
spring-boot
、
apache-kafka
、
spring-integration
我正在开发一个
Spring
Boot应用程序,它
使用
以
Kafka
主题为源的
Spring
集成
流。我们的
集成
流开始
使用
一个包含带有springframework.
cloud
.
stream
.annotation.Input和输出注释的SubscribableChannels的接口。这些配置为通过云配置和
spring
.
cloud
.
stream
.
kafka
.bindings
浏览 0
提问于2018-04-24
得票数 1
1
回答
无法
使用
spring
的
嵌入式
消息
代理
进行
测试
spring
、
spring-boot
、
spring-test
、
spring-cloud-stream
、
spring-boot-test
我有以下组件,用于发送
消息
给经纪人(卡夫卡),也通过StreamListener的
spring
-
cloud
接收。现在我需要写
测试
,在这里我向
嵌入式
代理发送
消息
,并
验证
消息
是否
已收到。,我尝试了
测试
自动连接
是否
不为空,接下来我希望将
消息
发送到输出通道,并通过
spring
云
测试
支持的
嵌入式
消息
代理接收它。(Abst
浏览 4
提问于2018-09-18
得票数 0
1
回答
Spring
@StreamListener条件不推荐替代方案
java
、
spring-boot
、
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我们让多个应用程序
使用
者收听相同的
kafka
主题,并且生产者
在
向主题发送
消息
时
设置
消息
头,以便特定实例能够评估标头并处理
消息
。TestObj message) {}
在
SpringCloudStream3.0.0
中
,@StreamListener
被<
浏览 11
提问于2021-09-16
得票数 5
1
回答
Spring
-
Cloud
-
Stream
process
kafka
消息
仅在应用程序启动
时
实现的状态存储已完全填充并准备就绪后才能处理
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
引用此solution,我的
spring
-
cloud
-
stream
application.yml文件具有以下配置: #application.yml
spring
.
cloud
.
stream
.bindings.input注解的类以及带有@StreamListener注解的方法内部,我
使用
kafka
stream
DSL和处理器API
集成
来访问状态存储,这些存储应该在应用程序启动
时
实现,因为appl
浏览 28
提问于2019-05-09
得票数 0
1
回答
StreamBridge绑定,而不是自
Spring
3.1版本以来就不再推荐的EnableBinding和输出注释
java
、
spring
、
avro
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
在其中一个API
中
,我根据HTTP请求触发器(当一个端点
被
调用时,生成一个meesage并发送到
kafka
)
使用
@Output和@EnableBinding注释生成
消息
。我有以下配置,它成功地
在
"myFooTopic“上生成
消息
,但当应用程序启动
时
,我注意到一些奇怪的日志,因为绑定似乎没有正确完成:
spring
.
kafka
.bootstrap-servers
浏览 8
提问于2022-03-08
得票数 1
1
回答
spring
云函数不注册多个函数定义
java
、
spring-boot
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
、
spring-cloud-function
类似地,我
在
com.foo.bar.fabric.nh44.functions.consumer包中有一个卡夫卡
消息
的
使用
者。其想法是将这些代码捆绑到JAR库(event-library)
中
,然后
在
我们所有的微服务中
使用
它来
进行
事件驱动的通信。我编写了一个
测试
,
在
微服务中
使用
这些组件编写
测试
,方法是
在
com.foo.bar.example代码的src/test/
浏览 7
提问于2022-09-04
得票数 0
2
回答
春云流-
kafka
-空
确认
头
spring-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我希望只
在
消息
处理成功
时
使用
spring
云流手动提交偏移量。这是我的代码- application.yml & Handler类 }--------------------------------------------------------------------------------- application: name: spri
浏览 3
提问于2021-02-08
得票数 2
回答已采纳
1
回答
在
spring
cloud
stream
中
使用
PollableMessageSource输入时,
如何
使用
avro原生解码器?
java
、
avro
、
spring-kafka
、
spring-cloud-stream
、
confluent-schema-registry
我正在
使用
PollableMessageSource输入来读取卡夫卡主题。有关该主题的
消息
在
Avro
中
。发布这些
消息
时
,use-native-decoding设置为true。如果我
使用
一个常规的配置,use-native-decoding配置属性会被正常
使用
,所以
消息
看起来发布正常。 因此,我在这里的主要问题是,
在
使用
可轮询的消费者
时
,
如何
强制本地解码?我的边界问
浏览 70
提问于2020-10-27
得票数 2
回答已采纳
1
回答
如何
用OutputDestination捕获特定于组的
消息
?
spring-boot
、
rabbitmq
、
integration-testing
、
spring-cloud
、
spring-cloud-stream
我们
进行
了
集成
测试
,最终将多条
消息
发送到同一个目的地,但有许多不同的组。
在
rabbitMQ术语
中
,相同的交换具有不同的主题。
spring
.
cloud
.
stream
.bindings.userEdited-out-0.destination=user.exchange
spring
.
cloud
.
stream
.rabbit.bindings.userEdited-out=applica
浏览 4
提问于2022-05-12
得票数 1
回答已采纳
1
回答
spring
-
cloud
-
stream
kafka
消费者并发
spring-cloud-stream
使用
spring
-
cloud
-
stream
的
kafka
绑定器,
如何
配置并发
消息
消费者(
在
单个消费者jvm
中
)?如果我理解正确的话,
使用
kafka
时
使用
并发
消息
消耗需要分区,但指出,要
使用
分区,您需要通过partitionKeyExpression或partitionKeyExtractorClass在生产者中指定分区选择
浏览 2
提问于2016-03-08
得票数 7
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简单入门
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
微服务架构开发实战:SpringCloudBus的设计原理
Spring Cloud Stream简介
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券