package de.juplo.kafka;
import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;
{
private final String id;
private final String topic;
- private final KafkaProducer<String, String> producer;
+ private final Producer<String, String> producer;
private long produced = 0;
private volatile boolean running = true;
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", StringSerializer.class.getName());
- producer = new KafkaProducer<>(props);
-
- this.topic = topic;
this.id = clientId;
+ this.topic = topic;
+ producer = new KafkaProducer<>(props);
}
public void run()