无法将来自kafka使用者的消息接收到postgres

ecbunoof  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(219)

我可以使用Kafka控制台阅读Kafka主题中的消息

/bin/kafka-console-consumer --topic Test --consumer.config 
/etc/kafka/consumer.properties --from-beginning --bootstrap-server 
ip1:9095,ip2:9095,ip3:9095

但无法使用jdbc接收器连接器将这些消息接收器到postgres中的表

/bin/connect-standalone /etc/schema-registry/connect-avro- 
standalone.properties /etc/kafka-connect-jdbc/psql.properties

通过此命令加载的使用者配置没有选择我正在使用的正确group.id和sasl验证。有没有一种方法可以在这段代码中传递相同的使用者配置值?
连接器属性

name=postgres-sink
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=3
connection.url=jdbc:postgresql://IP:5432/db? 
user=postgres&password=postgres
insert.mode=upsert
pk.mode=record_value
table.name.format=kafka_users
auto.create=true
auto.evolve=true
topics=Test

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题