properties.getKafka().getInfoChannelTopic(),
producer,
infoChannelConsumer,
properties.getKafka().getPollingInterval(),
properties.getKafka().getNumPartitions(),
properties.getKafka().getInstanceUri());
properties.getKafka().getInfoChannelTopic(),
producer,
infoChannelConsumer,
properties.getKafka().getPollingInterval(),
properties.getKafka().getNumPartitions(),
properties.getKafka().getInstanceUri());