Я работаю с Apache Spark 2.3 и читаю данные с порта UDP в формате lz0, распаковываю эти данные в структуру cpp с помощью кода c ++ и отправляю данные этого формата структуры в тему Kafka. после этого я хочу выполнить потоковую передачу с использованием Kafka (в формате cpp struct) и сохранить данные в другой теме Kafka. Но я не могу этого сделать или не могу найти API.
CPP struct:
typedef struct message{
int id;
char name[MAX_BUF];
float facevalue;
}BCASTMSG;
Когда вы печатаете данные темы Кафки на консоли, они не отображаются в читаемом формате.
хочу привести данные.
Любая помощь будет оценена.
Задача ещё не решена.
Других решений пока нет …