腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(307)
视频
沙龙
1
回答
合流
模式
注册表
的
Spring
Cloud
Stream
Kafka
无法
向
通道
输出
发送
消息
spring-boot
、
apache-kafka
、
avro
、
spring-cloud-stream
、
confluent-schema-registry
我想用Confluent Schema Registry和Avro Schema演进测试
Spring
Cloud
Stream
,以便将其与我
的
应用程序集成。我发现
Spring
Cloud
Stream
不支持到Confluent Schema Registry
的
安全连接,而且实现仍然非常基础。因此,我决定将Confluent Schema Registry Client与
Spring
Kafka
结合使用,用于
模
浏览 29
提问于2019-04-25
得票数 1
1
回答
如何测试使用Avro和
合流
模式
注册表
的
应用程序?
apache-kafka
、
spring-cloud
、
apache-kafka-streams
、
spring-kafka
、
spring-cloud-stream
我很难弄清楚如何测试使用Avro作为
消息
格式和(
合流
)
模式
注册表
的
应用程序。配置可以如下所示: application:
cloud
: schema-registry-client:
kafka
:
浏览 0
提问于2019-07-31
得票数 1
回答已采纳
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
消息
写入
kafka
主题,并将错误
消息
写入
浏览 2
提问于2017-10-19
得票数 1
1
回答
Spring
Cloud
Stream
Kafka
:如何在
向
kafka
主题生成
消息
后访问
kafka
头部
的
recordMetadata
spring-cloud-stream-binder-kafka
我想在
向
kafka
topic发出
消息
后,获取偏移量和分区信息。我通读了
spring
cloud
stream
kafka
绑定文档,发现这可以通过使用RECORD_METADATA
kafka
头来实现。来自
Spring
文档:() recordMetadataChannel成功
发送
结果应
发送
到
的
MessageChannel
的
bean名称;该bean必须存在于应用程序
浏览 0
提问于2020-09-23
得票数 1
1
回答
如何用
模式
id序列化protobuf
消息
php
、
apache-kafka
、
protocol-buffers
、
confluent-schema-registry
查找以protobuf格式实现
消息
序列化
的
库或算法,其
模式
版本是从
合流
模式
注册表
中检索
的
。我使用php-rdkafka扩展
向
Kafka
主题
发送
消息
。
浏览 2
提问于2022-04-20
得票数 -2
回答已采纳
2
回答
Spring
cloud
stream
kafka
绑定配置最大请求数
spring-boot
、
apache-kafka
、
spring-cloud
我使用
的
是
spring
cloud
stream
kafka
。message.max.bytes=20000000
spring
.
c
浏览 6
提问于2019-08-28
得票数 4
1
回答
如何在SCDF中
向
两个不同
的
输出
通道
发送
消息
?
spring-cloud-stream
、
spring-cloud-dataflow
我有一个源,它通过默认
的
output
通道
向
流中
的
处理器
发送
消息
。现在,我还想通过不同
的
频道
发送
失败
消息
。source |
浏览 2
提问于2017-03-07
得票数 0
回答已采纳
1
回答
弹簧云卡夫卡绑定查询
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
突然,我们观察到生产者正在
向
主题
发送
重复
的
信息,然后我们使生产者是幂等
的
。为了更好
的
控制,我们让autocommitOffSet做错了。enrichMessage = // Enrichment on inputMessage} 我们观察到如果ack.acknowledge()由于某些问题而失败,
消息
仍然
发送
到出站
通道
如何将整个使用者/生产者作为一个事务
的</e
浏览 3
提问于2021-09-28
得票数 0
2
回答
无法
追踪弹簧云流侦听器与弹簧云侦查
spring
、
trace
、
spring-cloud-stream
、
spring-cloud-sleuth
我有两个非常简单
的
春云流应用程序。Service3,
消息
生产者,通过绑定器-卡夫卡
向
消费者Service4
发送
消息
。 我用春云雪橇来追踪它们之间
的
跨度。Marshal跨越
Spring
云流绑定器compile('org.springframework.
cloud
:
spring
-
cloud
-sleuth-
stream
') compile('org.springframewo
浏览 9
提问于2017-02-22
得票数 0
1
回答
Confluent
模式
注册表
与
Spring
云
模式
注册表
apache-kafka
、
spring-cloud-stream
、
confluent-schema-registry
到目前为止,我一直在研究
spring
云
模式
注册表
和confluent
模式
注册表
。我可以看到一些区别,比如
spring
云
模式
注册表
将
模式
保存在普通数据库中,默认情况下保存在h2中,而confluent
模式
注册表
保存在
kafka
topic中。对于
spring
云
模式
注册表
,这种方法有没有性能影响?据我所知,即使数据被保存在主题上,如
浏览 26
提问于2021-06-29
得票数 0
2
回答
如何用弹簧引导和弹簧云流在
kafka
生产者上设置avro内容类型
avro
、
spring-kafka
、
spring-cloud-stream
我试图用avro
消息
生产者、
kafka
和avro消费者构建一个使用
spring
引导、
spring
云流
模式
注册表
和
kafka
绑定器
的
工作示例。在使用
消息
时会发生以下错误: 错误7059 --afka-侦听器-1 o.s.c.s.b.k.KafkaMessageChannelBinder :
无法
使用contentType java.lang.NullPointerException反序列化io.igx.android.S
浏览 6
提问于2017-03-09
得票数 1
1
回答
使用StreamBridge实现
Stream
中
的
生产者回调
java
、
spring-cloud
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
、
spring-messaging
我想知道一种使用StreamBridge执行回调
的
方法,我想做一些类似于返回ListenableFuture
的
KafkaTemplate.send
的
事情。弹簧云流是否可能使用
kafka
绑定发布一些事件,并使用像onSuccess和onFailure这样
的
回调?
浏览 19
提问于2022-07-07
得票数 0
回答已采纳
1
回答
无法
使用汇合平台将Avro数据推送到HDFS
apache-kafka
、
hdfs
、
avro
、
apache-kafka-connect
、
confluent-platform
我有一个系统将Avro数据推入到多个
Kafka
主题中。 在更改主题名称之后,我启动了
kafka
-connect-hdfs。这一步骤也是成功
的
。在此之后,我开
浏览 2
提问于2017-01-20
得票数 1
1
回答
Spring
Cloud
Bus和
Spring
for Apache
Kafka
有什么区别?
spring-cloud
使用
Spring
for Apache
Kafka
或
Spring
AMQP,我可以实现
消息
发布/订阅。
Spring
Cloud
Bus使用
kafka
/rabbitmq来做大致相同
的
事情,它们之间有什么区别?
浏览 11
提问于2018-08-01
得票数 4
1
回答
正在
合流
模式
注册表
中生成Avro
模式
,没有任何字段
apache-kafka
、
avro
、
spring-cloud-stream
、
spring-cloud-dataflow
、
confluent-schema-registry
项目描述如果我删除
模式
注册表
中
的
现有
模式
,然后重试,将auto.register.schemas设置为true,那么它将显示它为我生成
的
模式
中似乎
浏览 4
提问于2021-08-31
得票数 0
回答已采纳
1
回答
弹簧云函数路由
spring-boot
、
apache-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
、
spring-cloud-function
我正试图通过实现
Spring
云功能来创建一个
kafka
。尽管应用程序中
的
控件确实指向类并正在创建
消息
,但我没有在“目的地”中看到它们。=false
spring
.
cloud
.
stream
.
kafka
.bindings.articleAggregated.pr
浏览 4
提问于2021-11-17
得票数 0
回答已采纳
1
回答
无法
使用
spring
云流
kafka
发送
自定义标头
spring-boot
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我有两个用Java编写
的
微服务,使用
Spring
。,通过,在它们之间
发送
消息
。我需要
发送
一个自定义头,但到目前为止没有成功。我在互联网和
Spring
上已经阅读和尝试了大多数东西。这意味着我从未在接收方中接收到
消息
,因为
无法
找到标头,也不能为空。我怀疑标题从来没有写在
消息
中。现在我正试图用Kafkacat来验证这一点。</
spring
-
浏览 5
提问于2020-10-29
得票数 0
1
回答
如何使用
Spring
Cloud
Kafka
Stream
3.1创建生产者
java
、
spring
、
apache-kafka
、
spring-cloud-stream
我读了
Spring
Cloud
Stream
Binder
的
文档,但只发现如何定义消费者,或者消费者和生产者(例如,从主题中获取信息,转换数据并
发送
到另一个主题)。因此,我不知道是否可以继续使用像@Input、@Ouptut这样
的
注释来定义单个处理器,在这一点上我非常困惑,因为库表明这些注释已被弃用,但我找不到示例或文档来定义一个简单
的
生产者来向特定主题
发送
信息。文档链接:https://docs.
spring
.i
浏览 30
提问于2021-01-22
得票数 2
1
回答
春季云卡夫卡流绑定器transactionIdPrefix
向
出站主题
发送
2条
消息
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
最近,我们引入了幂等生成器并包含了transactionIdPrefix属性,并且我们观察到出站
通道
在主题中开始
发送
2条
消息
,因为它应该只
发送
一条
消息
。一条带有实际json
的
消息
将另一条
消息
的
值计算为‘b’\x00\x06&‘字符。下面是代码和配置。如果删除transactionIdPrefix,那么我可以看到只
发送
给出站主题
的
一条
消息
。=TX-
spring</em
浏览 3
提问于2021-10-01
得票数 1
1
回答
春云流卡夫卡绑定器enableDlq没有像我预期
的
那样工作。
spring-boot
、
apache-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在使用
spring
云流
kafka
绑定器和
模式
注册表
。(不是kakfa流)我要做
的
是,当不可反序列化
消息
进入输入主题时,将deserializable
消息
发送
到dlq.。所以我尝试了像下面这样
的
配置,但是
spring
应用程序让不断地无限地重试,并且说 由: org.apache.
kafka
.common.errors.SerializationException:错误反序列化id -1
的<
浏览 3
提问于2021-02-18
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
Spring Cloud Stream简单入门
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
微服务架构开发实战:SpringCloudBus的设计原理
Spring Cloud构建微服务架构:分布式服务跟踪
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券