在Spring Boot with Kafka中,我可以如下设置ConsumerFactory的属性: @EnableKafkapublic class KafkaConsumerConfigCloud Streams和Kafka Streams时,所有属性似乎仅通过资源文件夹中的application.properties或application.yml文件输入 spring.cloud.stream
我试图使用来桥接两个Kafka集群(本质上是一个花哨的MirrorMaker实例),使用bridge应用程序。正如文档中所述,我定义了两个绑定器。卡夫卡-基地1应该是默认的,卡夫卡-基地2可以作为输出活页夹在定义或部署属性中提供,例如: app.bridge.spring.cloud.stream.bindings.output.binder=kafka-qa2我的SCDF application.yaml包含两个绑定:
spring
但是,当我试图处理按键计算事件的流时,我在运行应用程序时会得到Serde class not found: org.apache.kafka.common.serialization.Serde$StringSerde=1000
spring.cloud.stream.kafka.streams.binder.configuration.default.key.serde=org.apache.kafka.common.seriali