How to consume messages from the kafka broker using java?

                                   How to consume messages from the Kafka broker using java

• First, create the properties class object for loading the Kafka properties.
• After Connection creation of Kafka Consumer use the add and subscribe methods get the messages from the mediator.
• Finally, Close the Kafka consumer connection.

import java.util.ArrayList; import java.util.List; import java.util.Properties; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.consumer.KafkaConsumer; /** * * @author:Janardhan Randhi * @Date Oct 27, 2018 * Class:This class Receives(consume)the messages from the kafka broker. */ public class SimpleHLConsumer { public static void main(String[] args) { Properties properties = new Properties(); properties.put("bootstrap.servers", "localhost:9092"); properties.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); properties.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); properties.put("group.id", "test-group"); KafkaConsumer kafkaConsumer = new KafkaConsumer(properties); List topics = new ArrayList(); topics.add("janardhan"); kafkaConsumer.subscribe(topics); try{ while (true){ ConsumerRecords records = kafkaConsumer.poll(10); for (Object record: records){ System.out.println(record); } } }catch (Exception e){ System.out.println(e.getMessage()); }finally { kafkaConsumer.close(); } } }

Share on FacebookPlus on Google+ Share on whatsapp

SUBSCRIBE TO OUR NEWSLETTER