Шаги следуют
Установленный / извлеченный слив 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, реестр схем и kafka connect jdbc, а также консольный потребитель avro с помощью команды ниже. Таблица ссылается: Клиент
sh kafka-avro-console-consumer --bootstrap-server ip:9092 --topic sqlite-jdbc-customer --from-beginning
я не вижу сообщений в консоли пользователя avro