@Setter
public static class KafkaServicesProperties
{
- private String clientId;
+ 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;
}