diff options
| author |   Ram Koya <rk541m@att.com> | 2018-08-24 15:08:23 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-08-24 15:08:23 +0000 |
| commit | 4ef34e65089fa86822f9e4c0efacd1c4da98673f (patch) | |
| tree | 3f65399d6d50b1362810cbd405e7b647dcade1cb /src/main/java/com/att/dmf/mr/backends | |
| parent | a8a0b8683c5bb018ae3aef681817f3e5656749a1 (diff) | |
| parent | 751f275e6eb2796c8fe22519dd8935443cc16e6f (diff) | |
Merge changes I6bae63d6,I5bed2ad4,I39e24692
* changes:
Sonar major issues
Sonar major issues
Sonar Major issues
Diffstat (limited to 'src/main/java/com/att/dmf/mr/backends')
| -rw-r--r-- | src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java b/src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java index dc4bcd5..9543828 100644 --- a/src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java +++ b/src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java @@ -178,10 +178,10 @@ public class KafkaPublisher implements Publisher { throws IOException { log.info("sending " + msgs.size() + " events to [" + topic + "]"); try{ - final List<ProducerRecord<String, String>> kms = new ArrayList<ProducerRecord<String, String>>(msgs.size()); + final List<ProducerRecord<String, String>> kms = new ArrayList<>(msgs.size()); for (message o : msgs) { - final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, o.getKey(), o.toString()); + final ProducerRecord<String, String> data = new ProducerRecord<>(topic, o.getKey(), o.toString()); try { |