How to create Kafka consumer API

Question

Hi,

Can anyone tell me how to create kafka consumer API? How to write consumer API code?

Thank You

Answer 1

Hi@akhtar,

If you know the kafka producer API code than it is very simple to write kafka consumer API.

Please go through the below link for kafka producer API before kafka consumer API code.

$ https://www.edureka.co/community/63581/how-to-create-kafka-producer-api

 The kafka consumer API code is given below.

import java.util.*;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.ConsumerRecord;
public class SupplierConsumer{
        public static void main(String[] args) throws Exception{
                String topicName = "SupplierTopic";
                String groupName = "SupplierTopicGroup";
                Properties props = new Properties();
                props.put("bootstrap.servers", "localhost:9092,localhost:9093");
                props.put("group.id", groupName);
                props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
                props.put("value.deserializer", "SupplierDeserializer");
                KafkaConsumer<String, Supplier> consumer = new KafkaConsumer<>(props);
                consumer.subscribe(Arrays.asList(topicName));
                while (true){
                        ConsumerRecords<String, Supplier> records = consumer.poll(100);
                        for (ConsumerRecord<String, Supplier> record : records){
                                System.out.println("Supplier id= " + String.valueOf(record.value().getID()) + " Supplier  Name = " + record.value().getName() + " Supplier Start Date = " + record.value().getStartDate().toString());
                        }
                }
        }
}

Hope this will help you.

Thank You