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 <[email protected]>
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
[email protected].
