The OEHCSProducer.java program is displayed with the following code. 
package oehcsproject;

import java.util.Properties;
import java.util.Scanner;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;

public class OEHCSProducer {
public static void main(String[] args) {
    String topicName = "bigdata001-topicdemo";
    String bootstrapServer = "198.168.1.10:6667";

    System.out.println("Starting producer for topic: " + topicName);
    Properties props = new Properties();
    props.put("bootstrap.servers", bootstrapServer);
    props.put("acks", "all");
    props.put("retries", 0);
    props.put("batch.size", 16384);
    props.put("linger.ms", 1);
    props.put("buffer.memory", 33554432);
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    Producer producer = new KafkaProducer(props);
    
    System.out.println("Input the contents and then press enter to send to the Topic. ");
    Scanner input = new Scanner(System.in);
    while (input.hasNext()) {
        producer.send(new ProducerRecord(topicName, input.nextLine().toString()));
    }

    input.close();
    producer.close();
}
}