How to create a Kafka Producer in Java

We want to create a simplest possible producer code that sends ten dummy string messages to a Kafka topic.
This example is an excerpt from the Book Kafka Streams – Real-time Stream Processing
For a detailed explanation of the example and much more, you can get access to the Book using below link.

Creating Simple Kafka Producer

Sending a message record to Kafka is a four-step process as shown in Code Listing.

public class HelloProducer { private static final Logger logger = LogManager.getLogger(HelloProducer.class); public static void main(String[] args) { logger.info("Creating Kafka Producer..."); Properties props = new Properties(); props.put(ProducerConfig.CLIENT_ID_CONFIG, AppConfigs.applicationID); props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, AppConfigs.bootstrapServers); props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, IntegerSerializer.class.getName()); props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName()); KafkaProducer<Integer, String> producer = new KafkaProducer<>(props); logger.info("Start sending messages..."); for (int i = 1; i <= AppConfigs.numEvents; i++) { producer.send(new ProducerRecord<>(AppConfigs.topicName, i, "Simple Message-" + i)); } logger.info("Finished - Closing Kafka Producer."); producer.close(); } }

You can access fully function project in our GitHub folder.

How to create a Kafka Producer in Java

Creating Simple Kafka Producer

Read More

Author : Prashant Pandey -

You will also like: