- String bootstrapServers = "localhost:9092";
- String topic = "transfers";
- String groupId = "transfers";
+ private String bootstrapServers = "localhost:9092";
+ private String topic = "transfers";
+ private Integer numPartitions = 5;
+ private String groupId = "transfers";
+ private String groupInstanceId;
+ private Map<String, String> instanceIdUriMapping;
+ private String localStateStorePath;
+ private int stateStoreInterval = 60;
+
+ public Map<String, String> getInstanceIdUriMapping()
+ {
+ return instanceIdUriMapping == null ? new HashMap<>() : instanceIdUriMapping;
+ }