import java.time.Duration;
-@ConfigurationProperties(prefix = "consumer")
+@ConfigurationProperties(prefix = "sumup.requests")
@Validated
@Getter
@Setter
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;
}