[incubator-pulsar] branch master updated: Check if producer is not null before closing (#1839)

[hr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hrsakai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c4d1ed9  Check if producer is not null before closing (#1839)
c4d1ed9 is described below

commit c4d1ed936b41a58b42d23cbedd87049dd9749976
Author: Sanjeev Kulkarni <sa...@gmail.com>
AuthorDate: Wed May 23 18:46:55 2018 -0700

    Check if producer is not null before closing (#1839)
---
 .../kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java
index 5aa9894..5081d54 100644
--- a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java
+++ b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java
@@ -65,8 +65,10 @@ public abstract class KafkaSink<K, V> extends SimpleSink<byte[]> {
 
     @Override
     public void close() throws IOException {
-        producer.close();
-        LOG.info("Kafka sink stopped.");
+        if (producer != null) {
+            producer.close();
+            LOG.info("Kafka sink stopped.");
+        }
     }
 
     @Override

-- 
To stop receiving notification emails like this one, please contact
hrsakai@apache.org.