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;
import java.util.Properties;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Future;
@Slf4j
{
private final String id;
private final String topic;
- private final KafkaProducer<String, String> producer;
+ private final Producer<String, String> producer;
private long produced = 0;
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", StringSerializer.class.getName());
- KafkaProducer<String, String> producer = new KafkaProducer<>(props);
+ Producer<String, String> producer = new KafkaProducer<>(props);
// end::create[]
this.id = clientId;
final long time = System.currentTimeMillis();
final ProducerRecord<String, String> record = new ProducerRecord<>(
- "test", // Topic
+ topic, // Topic
key, // Key
value // Value
);