{
private final String id;
private final String topic;
+ private final Integer partition;
private final KafkaProducer<String, Integer> producer;
private long produced = 0;
final ProducerRecord<String, Integer> record = new ProducerRecord<>(
topic, // Topic
+ partition, // Partition - Uses default-algorithm, if null
key, // Key
value // Value
);