腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
多卡夫卡绑定弹簧云数据流
卡夫卡-基地1应该是默认的,卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供,例如: app.bridge.
spring
.
cloud
.
stream
.bindings.output.binder=kafka-qa2我的SCDF application.yaml包含两个绑定:
cloud
: applicationProperties:
spring
:
浏览 6
提问于2017-02-03
得票数 0
回答已采纳
1
回答
使用Kafka的
Spring
Cloud
Stream
-重启消费者后消息未被读取
、
、
我的application.properties:
spring
.
cloud
.
stream
.bindings.input.consumer.headerMode=raw
spring
.<em
浏览 1
提问于2017-07-29
得票数 1
1
回答
使用
Spring
云流卡夫卡流绑定的问题
(DefaultBinderFactory.java:194) at org.springframework.
cloud
.
stream
.binding.BindingService.getBinder(BindingService.java:337) at org.springframewor
浏览 0
提问于2019-05-17
得票数 1
1
回答
缺少春云流的模式模块
、
springBootVersion = '1.4.2.RELEASE' dependencies { compile('org.springframework.
cloud
:
spring
-
cloud
-starter-
strea
浏览 1
提问于2016-11-25
得票数 1
回答已采纳
1
回答
应用程序/流默认属性
我在application.properties中指定了但是当我从仪表板部署一个流时,我可以在日志中看到
浏览 6
提问于2017-03-09
得票数 0
回答已采纳
1
回答
通过在流@Input("suffix"+"QueueA")and@Input("suffix"+"QueueA")中动态更改队列名称来在“队列”之间推送消息的任何配置
、
、
、
是否提供通过在
cloud
.
stream
@Input("suffix"+"SampleQueueA")和@Input("suffix"+"SampleQueueB")中动态更改队列名称来在两个“队列”之间推送消息 使用消息服务器RabbitMQ的Sprig
cloud
stream
的用例。: guest
stream
:ClientSam
浏览 27
提问于2019-05-26
得票数 0
1
回答
如何将特定的kafka使用者分配给特定的分区
、
我有一个有两个分区的“主题”。topic-1input0具有相同的目的地“主题”和相同的组。是否可以将特定的分区分配给特定的消息通道?
浏览 6
提问于2017-07-27
得票数 3
回答已采纳
1
回答
Spring
Cloud
DataFlow -无法转换来自Kafka的消息
、
、
使用
Spring
Cloud
DataFlow 1.2.2版本,配置如下:
spring
.
cloud
.dataflow.applicationProperties.
stream
.
spring
浏览 0
提问于2017-07-17
得票数 0
回答已采纳
1
回答
在发送avro消息时获取异常,异常是注册Avro模式的org.apache.kafka.common.errors.SerializationException:错误:
、
、
、
、
我正在使用
spring
云流并试图发布avro消息,但是得到了上述异常,
spring
.
cloud
.
stream
.bindings.feed-output-channel.producer.useNativeEncoding=true
spring
.
cloud
.
strea
浏览 14
提问于2022-01-21
得票数 0
回答已采纳
1
回答
从模块中编辑jhipster的application.yml
当我安装模块时,模块通过以下方式为我添加pom中的依赖项: this.addMavenDependency("org.springframework.
cloud
", "
spring
-
cloud</e
浏览 1
提问于2021-06-16
得票数 0
回答已采纳
1
回答
如何在YAML中通过
Spring
Cloud
Stream
提供Kafka Streams属性?
、
、
、
我想把
spring
.kafka.streams.*移到
spring
.
cloud
.
stream
下--这可能吗?
spring
: config: server:
stream
: input_technischerplatz:
浏览 43
提问于2020-04-27
得票数 0
3
回答
如何使用
Spring
cloud
stream
访问受密码保护的confluent模式注册服务器?
、
、
、
、
我正在使用
spring
cloud
stream
和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。props.put("basic.auth.user.info", "avnadmin:schema-reg-password"); 当我只使用vanilla java的kafka驱动时,一切都很好,但是如果我使用
Spring
cloud
stream
,我不知道如何注入这两
浏览 21
提问于2019-04-16
得票数 2
回答已采纳
1
回答
使用
spring
cloud
streams函数进行有条件的路由
、
、
、
、
第一个微服务的应用程序yaml:
spring
:
stream
: output:
cloud
: routing-expression: headers['type']definition: consumerPermissionEvent;consumerApiE
浏览 79
提问于2021-04-17
得票数 0
2
回答
Spring
cloud
stream
kafka绑定配置最大请求数
、
、
我使用的是
spring
cloud
stream
kafka。message.max.bytes=20000000
spring
.
cloud
.
stream
.kafka.bindings然而,我想概括一下
spring
cloud
kafka中的所有主题
浏览 6
提问于2019-08-28
得票数 4
1
回答
如何为生产者和消费者绑定
Spring
云流绑定?
、
、
、
、
我是
Spring
和RabbitMQ的新手。我正在尝试生成和使用来自兔子MQ的消息。我在为生产者和使用者配置exchange名称和队列名称时遇到了困难。下面是application.properties
spring
.rabbitmq.addresses=amqp://user:pass@localhost:5672/
spring</em
浏览 7
提问于2022-03-29
得票数 0
回答已采纳
1
回答
对现有队列的
Spring
3+ RabbitMQ配置
、
、
我只是从
spring
云文档中创建hello应用程序,但并不真正理解。("Received: " + value); };application.yml
spring
.
cloud
.
stream
浏览 2
提问于2020-02-07
得票数 0
回答已采纳
1
回答
Spring
数据流本地服务器需要连接动物园管理员吗?
、
、
、
、
<init>(ZkClient.java:84) at org.springframework.
cloud
.
stream
.binder.AbstractBinder.bindConsumer(AbstractBinder.java:177)
浏览 2
提问于2016-12-14
得票数 1
回答已采纳
2
回答
spring
cloud
stream
'bindingService‘错误
、
、
、
、
(BinderFactoryConfiguration.java:100) ~[
spring
-
cloud
-
stream
-1.0.0.RC1.jar:1.0.0.RC1] at org.springframework.
cloud
.
stream
.config.BinderFactoryConfiguration$$EnhancerBySpringCGLIB$$b9b6d96.CGLIB$binderTypeRegistry$1(<generated>) ~[
spring
-
浏览 7
提问于2016-04-30
得票数 5
1
回答
春云探测不同轨迹ID与卡夫卡的集成
、
、
、
我使用Kafka实现微服务之间的Asyng调用,使用
Spring
进行日志记录。
浏览 2
提问于2016-12-02
得票数 4
回答已采纳
1
回答
如何使用
Spring
Cloud
Kafka
Stream
3.1创建生产者
、
、
、
我读了
Spring
Cloud
Stream
Binder的文档,但只发现如何定义消费者,或者消费者和生产者(例如,从主题中获取信息,转换数据并发送到另一个主题)。文档链接:https://docs.
spring
.io/
spring
-
cloud
-
stream
-binder-kafka/docs/3.0.10.RELEASE/reference/html/
spring
-<em
浏览 30
提问于2021-01-22
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简介
Spring Cloud Stream简单入门
Spring Cloud Stream如何处理消息重复消费?
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券