kafka consumer and producer files

kafkaConsumer.java

import org.apache.kafka.clients.producer.*;

import java.util.Properties;

public class SimpleProducer {
  public static void main(String[] args) {
    Properties props = new Properties();
    props.put("bootstrap.servers", "localhost:9092");
    props.put("acks", "all");
    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);

    for (int i = 0; i < 100; i++) {
      producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), "message-" + i));
    }

    producer.close();
  }
}

kafkaProducer.java

import org.apache.kafka.clients.producer.*;

import java.util.Properties;

public class SimpleProducer {
  public static void main(String[] args) {
    Properties props = new Properties();
    props.put("bootstrap.servers", "localhost:9092");
    props.put("acks", "all");
    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);

    for (int i = 0; i < 100; i++) {
      producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), "message-" + i));
    }

    producer.close();
  }
}

pom.xml

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>your-kafka-version</version>
</dependency>