Sonar major issues 45/63045/1
authorSumapriya Sarvepalli <ss00493505@techmahindra.com>
Mon, 27 Aug 2018 11:13:02 +0000 (16:43 +0530)
committerSumapriya Sarvepalli <ss00493505@techmahindra.com>
Mon, 27 Aug 2018 11:13:02 +0000 (16:43 +0530)
 Replace with the diamond operator
Sonar Link:
https://sonar.onap.org/project/issues?assignees=sumapriya&id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr&open=AWVrvBaZxOv3LmQdCiha&resolved=false&severities=MAJOR
Location:
 src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java
Line No:L45 L80 L96

Change-Id: I1ffa790aa3c088d25fe83669b0380dedc33ae234
Issue-ID: DMAAP-655
Signed-off-by: Sumapriya Sarvepalli <ss00493505@techmahindra.com>
src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java

index 9543828..735e372 100644 (file)
@@ -42,10 +42,6 @@ import com.att.eelf.configuration.EELFManager;
 import com.att.nsa.drumlin.till.nv.rrNvReadable;
 
 
-//import kafka.javaapi.producer.Producer;
-//import kafka.producer.KeyedMessage;
-//import kafka.producer.ProducerConfig;
-//import kafka.producer.KeyedMessage;
 
 /**
  * Sends raw JSON objects into Kafka.
@@ -77,8 +73,7 @@ public class KafkaPublisher implements Publisher {
                        kafkaConnUrl="localhost:9092";
                }
                
-        //     props.put("bootstrap.servers", bootSever);
-       //System.setProperty("java.security.auth.login.config",jaaspath);
+       
        
                
                transferSetting( props, "bootstrap.servers",kafkaConnUrl);
@@ -93,7 +88,7 @@ public class KafkaPublisher implements Publisher {
                 props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
 
                
-               //fProducer = new Producer<String, String>(fConfig);
+               
                fProducer = new KafkaProducer<>(props);
        }