Вам нужно будет найти или создать свой собственный Kafka Connect Converter, затем добавить этот пакет в путь к классам каждого работника Connect, а затем установить его в качестве параметра преобразователя ключа / значения, из которого существующий Mon go Sink Connector может десериализовать сообщения в формы Struct и Schema и обрабатывать их правильно.
JSON никогда не требовалось. Avro и Protobuf тоже должны работать