+ @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;