X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationProperties.java;h=ccddc8191b007054d3cf6bf6f514ca787b1470fa;hb=a53845885ccfa90fb94dd7696762647a450c4394;hp=fa731c537595ad81c2b847d53c307e68eac9a0f8;hpb=dd41cf0d4a8b1cf00158dd5ce902bba1ab67389b;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/ApplicationProperties.java b/src/main/java/de/juplo/kafka/ApplicationProperties.java index fa731c5..ccddc81 100644 --- a/src/main/java/de/juplo/kafka/ApplicationProperties.java +++ b/src/main/java/de/juplo/kafka/ApplicationProperties.java @@ -7,9 +7,10 @@ import org.springframework.validation.annotation.Validated; import javax.validation.constraints.NotEmpty; import javax.validation.constraints.NotNull; +import java.time.Duration; -@ConfigurationProperties(prefix = "consumer") +@ConfigurationProperties(prefix = "sumup.requests") @Validated @Getter @Setter @@ -26,8 +27,23 @@ public class ApplicationProperties private String clientId; @NotNull @NotEmpty - private String topic; + private String topicIn; @NotNull @NotEmpty private String autoOffsetReset; + @NotNull + private Duration commitInterval; + @NotNull + @NotEmpty + private String topicOut; + @NotNull + @NotEmpty + private String acks; + @NotNull + private Integer batchSize; + @NotNull + private Integer lingerMs; + @NotNull + @NotEmpty + private String compressionType; }