X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FChatBackendProperties.java;h=73fa719e252a367e8977496c50d1cf68162c0d53;hb=c38bc4da9875d78aea1418e70c08652357eeac88;hp=4724f6b54d7f21d14dafcc6115c4823a8beaec23;hpb=915ed8f85459da3c95f86b6351a3d7129668bc8e;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java index 4724f6b5..73fa719e 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java +++ b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java @@ -34,11 +34,13 @@ public class ChatBackendProperties @Setter public static class KafkaServicesProperties { + private String clientId; + 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 } }