Update Pulsar-client to 2.7.0 (#170)

cr-org · Mar 5, 2021 · b0a72fd · b0a72fd
1 parent 945a7ed
commit b0a72fd
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/function/src/test/scala/cr/pulsar/FunctionInput.scala b/function/src/test/scala/cr/pulsar/FunctionInput.scala
@@ -20,9 +20,9 @@ import java.nio.ByteBuffer
 import java.{ lang, util }
 import java.util.Optional
 import java.util.concurrent.CompletableFuture
-
 import org.apache.pulsar.client.api.{ ConsumerBuilder, Schema, TypedMessageBuilder }
 import org.apache.pulsar.functions.api.{
+  StateStore,
   Context => JavaContext,
   Record => JavaRecord,
   WindowContext => JavaWindowContext
@@ -104,6 +104,17 @@ object FunctionInput {
         schema: Schema[O]
     ): TypedMessageBuilder[O]                                                 = ???
     override def newConsumerBuilder[O](schema: Schema[O]): ConsumerBuilder[O] = ???
+    override def getStateStore[S <: StateStore](name: String): S              = ???
+    override def getStateStore[S <: StateStore](
+        tenant: String,
+        ns: String,
+        name: String
+    ): S = ???
+    override def newOutputMessage[O](
+        clusterName: String,
+        topicName: String,
+        schema: Schema[O]
+    ): TypedMessageBuilder[O] = ???
   }
 
   def input[A](seq: Seq[A]): util.Collection[JavaRecord[A]] = {

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -11,7 +11,7 @@ object Dependencies {
     val fs2        = "2.5.3"
     val munit      = "0.7.22"
     val newtype    = "0.4.4"
-    val pulsar     = "2.6.2"
+    val pulsar     = "2.7.0"
 
     val betterMonadicFor = "0.3.1"
     val contextApplied   = "0.1.4"