1 package de.juplo.kafka;
5 import org.springframework.boot.context.properties.ConfigurationProperties;
7 import javax.validation.constraints.NotEmpty;
8 import javax.validation.constraints.NotNull;
11 @ConfigurationProperties(prefix = "producer")
14 public class ApplicationProperties
18 private String bootstrapServer;
21 private String clientId;
25 private Integer partition;
30 private Integer batchSize;
32 private Integer lingerMs;
35 private String compressionType;