debezium postgres连接器中的毫秒时间戳

Question

片段在我们的Kafka集群中滚动得如此之快，这可能是因为我们在Kafka群集中生成具有微秒时间戳的记录，而Kafka预计这将以毫秒为单位。有可能在debezium postgres连接器中将其更改为毫秒吗？我应该使用哪个配置来使数据以毫秒为单位到来？由于这个问题，我们的卡夫卡集群不稳定。

配置

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 }}

Answer 1

此问题已在debezium 1.1.0版本中修复