пользовательский кодер для прямой потоковой передачи с пламенем json kafka source

Question

Я пытаюсь прочитать json данные из kafka topi c, используя подход DirectStream. Попытка сделать Dstream со строковым ключом и значением google json type.

JavaPairInputDStream<String, JsonObject> directKafkaStream = KafkaUtils.createDirectStream(ssc,
                    String.class, JsonObject.class, StringDecoder.class, JsonDecoder.class, kafkaParams, topics);

Как написать пользовательский класс кодировщика для Json типа данных.