Kafka Connect отправляет объект структуры вместо JSON - PullRequest
2 голосов
/ 13 мая 2019

Я использую соединитель приемника Kafka для десериализации данных Avro, отправляемых потоковым приложением kafka.Я использую Avconconverter конфлуента в рабочей конфигурации, но я получаю объект struct в качестве вывода из приложения подключения вместо объекта JSON.Как я могу получить объект JSON?Ниже приведена конфигурация, которую я использую в файле connect-avro-standalone.properties,

key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://localhost:8081
key.converter.schemas.enable=false
...