0

这些段在我们的 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 }}
4

1 回答 1

0

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

于 2020-08-20T04:08:38.100 回答