Как можно эффективно читать значения JSON из темах Kafka в Kstream в потоках Kafka? Несмотря на то, что я пробовал различные подходы, я не смог найти правильный метод для извлечения значений объектов JSON в топологию потока < /p>
Тема json {"id": 20001234, "Workbook": "CVF", "State": «Успех"} < /p>
Код: Выделить всё
KStream kStream = streamsBuilder.stream("TopicName",Consumed.with(Serdes.Long(), Serdes.String()));
Ошибка: переход состояния от pending_error к ошибке
-Spring Boot ---
Подробнее здесь:
https://stackoverflow.com/questions/785 ... fka-topics