Я пытаюсь написать простой рабочий процесс, в котором я читаю CSV-файл, преобразую его в JSON и основываясь на существовании элемента в JSON, направляю этот конкретный объект JSON в тему Кафки. Например, у меня есть 2 записи JSON, в которых «env»: «prod» в одной и «env»: «dev» в другой. Исходя из env, я хочу, чтобы эта конкретная запись JSON переходила к определенной теме Kafka.
Я могу конвертировать CSV в JSON. Тем не менее, я не уверен, как прочитать определенный элемент из записи JSON, а затем направить. Любая помощь будет оценена. Пожалуйста, уточните кратко, если возможно.
Спасибо