Clock clock)
{
return new ChatRoomChannel(
- properties.getKafka().getTopic(),
+ properties.getKafka().getChatroomChannelTopic(),
chatRoomChannelProducer,
chatRoomChannelConsumer,
shardingStrategy,
defaultConsumerProperties.forEach((key, value) -> properties.put(key.toString(), value));
properties.put(
ConsumerConfig.CLIENT_ID_CONFIG,
- chatBackendProperties.getKafka().getClientIdPrefix() + "_MESSAGE_CHANNEL_CONSUMER");
+ chatBackendProperties.getKafka().getClientIdPrefix() + "_CHATROOM_CHANNEL_CONSUMER");
properties.put(
ConsumerConfig.GROUP_ID_CONFIG,
"chat_room_channel");
ZoneId zoneId)
{
return new ChatMessageChannel(
- properties.getKafka().getTopic(),
+ properties.getKafka().getMessageChannelTopic(),
chatMessageChannelProducer,
chatMessageChannelConsumer,
zoneId,
properties.setProperty(
ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,
chatBackendProperties.getKafka().getBootstrapServers());
- properties.setProperty(
- ConsumerConfig.CLIENT_ID_CONFIG,
- chatBackendProperties.getKafka().getClientIdPrefix());
properties.setProperty(
ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG,
"false");