Stream编程模型没看懂啊？

Question

问题一：Stream创建了两个binding，左边的binding连接Rabbit MQ，右边的binding连接Kafka。这句话写的是Stream底层是用这种模型实现消息驱动的吗？那为什么还要用RocketMQ呢？

问题二：input binding会从Rabbit MQ消费消息，经过一段代码的处理，把处理结果输送到Kafka。

1. 这里说的从Rabbit MQ消费消息，指的是我们定义的消息吗？

2. 然后把我们定义的消息又输送到Kafka吗？这里我就更糊涂了，消息是输送到kafka的，但是是从Rabbit MQ去消费的？消息不在一个中间件里面，咋整的？

3. 消息输送到kafka，从Rabbit MQ消费，那不是和Rocket MQ不就没关系了吗？怎么topic却能在RocketMQ的控制台找到？

Answer 1

大目 2022-11-28 11:01:01

问题1：这是stream官方的图，用来体现stream的强大：可以用相同的编程模型，对接不同的mq产品。你可以理解为，用它之后，你用rocketmq/kafka/rabbit，代码都是一样的，stream屏蔽了不同mq产品之间的代码差异。

问题2：理解一下问题1