У меня есть сценарий использования, в котором мне нужно преобразовать SourceRecord в GenericRecord. Кто-нибудь может мне помочь, как это сделать?
По сути, я пишу собственный Kafka Producer и встраиваю его в код времени выполнения Connect. Когда вызывается producer.send(), SourceRecord преобразуется в тип ProducerRecord<byte[],byte[]>. Теперь, откуда я могу получить GenericRecord, чтобы я мог выполнять свои собственные задачи?