1 package de.juplo.kafka;
5 import org.springframework.boot.context.properties.ConfigurationProperties;
6 import org.springframework.validation.annotation.Validated;
8 import javax.validation.constraints.NotEmpty;
9 import javax.validation.constraints.NotNull;
10 import java.time.Duration;
13 @ConfigurationProperties(prefix = "sumup.requests")
17 public class ApplicationProperties
21 private String bootstrapServer;
24 private String groupId;
27 private String clientId;
30 private String topicIn;
33 private String autoOffsetReset;
35 private Duration commitInterval;
38 private String topicOut;
43 private Integer batchSize;
45 private Integer lingerMs;
48 private String compressionType;