Используя разъём debezium mongo, я отправляю данные из mongodb в kafka. У меня есть 4 коллекции: транзакции, кошельки, карты и пользователи.
Перед запуском кафки-коннектора я создал тему "mongo_conn.digi.users". и когда я перезапустил его, Kafka -nector создал собственную тему "mongo_conn.digi.cards" и "mongo_conn.digi.transactions" и получил от них данные. Однако он не создавал тему для кошельков и не передавал данные в "mongo_conn.digi.users".
Итак, я удалил «mongo_conn.digi.users» и перезапустил соединитель. Как и ожидалось, "mongo_conn.digi.users" был воссоздан kafka-разъемом, но ничего не было выдвинуто. Также не было создано ни одной темы для коллекции кошельков.
Я пытаюсь найти причину того, почему Соединитель не создал тему для темы кошельков и почему kafka-Соединитель не выдвигает какие-либо данные для пользователей.
это мой выходной разъем