其中一个是轮询的，其他的应该是函数绑定。我的函数式消费者不工作。this.bMessageSource.b().poll(m -> { ... }, new ParameterizedTypeReference<MessageB>() {}spring: pubsub: consumer:
auto-create-r
浏览 52提问于2020-05-07得票数 1
回答已采纳
是否可以在application.yml中仅为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题我正在使用spring-cloud-stream和kafka-streams绑定器。 在更一般的意义上，这是创建kafka主题的正确方法吗？
浏览 30提问于2020-11-24得票数 0
回答已采纳
首先，我在项目Function<String, String>中添加了相应的spring.cloud.stream.bindings和spring.cloud.stream.function.definition然后，我将Supplier<Flux<String>>添加到具有相应spring.cloud.stream.bindings的同一个项目中，并将spring.clo
浏览 2提问于2020-01-15得票数 2
回答已采纳
我正试图在我的spring引导项目中集成spring云- gcp - pub -子流绑定器，以使用gcp发布子主题中的事件，并在运行该项目时获得以下错误。.TopicName.isParsableFrom(java.lang.String)'
The calling method's class, com.google.cloud.spring.stream.binder.pubsub.provisioning.PubSubCha
浏览 2提问于2022-08-21得票数 2
回答已采纳
我正在使用spring cloud连接到我的Kafka经纪人。它工作得很好。现在我想通过代码而不是注释来创建我的绑定。有没有一种方便的方法呢？
浏览 1提问于2017-07-16得票数 0
Google提供了自己的库来访问pub/sub服务。另一方面，Spring Cloud Stream也提供了同样的功能。一个比另一个有什么优势吗？
浏览 11提问于2020-01-30得票数 0
回答已采纳
1回答
弹簧云函数路由
、、、、
我正试图通过实现Spring云功能来创建一个kafka。", destination) }我知道它不是动态绑定，目的地是硬编码的，不过，我现在想测试这个特定的实现。spring.cloud.stream.bindings.articleAggregated.contentType=application/json
spring.cloud.strea
浏览 4提问于2021-11-17得票数 0
回答已采纳
我试过这样做：和和
spring.cloud.stream.kafka.streams.bindings.
浏览 1提问于2019-04-24得票数 1
1回答
因此，我从Google Cloud Storage获得了这个功能，我需要更改它，以便它可以上传多个文件，而不是一个文件。我正在尝试找到一个好的解决方案，让它总是等待，直到所有的文件都上传完。不确定如何使它异步-我应该在stream.on('finish',(...))上等待还是在file.makePublic().then(...)上等待，这肯定是一个Promiste，我可以用Promise.all功能： function sendUploadsTo
浏览 15提问于2019-09-02得票数 1
我正在尝试通过一个编排层来找到完成这一任务的最佳方法，该编排层完成所有幕后工作，包括记账、部署、消息队列创建和绑定等。 为此，我正在探索Spring Cloud数据流(SCDF)。然而，SCDF是专门为Spring boot应用程序创建数据集成管道的。但是，在我们可能有用各种语言编写的异构应用程序的情况下，是否有可能采用/适应SCDF？ ?
浏览 37提问于2021-09-21得票数 1
回答已采纳
因为如果我们使用@EnableBinding，功能会被禁用，因此我们会被困在迁移中。我们尝试研究了@PollableBean，但它似乎只适用于有有限流的反应式供应商。有什么办法可以做到这一点吗？参考：https://cloud.spring.io/spring-cloud-stream/reference/html/spring-cloud-stream.html
浏览 30提问于2020-08-21得票数 0
1回答
我可以在spring-cloud-stream-binder-kafka-core-3.0.6.RELEASE)，中看到一个属性recoveryInterval (recoveryInterval是KafkaConsumerProperties.java的一部分)，但是注释说它是不推荐的，而不是由绑定器使用。=5000
spring.cloud.stream.kafka.streams.binder.configuration.rec
浏览 3提问于2022-04-01得票数 0
回答已采纳
o.s.c.s.b.AbstractMessageChannelBinder$2 : Attempted to pause a component that does not support Pausable bean 'XXX'我试着开始/停止也使用执行器端点。
浏览 3提问于2022-03-03得票数 0
回答已采纳
)我有一个带有5个处理器的绑定程序，并希望自定义连接工厂名称。=hostspring.cloud.stream.binders.simple-rabbit.environment.spring.rabbitmq.password=pswd
浏览 0提问于2020-09-17得票数 0
2回答
春云巴士-重命名狂犬病队列？
、、、、
有没有办法告诉spring总线重命名它的rabbitmq队列？启动时，它们似乎只是一些随机值，如下所示：试图让spring总线将其重命名为一个更具人类可读性的可预测队列名我尝试在application.yml on for bootRun中添加以下内容： cloud: bindings:
浏览 3提问于2016-10-18得票数 2
回答已采纳
我在java应用程序中使用了spring cloud和apache kafka。我想为像bufferSize这样的生产者设置一些属性。下面是我的application.yaml的一个例子 spring: stream: point-output-channel
浏览 21提问于2021-07-08得票数 0
1回答
但是，我正在尝试使用Spring Stream绑定，即上面的代码被包装在 @Configurationclass StreamConfiguration$StringSerde
spring.cloud</em
浏览 29提问于2019-05-03得票数 1
1回答
我正在开发一个基于Kafka的spring云流的路由器(事件代理)应用程序，该应用程序位于功能范例中。应用程序从常量输入主题中消耗，映射和过滤消息，然后根据某些输入字段将其发送到某个主题(一次只有一条消息，而不是多个结果)。通过为输出消息设置spring.cloud.stream.sendto.destination头是最好的方法吗？如果是的话，我应该如何为生产者设置绑定呢？
浏览 4提问于2021-12-30得票数 0
我正在尝试将Spring Cloud Stream应用程序Chelsea.SR1迁移到Horsham。此项目没有绑定器，但使用spring消息传递和集成来集成自定义源和接收器。如何在没有AggregateApplicationBuilder的情况下绑定源代码、转换器和接收器？
或者有没有更好的方法在Horsham中实现这一点？我唯一的限制是，我需要使用可轮询的源/消费者。>Chelsea.SR1</spring-cloud</em
浏览 1提问于2019-12-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
