我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
我使用spring-cloud-stream-kafka-binder-3.0.4批量消费消息，消费后将消息转换为object，但得到上述异常。=TOPIC.FEED.NAMEspring.cloud.stream</e
浏览 64提问于2021-09-17得票数 0
回答已采纳
通过application.properties文件，我确实可以看到可用的选项(Spring.kafka.suer.*)来配置Kafka使用者。
但是，我无法找到的是配置确认模式的方法。
浏览 3提问于2017-07-20得票数 0
回答已采纳
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何注入这两个参数。目前，我将"basic.auth.user.info"和"basic.auth.credentials.source"放在applic
浏览 21提问于2019-04-16得票数 2
回答已采纳
我在本地运行了我的动物园管理员和3个kafka代理。我启动了一个生产者和一个消费者。我可以看到消费者正在消费消息。然后，我启动了三个具有相同消费者组名称的消费者(由于这是一个spring启动项目，所以端口不同)。但我发现所有的消费者现在都在消费(接收)消息。这是我的属性文件
spring.cloud.stream.bindings.input.destination=timerTo
浏览 3提问于2016-09-29得票数 0
他们的行为或多或少都是一样的--比如生产、加工和消费。https://cloud.spring.io/spring-cloud-static/spring-cloud-stream-binder-kafka/3.0.0.RELEASE/reference/html/spring-cloud-stream
浏览 20提问于2020-07-19得票数 0
回答已采纳
我有一个春季云流卡夫卡消费者服务，在那里确认是手动完成的。提供一个固定的消费群体。spring.cloud.stream.bindings.input.group=sampleconsumergroup
重置集和spring.cloud.stream.kafka.bindings.input.consumer.resetOffsets=true spring.cloud.stream</em
浏览 2提问于2019-03-06得票数 1
回答已采纳
对于有多个分区的主题-2)是否可以为每个分区配置多个线程，或者是否必须手动将其从侦听器线程传递到工作池？
浏览 5提问于2017-02-05得票数 6
回答已采纳
我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer如果我这样做，它就会起作用 spring.cloud.stream.bindings.scheduler-in-from-external-event.conte
浏览 13提问于2020-10-28得票数 0
回答已采纳
我使用的是Spring Boot2.1.1.RELEASE和Spring Cloud Greenwich.RC2，spring-cloud-stream-binder-kafka的托管版本是2.1.0RC4spring.cloud.stream.bindings.input.group=consumer-gp-1spring.cloud.stream.<
浏览 29提问于2019-03-18得票数 2
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。o.s.c.s.b.k.KafkaMessageChannelBinder :无法使用contentType java.lang.NullPointerException反序列化io.igx.android.Sensor
我有消费者端的spring.cloud.stream.bi
浏览 6提问于2017-03-09得票数 1
我想每15分钟批量消费一次消息。为此，我设置了这些属性， spring.cloud.stream.kafka.binder.consumer-properties.max.poll.records=5000000spring.cloud.<em
浏览 131提问于2021-09-22得票数 0
回答已采纳
1回答
我的问题是如何使用Spring Cloud Stream Kafka管理多实例。让我解释一下，在Spring Cloud Stream微服务上下文(eureka，configserver，kafka)中，我希望拥有相同微服务的两个实例。${hostname}它工作得很好，但问题是，每次我启动我的服务的新实例时，它都会在kafka中创建一个新的消费者组。现在我有很多闲置的消费群体。1：https:&#
浏览 44提问于2020-07-17得票数 2
回答已采纳
我有使用spring.cloud.stream.kafka.binder.brokers=KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes=ZKNODE_URL的消费者
如果我尝试运行spring boot消费者应用程序，但bean未启动，则整个spring boot应用程序无法启动: rg.springfram
浏览 4提问于2017-03-21得票数 0
我们已经实现了一个应用程序来生成消息和标题，并将其发送到kafka主题。消费者端应用程序正在聆听卡夫卡的主题。为了禁用将报头(包括contentType)嵌入到有效负载中，我们使用了spring.cloud.stream.bindings.input.consumer.headerMode我们使用的是spring-
浏览 2提问于2019-05-08得票数 0
我正在使用spring-cloud-starter-stream-kafka创建一个Kafka消费者绑定，并将spring.cloud.stream.bindings.input.consumer.autoStartup配置为false (https://cloud.spring.io/spring-cloud-static/
浏览 68提问于2020-06-25得票数 0
回答已采纳
我一直在玩spring云流(1.0.BUILD-使用kafka绑定程序的快照)，并注意到在离线的消费者中，发送的任何消息都会丢失。当我启动消费者时，它不会处理发送给kafka的积压请求。
浏览 0提问于2016-03-06得票数 4
回答已采纳
使用spring- Dalston.SR4运行spring引导的Dalston.SR4程序。我通过云流进行了研究，特别是关于kafka绑定器的使用，但在一些配置方面还不清楚：
当我们从卡夫卡经纪人那里消费时，我们真的需要设置spring.cloud.stream.考虑到设置了spring.cloud.stream.bindings.<channel>.group，我不明白为什么需要这样做。还是说只有在
浏览 2提问于2017-10-13得票数 0
回答已采纳
=TX-spring.cloud.stream.kafka.binder.transaction.producer.configuration.ack=allspring.cloud.stream.kafka.binder.transaction.producer.configuration.retries=10spring.cloud.stream.kafka.bindings.input.con
浏览 5提问于2021-10-04得票数 0
1回答
我尝试了以下的消费者 private ConsumerFactory consumerFactory;
log.info("record {}", record); }spring.cloud.stream.bindings.pollableInput.destinatio
浏览 1提问于2020-02-05得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
