How to create kafka producer API

Question

Hi everyone,

Can somebody tell me how to create kafka producer API?

Thank You

Answer 1

Hi@akhtar,

To create kafka producer API, you can use the below code and change your key/value pair according to your need.

import java.util.*;
import org.apache.kafka.clients.producer.*;
public class ProducerAPI {
   public static void main(String[] args) throws Exception{   
      String topicName = "ProducerAPI";
  String key = "Key1";
  String value = "Value-1";
      Properties props = new Properties();
      props.put("bootstrap.servers", "localhost:9092,localhost:9093");
      props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");         
      props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");     
      Producer<String, String> producer = new KafkaProducer <>(props);
  ProducerRecord<String, String> record = new ProducerRecord<>(topicName,key,value);
  producer.send(record);        
      producer.close();
  System.out.println("ProducerAPI Completed.");
}
}

Thank You