Как извлечь Json значений из KStream - PullRequest
0 голосов
/ 25 мая 2020

Я получаю сообщение Json от ввода topi c (employee_addition) topi c в виде пары значений ключа, ключ - это название отдела, а значение - информация о сотруднике в Json.

Я хочу извлечь только информацию о сотрудниках и сохранить их в классе данных о сотрудниках

Ключ: HR

Формат Json

{
"version": "v7",
"employee-data": {
"firstName": "John",
"middleName": ""
"LastName": "Michael",
"gender": "Male"
"Location": "Toronto"
"DateOfBirth": "02-Mar-1985",
"DateOfJoining": "02-May-2010",
"emailAddress": 'john.michael@ccc.com"
}

это класс

public class EmployeeHandler {
 private static String employeeinfo;

    public static void main(final String[] args) throws Exception {   
        StreamsBuilder builder = new StreamsBuilder();
        KStream<String, JsonObject> employeeStream = builder.stream("employee_addition"); 
            employeeStream.foreach((key,value) -> {
             employeeInfo = value;
             System.out.println( key + " --->" + value);
         }); 
    }

}

с помощью вышеуказанного метода он не попадает в сам foreach l oop. Как получить значение только из KStream?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...