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