在我们的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 }}
1条答案
按热度按时间khbbv19g1#
这个问题在debezium1.1.0版本中已经修复