сегменты перемещаются так быстро в нашем кластере Kafka, и это может быть связано с тем, что мы производим записи в кластере kafka с микросекундной меткой времени, а Kafka ожидает, что это будет в миллисекундах. Можно ли в коннекторе debezium postgres изменить его на миллисекунды? Какую конфигурацию я должен использовать, чтобы данные приходили за миллисекунды? Из-за этой проблемы наш кластер kafka работает нестабильно.
config
plugin.name: wal2json_streaming
max.queue.size: 65536
max.batch.size: 16384
slot.max.retries: 20
slot.name: {{ name }}
database.hostname: {{ hostname }}
database.port: 5432
database.user: {{ user }}
database.password: {{ password }}
database.dbname: {{ name }}
schema.whitelist: public
table.whitelist: public.outbox
database.server.name: {{ server.name }}
database.server.id: {{ server.id }}
database.history.kafka.bootstrap.servers: {{ bootstrapServers }}
