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

Question

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

配置

   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 版本中修复

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

milliseconds timestamp in debezium postgres connector

postgresql

apache-kafka

apache-kafka-connect

debezium

strimzi