Kafka Connect: как проанализировать SinkRecord, когда формат сообщения - JSON

Question

Вот метод переопределения для обработки записей:

@Override
public void put(Collection<SinkRecord> records) {
}

Сообщения, которые я отправил в тему Kafka, имеют формат JSON. Например:

{"key": "value"}

Итак, мой вопрос: как я могу проанализировать SinkRecord для объекта JSON.

Спасибо