1 package de.juplo.kafka.payment.transfer;
6 import org.springframework.boot.context.properties.ConfigurationProperties;
8 import java.util.HashMap;
12 @ConfigurationProperties("juplo.transfer")
15 public class TransferServiceProperties
17 private String bootstrapServers = "localhost:9092";
18 private String topic = "transfers";
19 private Integer numPartitions = 5;
20 private String groupId = "transfers";
21 private String groupInstanceId;
22 private Map<String, String> instanceIdUriMapping;
23 private String localStateStorePath;
24 private int stateStoreInterval = 60;
26 public Map<String, String> getInstanceIdUriMapping()
28 return instanceIdUriMapping == null ? new HashMap<>() : instanceIdUriMapping;