腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(2765)
视频
沙龙
1
回答
Spring
Cloud
Stream
Kafka
errorChannel
头部
spring-integration
、
spring-kafka
、
spring-cloud-stream
我们目前使用
Spring
Cloud
Stream
来提供输入的SubscribableChannel和输出的MessageChannel,并且我们使用
Spring
Integration来提供两个
Kafka
在其他
Spring
Integration应用程序中,我们使用
errorChannel
头来动态地提供错误处理通道(例如,当发生了需要回滚错误的某个更改时,更改错误通道)。但是,
Spring
Cloud
Stream
浏览 14
提问于2019-06-29
得票数 1
1
回答
应用程序运行时异常不会发送到
errorChannel
或无法侦听
errorChannel
的ServiceActivator。
error-handling
、
spring-integration
、
apache-kafka-streams
、
spring-cloud-stream
=myGroup
spring
.
cloud
.
stream
.
kafka
.streams.bindings.input.co
浏览 1
提问于2019-06-07
得票数 0
回答已采纳
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,要求将成功的
spring
:
stream
:
kaf
浏览 2
提问于2017-10-19
得票数 1
1
回答
如何在SCDF中向两个不同的输出通道发送消息?
spring-cloud-stream
、
spring-cloud-dataflow
我如何确保SCDF实际上为这个频道创建一个
Kafka
主题?溪流的定义是什么样子的?类似于……的东西source | processor使用常规的output通道/
Kafka
主题,source
浏览 2
提问于2017-03-07
得票数 0
回答已采纳
1
回答
春云数据流
errorChannel
不工作
kubernetes
、
spring-integration
、
spring-cloud-stream
、
spring-cloud-dataflow
stream
:
kafka
: environment.
spring
.
cloud
.
stream
.
kafka
.binder.brokers=brokerlist编辑:从kub
浏览 0
提问于2018-11-27
得票数 0
回答已采纳
1
回答
Spring
Cloud
Stream
Kafka
只为一个绑定添加
头部
spring
、
spring-cloud-stream
Spring
Cloud
Stream
的参考手册中提到,您可以使用"
spring
.
cloud
.
stream
.
kafka
.binder.headers“属性来设置所有绑定的
头部
。有没有办法为特定的绑定设置
头部
?例如,如下所示: bindings: destination: input-topic
浏览 8
提问于2016-09-27
得票数 0
回答已采纳
1
回答
用功能程序设计和流桥对消费者进行调查
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
application.properties
spring
.
cloud
.
stream
.function.definition= consumeResponse
spring
.
cloud
.
stream
.bindings.outputchannel1.destination = RE
浏览 7
提问于2022-03-10
得票数 0
回答已采纳
1
回答
多卡夫卡绑定弹簧云数据流
spring-cloud-dataflow
卡夫卡-基地1应该是默认的,卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供,例如: app.bridge.
spring
.
cloud
.
stream
.bindings.output.binder=
kafka
-qa2我的SCDF application.yaml包含两个绑定:
cloud
: applicationProperties:
spring<
浏览 6
提问于2017-02-03
得票数 0
回答已采纳
1
回答
SpringCloudStreamReactive-如何在无反应流管道情况下进行错误处理?
spring-cloud-stream
、
spring-kafka
喜欢 对于DLQ,并生成错误主题
spring
.
cloud
.
stream
.
kafka
.bindings.input.consumer.enableDlq=true
spring
.
cloud
.
stream
.
kafka
.bindings.input.consumer.dlqName=re
浏览 1
提问于2018-11-22
得票数 4
1
回答
春云流产生器重试和错误处理
spring-boot
、
spring-kafka
、
spring-cloud-stream
server.port: 9050
cloud
: bindings: destination: error-topic destination:
stream
-topic errorChannelEnabled: true <em
浏览 11
提问于2022-05-09
得票数 1
回答已采纳
1
回答
使用
Spring
云流卡夫卡流绑定的问题
spring-cloud-stream
属性文件
spring
:
spring
:
stream
::9092 type:
kafka
environment
浏览 0
提问于2019-05-17
得票数 1
1
回答
改变中的行为。使标头匹配器区分大小写
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我需要我的自定义'Id‘卡夫卡标题和不想'id’头从春天卡夫卡流。最后,我得到了两个标题:'Id‘(我的头)和'id’(由提供)。
浏览 2
提问于2021-07-16
得票数 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-cloud-dataflow
我在application.properties中指定了但是当我从仪表板部署一个流时,我可以在日志中看到另外,任何其他属性(如
Kafka
绑定器或zkNodes )都不会从application.properties中读取,但会使用默认值,从而使部署失败。 如何为所有已部署的应用程序/流覆盖这些属性?
浏览 6
提问于2017-03-09
得票数 0
回答已采纳
1
回答
使用StreamBridge实现
Stream
中的生产者回调
java
、
spring-cloud
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
、
spring-messaging
弹簧云流是否可能使用
kafka
绑定发布一些事件,并使用像onSuccess和onFailure这样的回调?
浏览 19
提问于2022-07-07
得票数 0
回答已采纳
1
回答
如何在YAML中通过
Spring
Cloud
Stream
提供
Kafka
Streams属性?
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我想把
spring
.
kafka
.streams.*移到
spring
.
cloud
.
stream
下--这可能吗?
spring
: config: server:
stream
: input_technischerplatz:
浏览 43
提问于2020-04-27
得票数 0
3
回答
如何使用
Spring
cloud
stream
访问受密码保护的confluent模式注册服务器?
apache-kafka
、
avro
、
spring-cloud-stream
、
confluent-schema-registry
、
aiven
我正在使用
spring
cloud
stream
和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。驱动时,一切都很好,但是如果我使用
Spring
cloud
stream
,我不知道如何注入这两个参数。目前,我将"basic.auth.user.info"和"basic.auth.credentials.source"放在application.yml文件中的"
浏览 21
提问于2019-04-16
得票数 2
回答已采纳
1
回答
缺少春云流的模式模块
spring-boot
、
spring-cloud-stream
springBootVersion = '1.4.2.RELEASE' dependencies { compile('org.springframework.
cloud
:
spring
-
cloud
-starter-
strea
浏览 1
提问于2016-11-25
得票数 1
回答已采纳
1
回答
Spring
Cloud
stream
binder自定义
头部
未被消费者接收
spring-kafka
、
spring-cloud-stream
我使用的是
Spring
cloud
stream
绑定器
kafka
,Edgware.SR4版本。制片人:
spring
:
浏览 130
提问于2019-05-24
得票数 0
1
回答
春云探测不同轨迹ID与卡夫卡的集成
spring
、
spring-boot
、
spring-cloud
、
spring-cloud-sleuth
我使用
Kafka
实现微服务之间的Asyng调用,使用
Spring
进行日志记录。
浏览 2
提问于2016-12-02
得票数 4
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简介
Spring Cloud Stream简单入门
Spring Cloud Stream如何处理消息重复消费?
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
Spring Cloud ELK+kafka日志分析平台搭建
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券