properties.getKafka().getInfoChannelTopic(),
producer,
infoChannelConsumer,
+ properties.getKafka().getPollingInterval(),
+ properties.getKafka().getNumPartitions(),
properties.getKafka().getInstanceUri());
}
dataChannelConsumer,
zoneId,
properties.getKafka().getNumPartitions(),
+ properties.getKafka().getPollingInterval(),
properties.getChatroomBufferSize(),
clock,
infoChannel,