Debezium Извлечение состояния новой записи SMT не работает должным образом в случае УДАЛЕНИЯ

#apache-kafka #apache-kafka-connect #debezium #апач-кафка #apache-кафка-подключение #дебезиум Вопрос: Я пытаюсь применить Debezium, New Record State Extraction SMT используя следующую конфигурацию: "transforms": "unwrap", "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState", "transforms.unwrap.drop.tombstones": true, "transforms.unwrap.delete.handling.mode": "rewrite", "transforms.unwrap.add.fields": "db,schema,table,txId,ts_ms" Для…