SampleProducer.java

public class SampleProducer {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "kafka-a.company.com:9092,kafka-b.company.com:9092,kafka-c.company.com:9092");
        props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
        props.put("sasl.mechanism", "PLAIN");
        //Few more props. Refer https://gist.github.com/pradp/a18312ab72e50117075131efc1a87629
        Producer<String, String> producer = new KafkaProducer<String, String>(props);
        Random rand = new Random();
        for (int i = 0; i < 100; i++)
            producer.send(new ProducerRecord<String, String>("sample-topic", Integer.toString(i), Integer
                    .toString(rand.nextInt())));
        producer.close();
    }
}