}
@Bean
- ChatHomeService kafkaChatHome(
+ KafkaChatHomeService kafkaChatHome(
ChatBackendProperties properties,
InfoChannel infoChannel,
DataChannel dataChannel)
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,