Я работаю с 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 на консоли, тогда они не в удобочитаемом формате.хочу привести данные.Любая помощь будет оценена.