Соединитель для раковины Kafka Connect "Passthrough"

Question

Поддерживает ли разъем приемника kafka jdbc запись того, что он потребляет, в другую тему.Я ищу механизм сквозного прохождения и проиллюстрирован ниже.Если это не так, я мог бы связать приемник и источник (читая от того, где написал приемник), но не думаю, что это будет так же эффективно.Возможно, я мог бы изменить существующий разъем приемника для достижения этой цели?

Topic 1 -> Sink Connector ->  Topic 2
               |
               V
               DB

Answer 1

Я бы предложил написать простое приложение Kafka Streams, которое перенаправляет все из темы 1 в тему 2. И использует коннектор как есть для загрузки содержимого из темы 1 в БД.

Answer 2

Connect Framework позволяет записывать в раздел очереди недоставленных сообщений записи, вызывающие ошибки, но в Connect такой функции, как tee, нет.

Если вы хотите, чтобы источник прочитал то, что написал приемник, то у вас будет два разъема.

Например,

JDBC_Sink -> DB -> Debezium -> Topic