Kafka-connect接收器连接器不适用于多个主题以及具有主题和db相同键的多个表

问题描述

任何人都可以帮助我。

当我从1个主题消费并插入到1个表名时，以下属性工作正常，但是当我添加2个主题从消费和2个表名中插入数据时。它不起作用，出现了我在属性后面提到的错误。

两个主题，数据库都有相同的密钥。

这些是我正在使用的属性：

name=CONNECT4
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=TOPIC1,TOPIC2
connection.url=jdbc:postgresql://127.0.0.1:5432/db?user=db&password=db&ssl=false
dialect.name=PostgresqlDatabaseDialect
insert.mode=upsert
batch.size=100
table.name.format=Table1,table2
auto.create=true
key.converter=org.apache.kafka.connect.storage.StringConverter
key.converter.schema.registry.url=http://127.0.0.1:8081
key.converter.schemas.enable=false
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://127.0.0.1:8081
value.converter.schemas.enable=true
value.subject.name.strategy=io.confluent.kafka.serializers.subject.RecordNameStrategy
pk.mode=record_value
pk.fields=Id

表和主题都具有相同的键-ID，但我仍然得到此原因：java.sql.sqlException：org.postgresql.util.PsqlException：错误：未实现跨数据库引用： / strong>如果有人可以帮助我，那太好了。

谢谢

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafka-connect postgresql-12