我们有一个场景,我们希望在cluster#1上消费来自kafka主题的数据,但在cluster#2上创建KTable主题(重新分区和changelog)。
通道绑定-
spring.cloud.stream.bindings.member.destination: member
spring.cloud.stream.bindings.member.consumer.useNativeDecoding: true
spring.cloud.stream.bindings.member.consumer.headerMode: raw
spring.cloud.stream.kafka.stre
生产者有没有办法将消息发送到代理中特定的主题部分? 到目前为止,我可以发送有2个分区的主题,但不能控制发送到特定的分区。 Component
@EnableBinding(Source.class)
public class RsvpsKafkaProducer {
private static final int SENDING_MESSAGE_TIMEOUT_MS = 10000;
private final Source source;
public RsvpsKafkaProducer(Source source) {
this.so
我用春云条纹Kstream。我测试一个主题&一个@StreamListner。没事的。
我为两个KStream输入修改我的代码。(两个@StreamListener)但是,弹簧云错误..。
***************************
APPLICATION FAILED TO START
***************************
Description:
The bean 'stream-builder-process', defined in null, could not be registered. A bean with that
我正在开发一个Spring Cloud Stream Kafka应用程序。我只添加了消费者来使用来自主题的消息,并使用FIX协议将它们传递给第三方。
到目前为止,它工作得很好,但现在第三方发回了响应,我想将它们生成一个新的主题。当我在现有代码中添加一个供应商时,它开始出现奇怪的行为。从remoteHost broker到本地主机的bootstrap.servers配置更改,并开始显示以下错误:
[AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be es