postgresql - Postgres sink 连接器在 DLQ 中放置消息

Question

我正在尝试探索 kafka 上的 postgres 源和接收器连接器。在 Postgres 中创建了 2 个具有相同字段（名称 varchar、created_at 时间戳）的表。

当 table1 上发生插入事件时，源连接器会生成有关该主题的消息。接收器连接器配置为使用来自主题的数据并将记录创建到 table2 中。

接收器连接器上没有发生事件消耗，并且消息将进入 DLQ 队列。

Connector Class: PostgresSink 
Topics: development-source_test 
Max Tasks: 1 

input.data.format: JSON_SR 
connection.host: ****.ap-south-1.rds.amazonaws.com 
connection.port: 5432 
connection.user: devteam 
db.name: dev-db 
ssl.mode: prefer 
insert.mode: INSERT 
table.name.format: sink_test 
db.timezone: UTC 
auto.create: false 
auto.evolve: false 
tasks.max: 1

标签： postgresqlapache-kafkaapache-kafka-connect