1回答
stream部分： spring.cloud.stream.kafka.streams.binder.configuration.default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
spring.cloud.stream.kafka.streams.binder.configuration.default.value.serde: org.apache.
浏览 29提问于2019-05-03得票数 1
1回答
卡夫卡-基地1应该是默认的，卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供，例如: app.bridge.spring.cloud.stream.bindings.output.binder=kafka-qa2我的SCDF application.yaml包含两个绑定： cloud: applicationProperties: spring:
浏览 6提问于2017-02-03得票数 0
回答已采纳
打扰了!我从我的teammates.They得到了相同的问题，问我卡夫卡主题，春天云流频道和春天云流目的地之间的不同点是什么。我们试着在网上搜索，但找不到任何线索。
浏览 2提问于2019-02-14得票数 0
1回答
我想使用Spring Cloud Stream来消费和处理Apache Kafka队列，并将它们写入MongoDB。我看到有一个选项可以使用这个库，这样函数将是反应性的，或者是命令性的。在大多数Spring项目中，命令式方式是默认的，但据我所知，在spring cloud stream中，反应式范例是默认的。 我想知道什么被认为是最“稳定”的api，例如，对于企业推荐使用什么？
浏览 21提问于2021-11-15得票数 0
回答已采纳
=headers['kafka_messageKey']
spring.cloud.stream.kafka.binder.producer-properties.key.serializer=org.apache.kafka
浏览 14提问于2022-01-21得票数 0
回答已采纳
我想把spring.kafka.streams.*移到spring.cloud.stream下--这可能吗？enabled: false bindings: destination: technischerplatz: false brokers: '${values.sprin
浏览 43提问于2020-04-27得票数 0
我有使用spring.cloud.stream.kafka.binder.brokers=KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes=ZKNODE_URL的消费者
如果我尝试运行spring boot消费者应用程序，但bean未启动，则整个spring boot应用程序无法启动: rg.springframework.context.ApplicationCo
浏览 4提问于2017-03-21得票数 0
1回答
我在application.properties中指定了但是当我从仪表板部署一个流时，我可以在日志中看到另外，任何其他属性(如Kafka绑定器或zkNodes )都不会从application.properties中读取，但会使用默认值，从而使部署失败。
如何为所有已部署的应用程序/流覆盖这些属性？
浏览 6提问于2017-03-09得票数 0
回答已采纳
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何注入这两个参数。目前，我将"basic.auth.user.info"和"basic.auth.credentials.source"放在application.yml文件中的"spring.c
浏览 21提问于2019-04-16得票数 2
回答已采纳
我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
在微服务架构中使用Kafka作为消息传递系统，我想知道首选的是Spring Kafka还是Spring Integration Kafka，为什么？另外，我们根据什么因素来决定选择哪一个？
浏览 75提问于2020-04-13得票数 2
我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer如果我这样做，它就会起作用 spring.cloud.stream.bindings.scheduler-in-from-external-event.content-type=applicationspri
浏览 13提问于2020-10-28得票数 0
回答已采纳
2回答
:spring-boot-starter-thymeleaf') compile('org.springframework.cloud:spring-cloud-starter-sleuth') //Marshal跨越Spring云流绑定器compile('org.springframework.cloud:spring-cloud-sleuth-stream') compile('org.springframework.cl
浏览 9提问于2017-02-22得票数 0
1回答
我正在尝试使用spring应用程序中的kafka主题。: bindings: destination: com.tonitingaurav.kafka.logPublisher是用不同的微服务编写的。</groupId>
<artifactId>spring-cloud-stream-binder-kafka<
浏览 4提问于2021-11-29得票数 2
我是新手阿帕奇Kafka，我已经创建了一个简单的Spring启动生产者和消费者项目，可以生产和消费正确的消息，但现在我想与Kafka流工作，但面临着困难找到一个简单的POC的Kafka流与Spring
浏览 60提问于2020-08-15得票数 0
回答已采纳
假设我的通道是pcin，我理解我应该使用折叠属性spring.cloud.stream.kafka.streams.bindings.pcin.producer.valueSerde和spring.cloud.stream.kafka.streams.bindings.pcin.producer.keySerde=pcs
spring.cloud.stream.bindings.pcout.producer.use-native-encoding=tr
浏览 1提问于2018-04-18得票数 0
回答已采纳
1回答
} compile('org.springframework.cloud:spring-cloud-stream')}
dependencyManagement {import
浏览 1提问于2016-11-25得票数 1
回答已采纳
云服务器
ICP备案
即时通信 IM
云直播
实时音视频
腾讯云开发者
