我可以使用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
暂无答案!
目前还没有任何答案,快来回答吧!