How to push (produce ) messages into the Kafka broker using java?

                                   How to push (produce ) messages into the Kafka broker using java

• First, create the properties class object for loading the Kafka producer properties.
• After Connection creation of Kafka producer use the send method to push the message into the broker.
• Finally, Close the Kafka producer connection.

import java.util.Properties; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerRecord; /** * * @author:Janardhan Randhi * @Date:Oct 23, 2018 * @Class: This class push the messages into kafka broker. */ public class Producer { public static void main(String[] args) { Properties properties = new Properties(); properties.put("bootstrap.servers", "localhost:9092"); properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); KafkaProducer kafkaProducer = new KafkaProducer(properties); try { for (int i = 0; i < 100; i++) { System.out.println(i); kafkaProducer.send(new ProducerRecord("janardhan", Integer.toString(i), "test message - " + i)); } } catch (Exception e) { e.printStackTrace(); } finally { kafkaProducer.close(); } } }

Share on FacebookPlus on Google+ Share on whatsapp

SUBSCRIBE TO OUR NEWSLETTER