Не удается обработать сообщение kafka json с помощью библиотеки Flink siddhi

#java #json #apache-kafka #apache-flink #siddhi Вопрос: Я пытаюсь создать простое приложение, в котором приложение будет потреблять сообщение Кафки, выполнять некоторые преобразования cql и публиковать в Кафке, и ниже приведен код:…