腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(3072)
视频
沙龙
1
回答
Spring
Cloud
Stream
Web+Stream
功能
spring
、
spring-boot
、
spring-cloud
、
spring-cloud-stream
、
spring-cloud-function
让我们像这样定义
Spring
Cloud
函数: @Bean log.infologfileEvent) -> { }; } 具有如下属性:
spring
.
cloud
.
stream
.bindings.lo
浏览 22
提问于2021-10-15
得票数 0
2
回答
Spring
Boot 2.2.4/Hoxton.SR1中的处理器App无法在
Spring
Cloud
数据流2.4.1中工作
spring-cloud-dataflow
:
stream
: definition: uppercase <?>Hoxton.SR1</
spring
-
cloud
.version> <dependency>> <groupId>org.springframework
浏览 25
提问于2020-03-26
得票数 0
1
回答
Spring
Cloud
Stream
Kinesis绑定器错误处理
spring-cloud-stream
我在
Spring
Cloud
Stream
中看到了对Rabbit和Kafka的这种级别的支持,但我没有看到对Kinesis绑定的支持。在Kinesis流处理器中处理错误的推荐方法是什么?
浏览 24
提问于2019-05-16
得票数 1
回答已采纳
2
回答
与春云流及
功能
连接的路径
spring-boot
、
kotlin
、
spring-cloud-stream
、
spring-cloud-function
我试着实现一个简单的场景,我想用头
spring
.
cloud
.function.definition = consume1或consume2发送一条消息 我希望consume1或consume2应该根据消息头上发送的内容进行调用, amqp_consumerQueue=consumer.app, amqp_redelivered=false, id=9a4dff25-88ef-4d76-93e2-c8719cda122d,
spring
.
cloud
.function.definitionamq.ctag-gGChFNCKIV
浏览 2
提问于2020-02-27
得票数 0
回答已采纳
1
回答
作为
Spring
-
Cloud
-Data-Flow流的一部分部署的
Spring
-
Cloud
-Function应用的Kafka主题名称错误
spring-cloud-dataflow
、
spring-cloud-function
See https://stackoverflow.com/questions/59155689/could-not-decode-json-type-for-key-file-name-in-a-
spring
-
cloud
-data-flow-
stream
但我读到
Spring
Cloud
Function应该允许我实现这样的应用程序,而不需要指定绑定和转换器注释,所以我将其更改为: @SpringBootApplication // @
浏览 13
提问于2020-04-28
得票数 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
回答
如何在RabbitMQ中动态创建队列的“N”号
spring-boot
、
rabbitmq
、
spring-cloud-stream
、
spring-rabbit
我试图使用StreamBridge SpringBoot和RabbitMQ作为代理来创建动态的n个队列--我以前用这种方法创建了队列
spring
.
cloud
.
stream
.bindings.sender-in-0.destination=sampleQueue
spring
.
cloud
.<em
浏览 5
提问于2022-11-10
得票数 0
1
回答
Spring
云流安全
spring-cloud-stream
希望在新项目中使用
Spring
Cloud
Stream
来实现事件驱动的方法,但是我似乎找不到任何关于安全性的文档。我们使用OAuth2来保证rest的安全性,有谁对流有什么建议吗?
浏览 1
提问于2017-02-16
得票数 1
1
回答
使用Kafka的
Spring
Cloud
Stream
-重启消费者后消息未被读取
spring
、
microservices
、
spring-cloud
我的application.properties:
spring
.
cloud
.
stream
.bindings.input.consumer.headerMode=raw
spring
.<em
浏览 1
提问于2017-07-29
得票数 1
1
回答
使用
Spring
云流卡夫卡流绑定的问题
spring-cloud-stream
(DefaultBinderFactory.java:194) at org.springframework.
cloud
.
stream
.binding.BindingService.getBinder(BindingService.java:337) at org.springframewor
浏览 0
提问于2019-05-17
得票数 1
2
回答
Spring
中没有@EnableBinding注释的Kafka绑定
spring
、
binding
、
apache-kafka
、
spring-cloud-stream
我正在使用
spring
cloud
连接到我的Kafka经纪人。它工作得很好。现在我想通过代码而不是注释来创建我的绑定。有没有一种方便的方法呢?
浏览 1
提问于2017-07-16
得票数 0
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
kafka streams绑定器自动创建生产者主题
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
是否可以在application.yml中仅为应用程序生成的主题启用
spring
.
cloud
.
stream
.kafka.streams.binder.auto-create-topics,而不是自动创建应用程序使用的主题我正在使用
spring
-
cloud
-
stream
和kafka-streams绑定器。 在更一般的意义上,这是创建kafka主题的正确方法吗?
浏览 30
提问于2020-11-24
得票数 0
回答已采纳
1
回答
应用程序/流默认属性
spring-cloud-dataflow
我在application.properties中指定了但是当我从仪表板部署一个流时,我可以在日志中看到
浏览 6
提问于2017-03-09
得票数 0
回答已采纳
1
回答
项目反应堆稳定性的
Spring
云流
spring
、
spring-webflux
、
spring-cloud-stream
、
reactor
、
spring-cloud-function
我想使用
Spring
Cloud
Stream
来消费和处理Apache Kafka队列,并将它们写入MongoDB。我看到有一个选项可以使用这个库,这样函数将是反应性的,或者是命令性的。在大多数
Spring
项目中,命令式方式是默认的,但据我所知,在
spring
cloud
stream
中,反应式范例是默认的。 我想知道什么被认为是最“稳定”的api,例如,对于企业推荐使用什么?
浏览 21
提问于2021-11-15
得票数 0
回答已采纳
1
回答
Spring
cloud
stream
:如何在新的Consumer<>函数式编程模型中使用@Transactional
spring-boot
、
spring-cloud-stream
、
spring-cloud-function
我有StreamListener,我想用新的
功能
模型和消费者<>替换它。-0.consumer.transacted=true
spring
.
cloud
.
stream
.bindings.log-
浏览 39
提问于2021-10-24
得票数 0
回答已采纳
1
回答
Spring
Cloud
Stream
Source扩展命名目标
spring-cloud-dataflow
我们正在扩展运行在kafka活页夹上的SCDF中的rabbit源连接器,并添加额外的
功能
,这些
功能
可以在消息传递到最终目的地之前使用添加额外处理的
功能
进行扩展。>Hoxton.SR1</
spring
-
cloud
.version> <
spring
-
cloud
.schema.version>2.2.1.RELEASE</
spring
-
cloud
.schema.vers
浏览 0
提问于2020-05-01
得票数 0
1
回答
通过在流@Input("suffix"+"QueueA")and@Input("suffix"+"QueueA")中动态更改队列名称来在“队列”之间推送消息的任何配置
rabbitmq
、
spring-amqp
、
spring-cloud-stream
、
spring-rabbit
是否提供通过在
cloud
.
stream
@Input("suffix"+"SampleQueueA")和@Input("suffix"+"SampleQueueB")中动态更改队列名称来在两个“队列”之间推送消息 使用消息服务器RabbitMQ的Sprig
cloud
stream
的用例。: guest
stream
:ClientSam
浏览 27
提问于2019-05-26
得票数 0
1
回答
如何将特定的kafka使用者分配给特定的分区
spring-integration
、
spring-cloud-stream
我有一个有两个分区的“主题”。topic-1input0具有相同的目的地“主题”和相同的组。是否可以将特定的分区分配给特定的消息通道?
浏览 6
提问于2017-07-27
得票数 3
回答已采纳
1
回答
在发送avro消息时获取异常,异常是注册Avro模式的org.apache.kafka.common.errors.SerializationException:错误:
java
、
spring-boot
、
avro
、
spring-cloud-stream
、
confluent-schema-registry
我正在使用
spring
云流并试图发布avro消息,但是得到了上述异常,
spring
.
cloud
.
stream
.bindings.feed-output-channel.producer.useNativeEncoding=true
spring
.
cloud
.
strea
浏览 14
提问于2022-01-21
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简介
Spring Cloud Stream简单入门
Spring Cloud Stream如何处理消息重复消费?
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券