Преобразование потребляемого Кафкой сообщения в Java POJO

Question

У меня есть Кафка, которая производит сообщение в формате protobuf. Я должен использовать этот ввод (можно преобразовать его в JSON) и преобразовать его в Java Pojo объект. Для этого я думаю использовать Apache Camel? Я не получаю ли его правильный выбор? Помогите мне, пожалуйста.