Я ищу соединитель debezium mysql для потоковой передачи записей CDC на kafka с ключом в виде строка (не для ключа avro) и значением в качестве записи avro.По умолчанию он делает ключ как запись avro.Есть предложения?
вы можете попытаться установить key.converter на org.apache.kafka.connect.storage.StringConverter и value.converter оставить на Avro.
key.converter
org.apache.kafka.connect.storage.StringConverter
value.converter
Или вы можете использовать конвертер JSON, поскольку он также сериализуется в текст.
J.