Added ability for sources to publish messages on their own just like …

…their function counterparts (#6941) Co-authored-by: Sanjeev Kulkarni <sanjeevk@splunk.com>
apache · May 13, 2020 · 5d6ca6d · 5d6ca6d
1 parent 7a8b935
commit 5d6ca6d
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/pulsar-io/kafka/src/test/java/org/apache/pulsar/io/kafka/source/KafkaAbstractSourceTest.java b/pulsar-io/kafka/src/test/java/org/apache/pulsar/io/kafka/source/KafkaAbstractSourceTest.java
@@ -22,6 +22,9 @@
 
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.pulsar.client.api.PulsarClientException;
+import org.apache.pulsar.client.api.Schema;
+import org.apache.pulsar.client.api.TypedMessageBuilder;
 import org.apache.pulsar.io.core.SourceContext;
 import org.apache.pulsar.io.kafka.KafkaAbstractSource;
 import org.apache.pulsar.io.kafka.KafkaSourceConfig;
@@ -158,6 +161,11 @@ public ByteBuffer getState(String key) {
             public CompletableFuture<ByteBuffer> getStateAsync(String key) {
                 return null;
             }
+
+            @Override
+            public <O> TypedMessageBuilder<O> newOutputMessage(String topicName, Schema<O> schema) throws PulsarClientException {
+                return null;
+            }
         };
         Map<String, Object> config = new HashMap<>();
         ThrowingRunnable openAndClose = ()->{