| commit | e53b12a952586fedd7b1301d3cc90c535b95557b | [log] [tgz] |
|---|---|---|
| author | Matteo Scandolo <teo@opennetworking.org> | Thu Sep 13 10:06:58 2018 -0700 |
| committer | Matteo Scandolo <teo@opennetworking.org> | Thu Sep 13 10:06:58 2018 -0700 |
| tree | db88d90fb6ad9a14ffa9db750424011ec2cc1e62 | |
| parent | 2aad779645683f97a9c099923f0918fa9d9c09cd [diff] |
Adding log in case the kafkaProducer is not defined and an event is received Change-Id: Ic424f0b763eb8eb25d6f5781a67179ceebbe093a
diff --git a/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java b/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java index d6e3392..bfc5ec9 100644 --- a/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java +++ b/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java
@@ -186,6 +186,7 @@ @Override public void send(String topic, JsonNode data) { if (kafkaProducer == null) { + log.warn("Not sending event as kafkaProducer is not defined: {}", data.toString()); return; }