kafka avro控制台使用者未显示来自kafka connect的任何消息

v1uwarro  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(213)

接下来的步骤
安装/提取汇流5.0.0.-2.11
修改kafka connect jdbc/source-quickstart.properties以指向我的本地数据库

name=test-source-sqlite-jdbc-autoincrement
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:mysql://127.0.0.1:3306/test?user=root&password=root
mode=incrementing
incrementing.column.name=id 
topic.prefix=sqlite-jdbc
query=select * from customer
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter=org.apache.kafka.connect.json.JsonConverter
poll.interval.ms=5000
table.poll.interval.ms=120000
mode=bulk

在connect-avro-standalone.properties plugin.path=汇合的提取文件夹中修改了以下属性

bootstrap.servers=domain:9092
key.converter=io.confluent.connect.avro.AvroConverter
key.converter.schemas.enable=true
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schemas.enable=true
internal.key.converter=org.apache.kafka.connect.json.JsonConverter
internal.value.converter=org.apache.kafka.connect.json.JsonConverter
internal.key.converter.schemas.enable=false
internal.value.converter.schemas.enable=false 
plugin.path=/home/confluent-5.0.0/

在修改了上述属性之后,我用下面的命令启动了zookeeper、kafka、schema registry和kafka connect jdbc以及avro控制台console consumer。参考表:客户

sh kafka-avro-console-consumer --bootstrap-server ip:9092 --topic sqlite-jdbc-customer --from-beginning

我在avro控制台中没有看到任何消息

暂无答案!

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

相关问题