腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(7410)
视频
沙龙
1
回答
在春
云
流
中调用Hibernate
、
、
我对春天的
云
流
很陌生。在
流
处理过程中调用Hibernate有效吗?
浏览 9
提问于2021-12-15
得票数 1
回答已采纳
1
回答
如何
通过
多个
StreamListener
Spring
云
流
和
Kafka
流
收听
多个
主题
、
我想听两个
Kafka
主题
,就像下面的代码一样,有两个源事件需要处理并转换为另一个事件。PartnerOrderCancelledEventImporter.Targets.class) } @
Stream
浏览 50
提问于2019-03-25
得票数 0
回答已采纳
1
回答
春季
云
流
中的内部通道
、
、
、
、
我开始开发一个
spring
云
流
项目。我
通过
@
Streamlistener
注释成功地收到了
Kafka
的消息。在将消息发送到任何输出通道之前,我必须
通过
调用外部服务或DB调用来转换有效负载。我不想从同一个
streamlistener
方法调用外部服务或DB方法。我的问题是,我们能否在
Spring
云
流
中创建内部通道(比如
流
)?
浏览 5
提问于2020-07-19
得票数 0
回答已采纳
1
回答
用于大容量数据处理的
Spring
或
Kafka
流
、
、
、
、
我正致力于为银行创建一个大容量的JSON数据处理应用程序,使用
Spring
、
Kafka
和
QuickFIX/J。这是我第一次使用
Kafka
和
QuickFIX/J这样的技术,无法决定是使用普通的
Kafka
spring
还是
Kafka
流
还是
spring
云
流
。以下是要求: 从
多个
进程读取数据,并将数据发送给QuickFIX/J启动器,后者进一
浏览 7
提问于2020-06-01
得票数 0
2
回答
春
云
流
和
消费
多个
卡夫卡
主题
、
、
、
在尝试使用一个@
StreamListener
中的
多个
主题
时,我遇到了一个
spring
引导流的问题。根据春
云
流
文档:确认到文档: 绑定中间件上通道的目标目的地(例如,RabbitMQ exchange或
Kafka
主题
)。(KafkaTopicUtils.java:39) ~[
spring
-cloud-stream-binder-
kafka
-core-1.2.1.RELEASE.jar:1.2.1.RELEASE
浏览 4
提问于2017-06-18
得票数 5
回答已采纳
1
回答
错误:无法指定
多个
目的地
我正在尝试配置发送消息到两个输出的put
流
,如下所示。@
StreamListener
(SampleBinding.INPUT1)publicorg.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor.lambda$postProcessAfterInitialization$0无法指定
多个
目的地
浏览 0
提问于2018-11-14
得票数 0
回答已采纳
1
回答
SpringCloudStreamReactive-
如何
在无反应流管道情况下进行错误处理?
、
如何
对反应性流管道进行错误处理。喜欢 @KafkaListener(
浏览 1
提问于2018-11-22
得票数 4
2
回答
消费单个json,发布多条AVRO消息
、
、
、
、
我对
Spring
kafka
Stream是个新手。我最近设置了一个项目,并尝试使用
kafka
stream API来发布AVRO。需求:需要解析一个复杂的Jsonobject,它可能有
多个
子jsons。解析Json并为每个子json发送AVRO消息。它也可以是一个或
多个
。 我知道
如何
使用
kafka
客户端API来做到这一点。当前stream类的代码如下: @Service@EnableBinding(StreamBindings.class) publ
浏览 38
提问于2021-08-12
得票数 0
2
回答
多重@EnableBinding与
Kafka
泉
云
流
、
、
、
我正在尝试设置一个
Spring
应用程序来
收听
Kafka
。@EnableBinding(StreamExample.StreamProcessor.class) KStream<String, String> outputProcessed();}
浏览 0
提问于2019-02-04
得票数 3
回答已采纳
1
回答
春天云
流
的动态目的地-卡夫卡
、
、
、
我正在开发一个基于
Kafka
的
spring
云
流
的路由器(事件代理)应用程序,该应用程序位于功能范例中。应用程序从常量输入
主题
中消耗,映射
和
过滤消息,然后根据某些输入字段将其发送到某个
主题
(一次只有一条消息,而不是
多个
结果)。
通过
为输出消息设置
spring
.cloud.stream.sendto.destination头是最好的方法吗?如果是的话,我应该
如何
为生产者设置绑定呢?
浏览 4
提问于2021-12-30
得票数 0
1
回答
Spring
@
StreamListener
条件不推荐替代方案
、
、
、
、
我们让
多个
应用程序使用者
收听
相同的
kafka
主题
,并且生产者在向
主题
发送消息时设置消息头,以便特定实例能够评估标头并处理消息。例如publiclog.info("sydney order request received mes
浏览 11
提问于2021-09-16
得票数 5
1
回答
将Stream连接到
Kafka
的
多个
StreamListeners
、
、
在使用连接到
Kafka
的
Spring
应用程序中,我尝试设置两个单独的
流
侦听器方法: Exception in thread "test-d44cb424-7575下
浏览 4
提问于2018-10-15
得票数 1
回答已采纳
1
回答
同一个
主题
的
多个
StreamListeners与卡夫卡连接的
Spring
、
、
我有
Spring
应用程序,我正在使用连接到
Kafka
。我试图为相同的
kafka
主题
设置两个单独的
流
侦听器方法。@
StreamListener
("countries") public KStream<?.toStream() .map((key, value) -> new KeyValue<>(null, valu
浏览 3
提问于2020-06-19
得票数 1
回答已采纳
1
回答
带有弹簧引导网络
流
的反应性
kafka
流
示例
、
、
我正在尝试构建一个
Spring
应用程序,它使用来自一个
Kafka
主题
的事件,对其进行一些处理(可能涉及对反应性db查找的操作),并将它们发送到另一个
kafka
主题
。目前,该应用程序为
kafka
使用了webflux
和
spring
云
数据
流
。 请有人建议使用好吗,还是应该使用其他方法来实现端到端的反应行为。尝试用
Spring
引导WebFlux,春季
云
数据
流
卡夫卡
浏览 7
提问于2022-12-02
得票数 0
3
回答
spring
boot
kafka
中基于消费者记录密钥的多消费者
、
、
我想根据消费者记录密钥列出
kafka
主题
。//do some processing //do some processing有没有可能有
多个
消费者根据密钥
收听
同一个话题
浏览 4
提问于2020-01-09
得票数 0
2
回答
如果没有
kafka
broker运行,我
如何
禁用
spring
云
流用于开发?
、
、
、
、
我有
多个
弹簧引导应用程序,与卡夫卡经纪人一起实现春
云
流
。我想知道我是否可以停止或禁用
spring
云
流
或
kafka
broker连接来启动应用程序。
浏览 3
提问于2020-01-28
得票数 8
2
回答
> @
StreamListener
进程(KStream<?,
Spring
流
)分区
、
我有一个
主题
,在我的
流
处理器中有
多个
分区,我只想从一个分区中流式传输它,并且可以弄清楚
如何
配置它
spring
.cloud.stream.bindings.input.destination=uinput
spring
.cloud.stream.bindings.input.group
浏览 1
提问于2019-02-16
得票数 0
1
回答
春季
云
流
手册Poller
Kafka
、
、
、
、
我不想使用@KafkaListener或@
StreamListener
,但我想手动投票
kafka
。我使用的是春
云
启动
流
卡夫卡库,我有以下卡夫卡制作人 private KafkaTemplate<byte[], byte[]> template; });我想手动投票相同的卡夫卡
主题
使用春季-卡夫卡。=
kafka</em
浏览 1
提问于2020-02-05
得票数 0
1
回答
春
云
启动
流
-
kafka
不创建提供给
spring
.boot.cloud.stream.bindings.output.destination的
主题
。
、
、
、
、
在春季引导应用程序中,我正在使用
spring
云
启动器-
流
-
kafka
和
spring
-
云
流
罐子。问题是,有时当我们在docker中运行应用程序(使用docker-组合)而不是创建测试
主题
时,它是将“输出”创建为一个
主题
。对于卡夫卡,我使用的是wurstmeister
浏览 3
提问于2017-11-14
得票数 1
回答已采纳
1
回答
春
云
卡夫卡
流
DefaultPollableMessageSource不可用
、
你好,我是测试弹簧云和卡夫卡
流
,并得到错误。2.2.4.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) ~[
spring
-boot2.2.4.RELEASE] at org.
浏览 5
提问于2020-03-25
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简单入门
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
使用Apache Kafka的Golang实践指南
Kafka权威指南(二):为什么选择Kafka
Kafka的三种客户端线程模型和一个小惊喜
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券