回答情况：
提问时间：
问题标签：
我有一个使用kafka绑定的spring-cloud-stream worker @Slf4j@RequiredArgsConstructorps:我正在遵循这个测试https://github.com/spring-cloud/spring-cloud-stream/blob/master/spring-cloud-stream/src/test
浏览 139提问于2019-06-01得票数 1
打扰了!我从我的teammates.They得到了相同的问题，问我卡夫卡主题，春天云流频道和春天云流目的地之间的不同点是什么。我们试着在网上搜索，但找不到任何线索。
浏览 2修改于2019-02-14得票数 0
使用spring-cloud-stream的kafka绑定器，如何配置并发消息消费者(在单个消费者jvm中)？
浏览 2提问于2016-03-08得票数 7
我想知道如何配置io.micrometer.core.instrument.binder.kafka.KafkaClientMetrics类(v1.5.2)。我从哪里得到消费者和生产者，这是由底层的kafka活页夹创建的。什么时候我必须调用整个过程呢？(目前还没有自动配置) 因为Set<ObjectName> objs = mBeanServer.queryNames(new ObjectName(JMX_DOMAIN + ":type=" + type + ",*"), null);返回一个空集，所以自动配置的io.micrometer.core
浏览 24提问于2020-07-15得票数 0
回答已采纳
我在想DeadLetterPublishingRecoverer，但我找不到一种方法让它与spring-cloud-stream一起工作，而不是spring-kafka。
浏览 10修改于2020-07-13得票数 0
回答已采纳
在我的应用程序中，streamlistner使用了来自多个主题的kafka消息，但我想为一个主题添加功能性的消费者bean，这是否可能一些主题由streamlistner消费，一些主题与消费者bean在同一应用程序中使用？当我尝试的时候，只创建了哪些主题是streamlistner消费的，而不是消费者bean的？ application.yml spring: function: stream: binder:
浏览 108提问于2021-03-22得票数 0
我正在尝试使用spring-cloud-stream，并创建official blog的示例项目。 实现与本文完全相同。{ implementation 'org.springframework.cloud:spring-cloud-stream
浏览 34提问于2021-04-12得票数 0
我正在构建一个spring-cloud应用程序，并使用stream来管理我的rabbitmq优先级队列。但是application.yml中的maxPriority设置不起作用。spring: stream: bindings: producer: highLevelInput:
浏览 12修改于2017-06-22得票数 0
dependency> <groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream
浏览 18提问于2019-07-03得票数 0
我正在使用spring-cloud-stream : 2.1.1.RELEASE和Rabbit绑定器。
浏览 2提问于2019-06-06得票数 0
我搜索过文档和示例，但我找到的都是基于spring-cloud-stream提供的经典绑定的示例。我正在尝试看看是否有一种方法可以用函数式风格访问这些信息。
浏览 194提问于2021-02-10得票数 0
回答已采纳
这是这个question的续集。我可以将“普通”Apache Kafka绑定器和功能模型一起使用吗？到目前为止，使用基于注释的配置，我在一个应用程序中混合了这两者，spring-cloud-stream-binder-kafka用于简单的消费/生产，spring-cloud-stream-binder-kafka-streams用于高级流处理。 函数式模型似乎只被streams绑定器支持，如果我尝试混合这两种方法-基于简单使用的注解和用于流的函数式，流绑定没有注册。 spring.cloud: function:
d
浏览 21修改于2019-10-19得票数 0
回答已采纳
我正在尝试使用spring-cloud-stream rabbitmq编写一个应用程序，但没有使用spring-boot。可以不使用spring-boot而使用spring-cloud-stream吗？谁能给我举个例子？.| +--- org.springframework.bootorg.springframework.cloud:spring-cloud-stream-binder-ra
浏览 0修改于2016-09-21得票数 2
我正在使用spring-cloud-data-flow-server-yarn，并在我的yarn集群中成功地部署了我的spring-cloud-stream应用程序。
浏览 3修改于2017-06-01得票数 0
当我手动确认消费者应用程序中的偏移量时，我希望消费者可以自动重新获得未确认消息，但我不能成功。cloud: kafka: brokers: ****:**** replication-factor: 1 input: auto-commit-offset: false
auto-commit-on-error: fals
浏览 1修改于2017-01-25得票数 0
我想发送一些东西到Kafka主题在生产者(而不是在读写过程中)事务使用输出通道。我在StackOverflow (Spring cloud stream kafka transactions in producer side)上阅读了文档和另一个主题。 问题是我需要为每个节点设置唯一的transactionIdPrefix。有什么建议怎么做吗？
浏览 13提问于2020-10-22得票数 0
回答已采纳
我正在使用spring-cloud-stream kafka绑定器来消费来自kafka主题的消息。源系统正在以ascii发送json消息。
浏览 0修改于2017-03-08得票数 1
我正在尝试做一个简单的spring-cloud-stream单元测试来验证流之间的连接；基本上，处理程序可以从一个流中读取并写入到另一个流中。这部分运行得很好。spring-cloud-stream测试文档here示例有 @RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment= SpringBootTest.WebEnvironment.RANDOM_PORT我们使用的是spring-cloud-stream和spring-cloud-stream-test-support的2
浏览 46提问于2019-01-11得票数 0
回答已采纳
它突然工作得很好，这个问题从12月18日起就弹出了，找不到任何线索，突然这个异常在6个月后不断出现。我搜索并找到了这个。在这篇文章中，我也报道了我所面临的同样的问题，但没有找到任何解决办法或线索，所以我发布了这个问题。 Error while processing: null at org.ap
浏览 0提问于2018-12-24得票数 0
回答已采纳
是否可以在Spring Cloud Stream中使用带有@EnableBinding注释的类或带有@StreamListener的方法中的交互式查询(InteractiveQueryService)？我尝试在提供的KStreamMusicSampleApplication类和进程方法中实例化ReadOnlyKeyValueStore，但总是为空。 我的@StreamListener方法正在监听一堆KTables和KStreams，在处理拓扑的过程中，例如过滤，我必须检查来自KStream的键是否已经存在于特定的KTable中。 我试图弄清楚如何扫描传入的KTable以检查密钥是否已经存在，
浏览 16修改于2019-05-01得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号