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

pw9qyyiw  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(666)

在我们的kafka集群中,这些片段滚动得如此之快,这可能是因为我们正在向kafka集群中生成具有微秒时间戳的记录,而kafka期望它以毫秒为单位。是否可以在debezium postgres连接器中将其更改为毫秒?我应该使用哪个配置使数据以毫秒为单位传入?我们的Kafka星团正因为这个问题而变得不稳定。
配置

  1. plugin.name: wal2json_streaming
  2. max.queue.size: 65536
  3. max.batch.size: 16384
  4. slot.max.retries: 20
  5. slot.name: {{ name }}
  6. database.hostname: {{ hostname }}
  7. database.port: 5432
  8. database.user: {{ user }}
  9. database.password: {{ password }}
  10. database.dbname: {{ name }}
  11. schema.whitelist: public
  12. table.whitelist: public.outbox
  13. database.server.name: {{ server.name }}
  14. database.server.id: {{ server.id }}
  15. database.history.kafka.bootstrap.servers: {{ bootstrapServers }}
khbbv19g

khbbv19g1#

这个问题在debezium1.1.0版本中已经修复

相关问题