Искровой поток: cpp struct to kafka, kafka to spark streaming

Я работаю с 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;

Когда вы печатаете данные темы Кафки на консоли, они не отображаются в читаемом формате.
хочу привести данные.
Любая помощь будет оценена.

0

Решение

Задача ещё не решена.

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]