Искровой поток: cpp struct to kafka, kafka to spark streaming - PullRequest
0 голосов
/ 14 декабря 2018

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

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

...