@Setter
public static class KafkaServicesProperties
{
- private String topic = "test";
+ private String clientIdPrefix;
+ private String bootstrapServers = ":9092";
+ private String chatroomChannelTopic = "chatroom_channel";
+ private String messageChannelTopic = "message_channel";
private int numPartitions = 2;
}
- public enum ServiceType { inmemory }
+ public enum ServiceType { inmemory, kafka }
public enum StorageStrategyType { files, mongodb }
public enum ShardingStrategyType { none, kafkalike }
}