Я хочу использовать коннектор debezium mongo, чтобы:
-> получать события от mongo
-> получать их в моей кафке
-> читать из kafka
моя проблема в том, что когда debezium получает события обновления от mongo, он только отправляет обновленные поля:
Значение события изменения обновления в этой коллекции будет фактически иметь ту же самую схему, иего полезная нагрузка будет структурирована одинаково, но будет иметь разные значения.В частности, событие обновления не будет иметь значения after и вместо этого будет иметь строку исправления, содержащую JSON-представление идемпотентной операции обновления.
, и мне было интересно, могу ли я как-то его настроить, потому что естьнекоторые поля, которые я хотел бы получить с событиями обновлений.