我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
我正在寻找关于sasl.jaas.config的配置说明，当你有2个不同的主题，每个都有不同的连接密钥？我使用的是spring-cloud-starter-stream-kafka 3.1版。我没有使用spring-cloud-stream-binder-kafka，我也不知道that would solve my problem。当只涉及一个主
浏览 262提问于2021-04-01得票数 0
回答已采纳
我正在尝试使用Spring cloud和绑定器在同一个spring启动应用程序中实现Kafka consumer和Kafka producer。我认为问题出在kafka生产者和消费者的多个/不同的jaas配置上。Kafka消费者<
浏览 186提问于2020-03-25得票数 1
使用spring-cloud-stream的kafka绑定器，如何配置并发消息消费者(在单个消费者jvm中)？Kafka文档提到了循环分区。
s-c-s文档根本没有提到spring.cloud.stream.bindings.*.concurrency，尽管这在我上面描述的用例中似乎很重要。使用生产者配
浏览 2提问于2016-03-08得票数 7
1回答
弹簧云函数路由
、、、、
=falsespring.cloud.stream.kafka.bindings.articleAggregated.producer.configuration.client.id=articleAggregated
spring.cloud.stream.kaf
浏览 4提问于2021-11-17得票数 0
回答已采纳
类具有和的专用属性。但是，没有管理属性。我想知道在设计时，是否有具体的原因没有考虑到管理属性。因此，由于我不能使用KafkaBinderConfigurationProperties配置特定的管理属性，所以其他的替代方法是使用或。以下是我认为上述两种选择的一些缺点，
对于使用spring.cloud
浏览 27提问于2022-11-18得票数 1
我正在使用spring cloud stream Kafka活页夹编写一个Kafka生产者和消费者。我希望访问生产者和消费者中的以下信息b)分区我确实检查了文档，但并不能真正找到在哪里可以完成这项工作。我在文档中看到的就是指定一个recordMetadataChannel作为生产者&#x
浏览 0提问于2021-03-18得票数 1
是否可以在application.yml中仅为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题我希望我的制作人只负责创建主题。我正在使用spring-cloud-stream和kafka-streams绑定器。 在更一般<
浏览 30提问于2020-11-24得票数 0
回答已采纳
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。在使用消息时会发生以下错误：
错误7059 --afka-侦听器-1 o.s.c.s.b.k.KafkaMessageChannelBinder :无法使用contentType java.lang.NullPointerEx
浏览 6提问于2017-03-09得票数 1
我有一个简单的流处理器(不是消费者/生产者)，它看起来像这样(Kotlin)fun processFoo():Function<KStream<FooName, FooAddress>,这是我的配置文件： brokers: localhost:9093
spring.cloud
浏览 4提问于2020-10-24得票数 1
回答已采纳
2回答
我必须在我的应用程序中定义主题。我使用来配置应用程序之间的消息传递。春云流在背景中采用卡夫卡粘合剂。我想知道用分区和复制因子创建主题的最好方法是什么，我想知道我们是应该配置它本身，还是应该使用application.properties。如果分区号可以是一个依赖于使用者编号的动态值，那该怎么办？请给我提示，以正确的方式实施。
浏览 5提问于2022-06-29得票数 0
回答已采纳
我正在运行Stream应用程序，在该应用程序中，我从Kafka主题读取事务，处理事务，然后将它们发送到IBM。当没有与IBM的连接时，我试图处理这个错误，以防止事务丢失。在本例中，jms模板将抛出一个异常，流侦听器不会提交事务。期望的行为是事务保持在Kafka主题中，而流侦听器再次读取它。然而，消息似乎只被消耗了一次，并且没有发生“回滚”。要做到这一点，以下是我的心声： cloud:
<e
浏览 1提问于2019-08-02得票数 1
回答已采纳
1回答
我试图使用StreamBridge SpringBoot和RabbitMQ作为代理来创建动态的n个队列--我以前用这种方法创建了队列spring.cloud.stream.bindings.sender-in-0.destination=sampleQueuespring.
浏览 5提问于2022-11-10得票数 0
2回答
运行时配置更新
、、、、
我使用Spring云流和Kafka绑定器来使用SASL连接到Kafka集群。SASL配置如下所示：spring.cloud.stream.kafka.binder.config
浏览 3提问于2021-03-26得票数 0
我正在使用spring-cloud-starter-stream-kafka创建一个Kafka消费者绑定，并将spring.cloud.stream.bindings.input.consumer.autoStartup配置为false (https://cloud.spring.io/spring-clou
浏览 68提问于2020-06-25得票数 0
回答已采纳
我正在使用spring cloud stream和使用confluent's schema registry的Aiven的模式注册表。Aiven的模式注册表使用密码保护。根据these的说明，需要设置这两个配置参数才能成功访问模式注册表服务器。驱动时，一切都很好，但是如果我使用Spring cloud stream，我不知道如何注入这两个参数。目前，我将
浏览 21提问于2019-04-16得票数 2
回答已采纳
我需要通过Spring Boot启用kafka连接到event hub，并且我有连接字符串和名称空间，我应该在哪里连接。我正在使用这样的依赖关系我找到了一个教程，其中我需要从本地机器使用az login登录到azure并创建auth文件，但是我得到了应该使用的连接字符串，所以有没有办法只使用如下命名空间的连接字符串
浏览 51提问于2020-08-03得票数 4
回答已采纳
我知道如何使用命令式编程方法定义生产者，但我找不到如何使用函数式编程方法定义生产者。我读了Spring Cloud Stream Binder的文档，但只发现如何定义消费者，或者消费者和生产者(例如，从主题中获取信息，转换数据并发送到另一个主题)。因此，我不知道是否可以继续使用像@Input、@Ouptut这样的注释来定义单个处理器，在这一点上我非常困惑，因为库表明这些注释已被弃用
浏览 30提问于2021-01-22得票数 2
在我的制作人application.properties中，我有spring.cloud.stream.bindings.output.producer.partitionCount=4
我的消费者application.properties看起来像这样spring
浏览 0提问于2016-08-18得票数 0
我让一个非SCS生产者(使用Spring-Kafka的应用程序)尝试向一个SCS消费者订阅的主题发送一个json序列化对象。放在主题上的信息是-SCS消费者的配置如下。spring.cloud.<em
浏览 0提问于2017-02-10得票数 1
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
