是否可以在Spring Cloud Stream Kafka Streams 3.0 Binder风格的API方法上使用@KafkaStreamsStateStore注释？看起来如果我把@KafkaStreamsStateStore放在我的
浏览 33提问于2020-06-19得票数 1
回答已采纳
我正在尝试将单独的Serde放在我的每个消费者身上，而不是所有消费者。例如，这会将Avro反序列化程序添加到我的应用程序中的所有使用者。我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeseria
浏览 13提问于2020-10-28得票数 0
回答已采纳
1回答
我想使用Spring Cloud Stream来消费和处理Apache Kafka队列，并将它们写入MongoDB。我看到有一个选项可以使用这个库，这样函数将是反应性的，或者是命令性的。在大多数Spring项目中，命令式方式是默认的，但据我所知，在spring cloud stream中，反应式范例是默认<em
浏览 21提问于2021-11-15得票数 0
回答已采纳
1回答
在春季云流卡夫卡绑定中，是否有一种方法来设置两个重连接尝试之间的重新连接频率或时间？
如果卡夫卡集群在应用程序运行时出现故障，它将继续尝试重新连接，CPU使用率将上升到100%。我可以在spring-cloud-stream-binder-kafka-core-3.0.6.RELEASE)，中看到一个属性recoveryInterval (recoveryInte
浏览 3提问于2022-04-01得票数 0
回答已采纳
我知道如何使用命令式编程方法定义生产者，但我找不到如何使用函数式编程方法定义生产者。我读了Spring Cloud Stream Binder的文档，但只发现如何定义消费者，或者消费者和生产者(例如，从主题中获取信息，转换数据并发送到另一个主题)。因此，我不知道是否可以继续使用像@Input、@Ouptut这样的注释来定义单个处理器，在这一点<e
浏览 30提问于2021-01-22得票数 2
这是关于升级生产中的现有代码库，这些代码库使用来自kafka-clients，kafka-streams，spring-kafka 2.4.0到2.6.x的窗口，并将spring-boot-starter-parent2.2.2.RELEASE升级到2.3.x，因为2.2与kafka-streams 2.6不兼容。streams code
浏览 20提问于2021-05-15得票数 2
我想在我的春季云流卡夫卡应用程序中为我的生产者设置acks=all属性。我试过这样做：和和
spring.cloud<
浏览 1提问于2019-04-24得票数 1
我无法使用文档()中指定的语法更改通道(或绑定)的Serde。假设我的通道是pcin，我理解我应该使用折叠属性spring.cloud.stream.kafka.streams.bindings.pcin.producer.valueSerde和spring.cloud.stream.kafka.streams.bindings
浏览 1提问于2018-04-18得票数 0
回答已采纳
在我的代码上，甚至在示例代码上，我总是会遇到相同的错误：
java.lang.IllegalStateException: Error retrieving state store: prod-id-count-store$0(InteractiveQueryService.java:115) ~[spring-cloud-stream-binder-kafka-streams-
浏览 18提问于2022-10-13得票数 0
回答已采纳
是否可以在application.yml中仅为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题我希望我的制作人只负责创建主题。我正在使用spring-cloud-stream</
浏览 30提问于2020-11-24得票数 0
回答已采纳
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。vanilla java的kafka驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何注入这两个参数。目前，我将&
浏览 21提问于2019-04-16得票数 2
回答已采纳
这是这个question的续集。我可以将“普通”Apache Kafka绑定器和功能模型一起使用吗？到目前为止，使用基于注释的配置，我在一个应用程序中混合了这两者，spring-cloud-stream-binder-kafka用于简单的消费/生产，spring-cloud-stream</e
浏览 21提问于2019-10-16得票数 0
回答已采纳
在使用@StreamListener收听kafka主题之后，在RuntimeException、全局erroChannel或主题特定errorChannel (topic.group.errors)上没有收到任何错误消息spring.cloud.stream.kafka.streams.binder.brokers=localhost
spring.cloud.
浏览 1提问于2019-06-07得票数 0
回答已采纳
1回答
我对Kafka Stream API非常陌生。我有一个这样的KStream： KStream<Long,String> joinStream = builder.stream(("output")); 带有记录数的KStream值如下所示：我需要构建一个Rest API，它将根据值、利润和spotPrice进行计算。但我一直在努力获取最后一张唱片的价值。
浏览 20提问于2021-03-29得票数 1
我正在尝试连接其中一个托管kafka提供商的kafka streams身份验证类型为SASL_SSL下面是我的application.yml cloud: binder:
浏览 2提问于2018-10-08得票数 0
我正在尝试使用Kafka Streams的函数式风格，并且需要为我的应用程序设置信任库和密钥库。下面是一个非常小的代码片段： spring: stream: binder: security.protocol: SS
浏览 10提问于2021-04-09得票数 0
我有一个应用程序，当使用转换器执行去重复时，它在处理器API中使用StateStore。 @KafkaStreamsStateStore(name:38)引起的Avro消息
尽管
浏览 0提问于2019-06-17得票数 3
我正在尝试使用spring-cloud-stream，并创建official blog的示例项目。 实现与本文完全相同。initializr上选择了Cloud Stream和Spring for Apache Kafka Stream，并添加了ShadowJar。:kafka-streams'
implementation 'org.springfram
浏览 34提问于2021-04-12得票数 0
这是我的配置文件： brokers: localhost:9093
spring.cloud.stream.kafka.streams.binder.
浏览 4提问于2020-10-24得票数 1
回答已采纳
我正在尝试(单元)测试使用Kafka DSL的Spring Cloud Stream Kafka处理器，但收到以下错误"Connection to node -1 could not be established我同时尝试了EmbeddedKafka和TestBinder，但我仍然有相同的行为。我尝试从开始(它可以工作)，并且我调整了应用程序以使用Kafka DSL，并且几乎保留了测试类<
浏览 68提问于2018-06-01得票数 4
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号