{
private String clientIdPrefix;
private String bootstrapServers = ":9092";
- private String topic = "test";
+ private String chatroomChannelTopic = "chatroom_channel";
+ private String messageChannelTopic = "message_channel";
private int numPartitions = 2;
}