#ifndef __NxCoreKafkaConsumer_h_
#define __NxCoreKafkaConsumer_h_

#include "misc_framework/DataNodes.h"

void initKafkaConsumer(DataNodeManager *manager);

#endif