Spring Integration Kafka: адаптер входящего канала против адаптера, управляемого сообщениями

Question

Я новичок в использовании пружинной интеграции кафки. Я читал документы и запутался между адаптером входящего канала и адаптером канала, управляемого сообщениями. Может кто-нибудь объяснить разницу между ними. Также у Spring интеграции для kafka есть некоторый механизм обработки ошибок, например, тот, который присутствует в Spring интеграции для amqp / rmq (с использованием dlq).

PS: мы пытаемся перейти от кролика mq к kafka как источнику сообщенийв рамках весенней интеграции

спасибо,

Answer 1

Адаптер на основе сообщений аналогичен входящему адаптеру rabbitmq в том смысле, что сообщения «выталкиваются» в поток интеграции при наличии записей в теме.

Адаптер входящего канала использует модель «тянуть», где вы опрашиваете сообщения по расписанию. Существует эквивалент для RabbitMQ (начиная с 5.0.1), но в настоящее время он не настраивается с помощью XML.

некоторый механизм обработки ошибок

Компоненты SIK являются подклассами одного и того жеклассы, как и все другие компоненты SI, так что те же самые возможности, как правило, доступны, да.