我有一个处理死信队列的Spring Cloud Stream应用程序。我在这里处理转发到DLQ主题的记录，如下所示-@EnableBinding(Processor.class) }}当我运行这个应用程序时，我得到下面的错误-java.lang.Il
浏览 26提问于2020-05-14得票数 0
1回答
带弹簧靴的云卡夫卡给了我错误
、、、、
嘿，我按照一步一步的指导，为卡夫卡在春天的靴子。spring.cloud.function.definition是什么？以及如何设置它？由: java.lang.IllegalArgumentException:发现了BeanFacto
浏览 18提问于2019-10-26得票数 2
回答已采纳
2回答
这两个函数都在@Configuration类中。: stream: notification-in-0.destination: pos-topic
notification-out我从Spring得到的所有可疑信息都是信息：@Bean method FunctionConfiguration.po is non-static and returns an object assignableto Spring
浏览 4提问于2021-04-15得票数 0
回答已采纳
1回答
我一直在尝试使用polyglot并构建一个简单的python处理器。我遵循了polyglot recipe，但我无法获得要部署的流。我最初部署的处理器与示例中使用的处理器相同，但得到以下错误： 请求的未知命令行参数:请求的spring.cloud.stream.bindings.input.destination未知环境变量: SPRING_CLOUD_STREAM</em
浏览 24提问于2020-07-17得票数 1
回答已采纳
2回答
我按照前面的问题和配置的流进行了描述，但是，我无法使它正确工作。spring.cloud.stream.bindings.input.group=defaultspring.cloud
浏览 0提问于2016-03-15得票数 3
回答已采纳
2回答
在尝试使用一个@StreamListener中的多个主题时，我遇到了一个spring引导流的问题。如果信道绑定为使用者，则可以将其绑定到多个目的地，并且可以将目标名称指定为逗号分隔的字符串值。如果未设置，则使用通道名称。不能重写此>属性的默认值。但是，在我使用了next config之后： cloud: bindings:
testchan
浏览 4提问于2017-06-18得票数 5
回答已采纳
我正在寻找关于sasl.jaas.config的配置说明，当你有2个不同的主题，每个都有不同的连接密钥？我使用的是spring-cloud-starter-stream-kafka 3.1版。我没有使用spring-cloud-stream-binder-kafka，我也不知道that would solve my problem。当只涉及一个主题时，我可以找到许多示例，使用“消费者继承的s
浏览 262提问于2021-04-01得票数 0
回答已采纳
2回答
我有一个主题，在我的流处理器中有多个分区，我只想从一个分区中流式传输它，并且可以弄清楚如何配置它spring.cloud.stream.bindings.input.destination=uinput
spring.cloud.strea
浏览 1提问于2019-02-16得票数 0
1回答
注意并处理代理中的错误
、、、、
我还尝试将生成器实现为，但在这种情况下，在应用程序启动时也不会创建exchange/队列，即使发送方法的返回状态为"OK“，发送的消息也会消失。但是我们需要知道发送在这一点上确实失败了(我们使用这个布尔返回值来持久化已发送对象的状态)。有什么办法可以做到吗？我找到了一个有趣的解决生产者问题的方法
浏览 10提问于2022-01-19得票数 1
我使用Spring数据流来设置读取CSV文件的流，使用自定义处理器对其进行转换并对其进行日志记录：
stream create --name testsourcecsv --definition "file=application/json | log --spring.cloud.stream.bindings.input.content-type=application/json" --deploy:268) ~[sp
浏览 8提问于2019-12-03得票数 1
回答已采纳
1回答
但是，如果将它部署为带有服务器的坞容器(也是1.5.0版本)，则永远不会命中onError方法。(路由器开始处的日志语句永远不会输出)spring.<em
浏览 0提问于2018-11-27得票数 0
回答已采纳
2回答
我试图组合，方法是使用来自Function类型的函数式bean的返回Flux<Message<T>>，并为每个Message设置标题spring.cloud.stream.sendto.destination，如描述的那样。person.getEvents()) .set
浏览 0提问于2020-06-07得票数 1
回答已采纳
我想在我的春季云流卡夫卡应用程序中为我的生产者设置acks=all属性。我试过这样做：和和
spring.cloud.stream</e
浏览 1提问于2019-04-24得票数 1
1回答
在春季云流卡夫卡绑定中，是否有一种方法来设置两个重连接尝试之间的重新连接频率或时间？# in application.properties
spring.cloud.stream.kafka.streams.binder.configuration.reconnect.backoff.
浏览 3提问于2022-04-01得票数 0
回答已采纳
我正在尝试使用TestSupportBinder为spring cloud stream应用程序编写测试。我找到的所有示例，包括和，都是用Transformer测试Processor。这些测试使用Tranformer获取输出通道，并将通道对象提供给messageCollector.forChannel方法以轮询输出。
但是，我没有使用提供的Processer，而是编写了自己的接口。我找不到在测试代码中获取所需的Cha
浏览 0提问于2017-04-17得票数 3
2回答
我的绑定配置：spring: stream: comp-out:
destination: company'spring.cloud.stream.bindings.user-out.producer‘下的属性绑定到org.springframework.cloud.stream.binder.Produce
浏览 0提问于2019-06-20得票数 3
4回答
下面是基于应用程序的测试场景。我的应用程序有一个有两个队列的主题。第一个队列的BindingKey被命名为“城市”，因为第二个队列是绑定键"persons“。spring.config.name=streaming
spring.cloud.stream.bindings.citiesChannel.destination=str
浏览 0提问于2017-04-04得票数 3
回答已采纳
1回答
我刚刚开始学习和Dataflow，我想知道一个重要的用例。我创建了示例处理器乘法器，它接收消息并将其重发5次输出。} }}
你能看到的是我想要实现的是在DLQ中支持输入消息，在之前发送的4条消息被恢复，并且不被下一个操作数使用(就像在正常的JMS事务中一样)。我已经尝试在我的处理器项目中定义以下属性，但没有成功。<em
浏览 0提问于2016-08-18得票数 2
回答已采纳
2回答
我已经用spring云流配置了一个基于spring引导的应用程序。我试图在一个KStream上工作，但是我不断地得到错误"java.lang.IllegalArgumentException:方法必须是声明性的“。有人能帮我理解如何配置这个吗？我查阅了StreamListener文档，但无法让它开始工作。配置
spring.cloud.stream.kafka.binder.brokers
浏览 0提问于2019-02-07得票数 4
回答已采纳
在运行在Kubernetes上的SCDF中，向数据流服务器传递附加参数或环境变量的格式是什么？当在Docker中本地运行时，我可以做如下所示的事情，但不确定使用舵图部署到Kubernetes时等效的是什么。} ports: environment:
- spring.cloud.dataflow
浏览 1提问于2021-08-06得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
