[pulsar] branch master updated: Fix sink-record to get topic name (#2675)

[rd...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 1d7bb17  Fix sink-record to get topic name (#2675)
1d7bb17 is described below

commit 1d7bb1729ede3a2e4a6aaf5ff585f13b378239bf
Author: Rajan Dhabalia <rd...@apache.org>
AuthorDate: Sat Sep 29 00:28:36 2018 -0700

    Fix sink-record to get topic name (#2675)
---
 .../main/java/org/apache/pulsar/functions/instance/SinkRecord.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/SinkRecord.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/SinkRecord.java
index a818020..3e1d5c0 100644
--- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/SinkRecord.java
+++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/SinkRecord.java
@@ -38,6 +38,11 @@ public class SinkRecord<T> implements Record<T> {
     }
 
     @Override
+    public Optional<String> getTopicName() {
+        return sourceRecord.getTopicName();
+    }
+
+    @Override
     public Optional<String> getKey() {
         return sourceRecord.getKey();
     }