Как получить конкретное поле из jsonobject (массива) с помощью потоковой передачи kafka java8

Question

Не могли бы вы разрешить мои сомнения.Я смог получить поле из jsonObject (a-->{"host":"mou","type":"kat"}) в моей теме Kafka, используя потоки Kafka, с кодом ниже в Java8.

KStream<String, String> sources = builder
    .stream(Serdes.String(), jsonSerde, "example")
    .map((k,v) -> new KeyValue<>(k, (String) v.path("a").toString()));

sources.foreach((w, c) -> System.out.println("word: ->"  + c));

sources.print("FETCHING FIELD VALUE");

Но если мой ввод {"type":"abc","name":"abc","a"[{"host":"mouni"}]}, яполучаю ошибку сериализации.(Пожалуйста, отправьте POC по моей проблеме.)

Answer 1

с приведенными ниже строками кода.

 KStream<String, String> sources = builder.stream(Serdes.String(), jsonSerde, "example")

               .map((k,v) -> new KeyValue<>(k,  v.path("l").path(0).path("a").toString()));