void initConsumer(const char *broker_host, const char *topic);
void startConsumer();
enum RecordTypes { EAi, EBi, EString, EWaveform };