Über

Why Bodybuilders Love Dianabol PPT Horm(props);

// Send a message to topic "test"
String topic = "test";
String key = "key1";
String value = "Hello, world!";
ProducerRecord record = new ProducerRecord(topic, key, value);
producer.send(record);

// Flush and close the producer
producer.flush();
producer.close();




This program will send a single message to the Kafka topic named "test". Make sure you have a running Kafka cluster with a broker listening (props))
for (int i = 0; i