我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
1回答
卡夫卡-基地1应该是默认的，卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供，例如: app.bridge.spring.cloud.stream.bindings.output.binder=kafka-qa2我的SCDF application.yaml包含两个绑定： cloud: applicationProperties: spring<
浏览 6提问于2017-02-03得票数 0
回答已采纳
我是spring cloud的新手，我正在寻找使用kafka broker的spring cloud stream的任何简单完整的示例。
浏览 5提问于2017-03-13得票数 0
属性文件spring: spring: stream::9092 type: kafka
environment
浏览 0提问于2019-05-17得票数 1
=headers['kafka_messageKey']
spring.cloud.stream.kafka.binder.producer-properties.key.serializer=org.apa
浏览 14提问于2022-01-21得票数 0
回答已采纳
1回答
我在application.properties中指定了但是当我从仪表板部署一个流时，我可以在日志中看到另外，任何其他属性(如Kafka绑定器或zkNodes )都不会从application.properties中读取，但会使用默认值，从而使部署失败。
如何为所有已部署的应用程序/流覆盖这些属性？
浏览 6提问于2017-03-09得票数 0
回答已采纳
我想把spring.kafka.streams.*移到spring.cloud.stream下--这可能吗？spring: config: server: stream: input_technischerplatz:
浏览 43提问于2020-04-27得票数 0
1回答
springBootVersion = '1.4.2.RELEASE' dependencies { compile('org.springframework.cloud:spring-cloud-starter-strea
浏览 1提问于2016-11-25得票数 1
回答已采纳
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何注入这两个参数。目前，我将"basic.auth.user.info"和"basic.auth.credentials.source"放在application.yml文件中的"
浏览 21提问于2019-04-16得票数 2
回答已采纳
2回答
:spring-boot-starter-thymeleaf') compile('org.springframework.cloud:spring-cloud-starter-sleuth') //Marshal跨越Spring云流绑定器compile('org.springframework.cloud:spring-cloud-sleuth-stream')
浏览 9提问于2017-02-22得票数 0
Cloud Streams和Kafka Streams时，所有属性似乎仅通过资源文件夹中的application.properties或application.yml文件输入 spring.cloud.stream.bindingsdestination: data2 contentType: application/jsonspring.cloud.stre
浏览 25提问于2019-01-31得票数 1
我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer如果我这样做，它就会起作用 spring.cloud.stream.bindings.scheduler-in-from-external-event.content-type=a
浏览 13提问于2020-10-28得票数 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.prod
浏览 1提问于2018-04-18得票数 0
回答已采纳
我的application.properties：spring.cloud.stream.bindings.input.consumer.headerMode=rawspring.<em
浏览 1提问于2017-07-29得票数 1
我使用的是spring cloud stream kafka。=10.6.22.20spring.kafka.bootstrap-servers=10.6.22.20:9092
#spring.kafka.consumer.group-id=example-consumer-
浏览 0提问于2017-06-21得票数 0
我使用的是spring cloud stream kafka。message.max.bytes=20000000spring.cloud.stream.kafka.bindings然而，我想概括一下spring
浏览 6提问于2019-08-28得票数 4
在使用Spring引导、事件中心和Kafka时，我正面临上述问题。下面是我所关注的依赖关系。<groupId>org.apache.kafka</groupId> <version2.7.0</version>
<
浏览 5提问于2021-04-27得票数 0
1回答
现在，我尝试用kafka创建Message函数来使用spring-cloud-stream-bind-kafka，但效果不太好。Configuration:build.gradle:compile "org.springfra
浏览 0提问于2019-06-05得票数 0
回答已采纳
1回答
at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.ensureDlqMessageCanBeProperlySerialized(KafkaMessageChannelBinder.java:1037)
at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.lambda我怀疑我没有为它使
浏览 1提问于2019-08-14得票数 0
回答已采纳
云服务器
ICP备案
即时通信 IM
云直播
对象存储
腾讯云开发者
