Clock clock)
{
return new ChatRoomChannel(
- properties.getKafka().getTopic(),
+ properties.getKafka().getChatroomChannelTopic(),
chatRoomChannelProducer,
chatRoomChannelConsumer,
shardingStrategy,
ZoneId zoneId)
{
return new ChatMessageChannel(
- properties.getKafka().getTopic(),
+ properties.getKafka().getMessageChannelTopic(),
chatMessageChannelProducer,
chatMessageChannelConsumer,
zoneId,