Я использую команду:
# bin / connect-standalone.sh config / connect-standalone.properties config / debezium-config.properties
Мои debezium-config.properties:
name=publications-connector
database.hostname=localhost
database.port=5432
database.user=andy
database.password=postgres
database.dbname=postgres
database.server.name=dbserver1
table.whitelist=public.publications
В Postgres у меня есть таблица публикаций
Когда я вставляю новую запись в таблицу публикаций, я вижу, что мой потребитель показывает новое сообщение в формате json.
Однако, когда я обновляю существующую запись в публикациях, новое сообщение не публикуется в теме и, следовательно, ничего не потребляет.
Как я могу это исправить?
Кроме того, я хотел бы добавить еще одну таблицу 'comments' в свою базу данных. Какие изменения мне нужно внести в файл debezium-config.properties или где-либо еще, чтобы эти сообщения были опубликованы в отдельной теме?
Я вижу следующие журналы с консоли:
ПРЕДУПРЕЖДЕНИЕ: не найдено значений для таблицы 'public.publications' из сообщения об обновлении в 'source_info [server = dbserver1'db =' postgres ', .... schema = public, table = публикации]'; пропуск записи (io.debezium.connector.postgres.RecordsStreamProducer: 333)
Спасибо