import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
+import java.util.HashMap;
+import java.util.Map;
+
@ConfigurationProperties("juplo.transfer")
@Getter
@Setter
public class TransferServiceProperties
{
- String bootstrapServers = "localhost:9092";
- String topic = "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;
+
+ public Map<String, String> getInstanceIdUriMapping()
+ {
+ return instanceIdUriMapping == null ? new HashMap<>() : instanceIdUriMapping;
+ }
}