弹簧集成卡夫卡:入站通道适配器与消息驱动适配器

Question

我是使用弹簧集成卡夫卡的新手。我正在阅读文档，并在入站通道适配器和消息驱动的通道适配器之间感到困惑。有人可以解释它们之间的区别.Kafka 的 Spring 集成也有一些错误处理机制，就像 amqp/rmq(使用 dlq( 的 Spring 集成中存在的机制一样。

PS ：我们正试图从兔子mq转向kafka作为春季集成框架中的消息源

谢谢

Answer 1

消息驱动的适配器类似于 rabbitmq 入站适配器，因为只要主题中有记录可用，消息就会"推送"到集成流中。

入站通道适配器使用"拉取"模型，您可以在其中按计划轮询消息。RabbitMQ 有一个等效项(从 5.0.1 开始(，但它目前无法使用 XML 进行配置。

一些错误处理机制

SIK 组件是与所有其他 SI 组件相同的类的子类，因此通常可以使用相同的功能，是的。