我试着用春天的云流卡夫卡流来阅读卡夫卡。然后，在一分钟的时间窗口内将事件聚合起来，并将其用于不同的主题。然后，我需要从主题中读取聚合事件，并将其写入不同的主题，同时将主题绑定到另一个kafka集群中的不同主题。但是我得到了下面的活页夹例外。environment: cloud:
stream:cloud</em
浏览 0提问于2019-05-17得票数 1
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。根据these的说明，需要设置这两个配置参数才能成功访问模式注册表服务器。驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何注入这两个参数。目前，我将"basic.auth.u
浏览 21提问于2019-04-16得票数 2
回答已采纳
我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
我想把spring.kafka.streams.*移到spring.cloud.stream下--这可能吗？spring: config: server: stream: input_technischerplatz:
浏览 43提问于2020-04-27得票数 0
2回答
我有两个非常简单的春云流应用程序。Service3，消息生产者，通过绑定器-卡夫卡向消费者Service4发送消息。
我用春云雪橇来追踪它们之间的跨度。Marshal跨越Spring云流绑定器compile('org.springframework.cloud:spring-cloud-sleuth-stream') compile('org.springframewo
浏览 9提问于2017-02-22得票数 0
我需要升级kafka broker到版本2.x，所有的模块都很好，只有一个组件。它使用的是spring cloud stream和kafka绑定器版本2.0.2。在内部，它似乎在使用kafka-client 1.0.2此外，sprin
浏览 12提问于2021-02-19得票数 1
回答已采纳
1回答
我试图使用来桥接两个Kafka集群(本质上是一个花哨的MirrorMaker实例)，使用bridge应用程序。正如文档中所述，我定义了两个绑定器。卡夫卡-基地1应该是默认的，卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供，例如: app.bridge.spring.cloud.stream.bindings.output.binder=kafka-qa2我的SCDF application.yaml包含两个<
浏览 6提问于2017-02-03得票数 0
回答已采纳
在Spring Boot with Kafka中，我可以如下设置ConsumerFactory的属性： @EnableKafkapublic class KafkaConsumerConfigCloud Streams和Kafka Streams时，所有属性似乎仅通过资源文件夹中的application.properties或application.yml文件输入 spring.cloud.stream
浏览 25提问于2019-01-31得票数 1
1回答
我使用Kafka实现微服务之间的Asyng调用，使用Spring进行日志记录。日志记录是正常的，但是当有消息从Microservice1到Microservice2时，日志记录的消息具有不同的跟踪ID。难道他们不需要有相同的追踪Id但有不同的SpanId吗？有没有特殊的配置？
浏览 2提问于2016-12-02得票数 4
回答已采纳
是否可以为Apache Kafka配置Spring Cloud DataFlow的身份验证？我可以在哪里看到示例？
谢谢。
浏览 15提问于2016-08-03得票数 0
我正在尝试将单独的Serde放在我的每个消费者身上，而不是所有消费者。例如，这会将Avro反序列化程序添加到我的应用程序中的所有使用者。我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer如果我这样做，它就会起作用
浏览 13提问于2020-10-28得票数 0
回答已采纳
我正在开发一个Spring Cloud Stream Kafka应用程序。我只添加了消费者来使用来自主题的消息，并使用FIX协议将它们传递给第三方。下面是我的application.yml文件：spring.cl
浏览 7提问于2020-07-30得票数 0
回答已采纳
我不知道如何用kafka做一个样本测试，我试着按照弹簧指南做，但不起作用。 assertThat(received.getPayload(), equalTo("hello"));}
我的类生成器是: Failed to instantiate [org.springframework.cloud.stream.test.binder.MessageCollec
浏览 20提问于2017-02-17得票数 1
在遵循之后，我能够直接将主题中的数据消费到我的Java对象中。以下属性完成了所有的魔术 spring.json.value.default.type: com.xxxx.datamapper.domain.FormData
但是，现在我想在一个spring引导应用程序中运行两个流侦听器。为此，我需要为每个使用者绑定进行类似的配置。<em
浏览 13提问于2020-05-21得票数 0
在使用spring:1.5.1时，我得到了下面提到的错误，但在使用spring:1.4.4时却没有得到这样的错误。spring.cloud.stream.bindings.input.content-type=application/json
浏览 17提问于2017-02-01得票数 4
回答已采纳
我从我的teammates.They得到了相同的问题，问我卡夫卡主题，春天云流频道和春天云流目的地之间的不同点是什么。我们试着在网上搜索，但找不到任何线索。
浏览 2提问于2019-02-14得票数 0
1回答
我需要将使用的无效消息发送到DLT中，但在单独的引导服务器中。我目前有这样的配置： spring.cloud.stream.binders.some-kafka-binder.type=kafka
spring.cloud.stream.binders.some-kafka-binder.environment.spring.cloud<
浏览 22提问于2021-10-18得票数 1
我使用的是带有卡夫卡绑定的小枝云流。我有多个不同内容类型的消费者。是否有一种方法可以配置反序列化器的基础上？
浏览 0提问于2021-03-16得票数 0
回答已采纳
:183) ~[spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
浏览 5提问于2020-03-25得票数 0
我的要求是使用绑定可视化和控制。(POST /actuator/bindings/{bindings-name} {"state":"PAUSED"})我正在使用的版本如下。org.springframework.cloud:spring-cloud-stream:3.0.1.RELEASE
org.springfram
浏览 3提问于2020-02-18得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
实时音视频
对象存储
腾讯云开发者
