使用kafka流作为输入通道和rabbitmq作为输出的spring cloud stream multi binder的任何示例？

Question

我们有一个需求，通过 kafka 流消费数据并将输出发送到 rabbitmq 通道。有没有类似的可用示例？

我试过了 - https://github.com/spring-cloud/spring-cloud-stream-samples/blob/master/multibinder-samples/multibinder-kafka-rabbit/src/main/resources/application.yml

spring.cloud.stream.default-binder: 卡夫卡

但是得到这个 - java.lang.IllegalStateException：绑定器“kafka”无法绑定 com.sun.proxy.$Proxy103

Answer 1

在同一处理器中混合两种不同的绑定目标类型（KStream 和 MessageChannel (StreamListener)）目前存在一些限制。作为一种变通方法，您可以在同一个应用程序中拥有两个 StreamListener 方法。一个是普通的 Kafka Streams 处理器，其中有一个输入 KStream 和一个输出 KStream。第二个StreamListener 方法是一个多绑定器场景，您从 Kafka 主题接收并输出到 Rabbit 交换。我认为这应该解决您在上面描述的用例。让我们知道这是否有效。我们可以添加一个示例应用程序来演示这一点。