Refaktorisierung für Tests - KafkaConsumer als eigenständige Bean
[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 import org.springframework.validation.annotation.Validated;
7
8 import javax.validation.constraints.NotEmpty;
9 import javax.validation.constraints.NotNull;
10
11
12 @ConfigurationProperties(prefix = "consumer")
13 @Validated
14 @Getter
15 @Setter
16 public class ApplicationProperties
17 {
18   @NotNull
19   @NotEmpty
20   private String bootstrapServer;
21   @NotNull
22   @NotEmpty
23   private String groupId;
24   @NotNull
25   @NotEmpty
26   private String clientId;
27   @NotNull
28   @NotEmpty
29   private String topic;
30   @NotNull
31   @NotEmpty
32   private String autoOffsetReset;
33 }