#apache-kafka #apache-kafka-connect
#apache-kafka #apache-kafka-connect
Вопрос:
Я использую Kafka Connect для обработки сообщений из моей темы Kafka, и когда я получаю SinkRecord, содержащий сообщение Avro, получаемое значение имеет тип «Struct», который является специфичным для Kafka Connect «org.apache.kafka.connect.data.Struct» однако меня больше интересует получение конкретного объекта, который представляет эта структура (например, объект «Customer», у которого есть все геттеры / сеттеры, которые я хотел бы видеть)
Есть ли простой способ сопоставить объект «Struct» обратно с объектом «Customer» с помощью Kafka Connect?
Комментарии:
1. Используете ли вы реестр Schema? Если это так, вы бы хотели импортировать или просмотреть класс AvroData, используемый в AvroConverter Confluent
2. @Onecricket большое спасибо, что действительно сработало!
Ответ №1:
В классе Confluent AvroData есть fromConnectData, который делает именно это.