import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
+
@ConfigurationProperties(prefix = "producer")
@Getter
@Setter
private String bootstrapServer;
private String clientId;
private String topic;
+ private Integer partition;
private String acks;
- private int throttleMs;
+ private Integer batchSize;
+ private Integer lingerMs;
+ private String compressionType;
}