Update StandaloneSender.java

Author: MohamedEL59

example-java/src/main/java/com/softwaremill/kmq/example/standalone/StandaloneSender.java

@@ -3,12 +3,16 @@
 import com.softwaremill.kmq.example.UncaughtExceptionHandling;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.kafka.clients.CommonClientConfigs;
 import org.apache.kafka.common.serialization.ByteBufferSerializer;
+import org.apache.kafka.common.config.SslConfigs;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
+import java.util.HashMap;
+import java.util.Map;
 
 import static com.softwaremill.kmq.example.standalone.StandaloneConfig.KAFKA_CLIENTS;
 import static com.softwaremill.kmq.example.standalone.StandaloneConfig.KMQ_CONFIG;
@@ -20,6 +24,22 @@ class StandaloneSender {
 
     public static void main(String[] args) throws InterruptedException, IOException {
         UncaughtExceptionHandling.setup();
+        
+        /* EXAMPLE with extraConfig : SSL Encryption & SSL Authentication
+        Map extraConfig = new HashMap();
+        //configure the following three settings for SSL Encryption
+        extraConfig.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL");
+        extraConfig.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, "/directory/kafka.client.truststore.jks");
+        extraConfig.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG,  "test1234");
+
+        // configure the following three settings for SSL Authentication
+        extraConfig.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "/directory/kafka.client.keystore.jks");
+        extraConfig.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, "test1234");
+        extraConfig.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG, "test1234");
+        
+        KafkaProducer<ByteBuffer, ByteBuffer> msgProducer = KAFKA_CLIENTS
+                .createProducer(ByteBufferSerializer.class, ByteBufferSerializer.class, extraConfig);
+        */
 
         KafkaProducer<ByteBuffer, ByteBuffer> msgProducer = KAFKA_CLIENTS
                 .createProducer(ByteBufferSerializer.class, ByteBufferSerializer.class);