Sonar Fixes

[policy/apex-pdp.git] / plugins / plugins-event / plugins-event-carrier / plugins-event-carrier-kafka / src / main / java / org / onap / policy / apex / plugins / event / carrier / kafka / ApexKafkaProducer.java

diff --git a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducer.java b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducer.java
index b570c40..f7ff147 100644 (file)
--- a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducer.java
+++ b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaProducer.java
@@ -80,7 +80,7 @@ public class ApexKafkaProducer extends ApexPluginsEventProducer {
             }
         }
 
-        kafkaProducer.send(new ProducerRecord<String, Object>(kafkaProducerProperties.getProducerTopic(), name, event));
+        kafkaProducer.send(new ProducerRecord<>(kafkaProducerProperties.getProducerTopic(), name, event));
         if (LOGGER.isTraceEnabled()) {
             LOGGER.trace("event sent from engine using {} to topic {} : {} ", this.name,
                     kafkaProducerProperties.getProducerTopic(), event);