EndlessProducer in RestProducer umgearbeitet
[demos/kafka/training] / src / main / java / de / juplo / kafka / ApplicationProperties.java
1 package de.juplo.kafka;
2
3 import lombok.Getter;
4 import lombok.Setter;
5 import org.springframework.boot.context.properties.ConfigurationProperties;
6
7 @ConfigurationProperties(prefix = "producer")
8 @Getter
9 @Setter
10 public class ApplicationProperties
11 {
12   private String bootstrapServer;
13   private String clientId;
14   private String topic;
15   private String acks;
16   private Integer batchSize;
17   private Integer lingerMs;
18   private String compressionType;
19 }