Update pulsar-client to 2.11.2 (#409)

* Update pulsar-client to 2.11.2 * Add new function mock
cr-org · Nov 10, 2023 · c0b19d6 · c0b19d6
1 parent eb84cdc
commit c0b19d6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/function/src/test/scala/cr/pulsar/FunctionInput.scala b/function/src/test/scala/cr/pulsar/FunctionInput.scala
@@ -27,6 +27,7 @@ import org.apache.pulsar.functions.api.{
   Record => JavaRecord,
   WindowContext => JavaWindowContext
 }
+import org.apache.pulsar.functions.api.utils.FunctionRecord.FunctionRecordBuilder
 import org.slf4j.Logger
 import cr.pulsar.JavaConversions._
 import org.apache.pulsar.client.admin.PulsarAdmin
@@ -110,8 +111,9 @@ object FunctionInput {
         tenant: String,
         ns: String,
         name: String
-    ): S                                     = ???
-    override def getPulsarAdmin: PulsarAdmin = ???
+    ): S                                                                                = ???
+    override def getPulsarAdmin: PulsarAdmin                                            = ???
+    override def newOutputRecordBuilder[O](schema: Schema[O]): FunctionRecordBuilder[O] = ???
   }
 
   def input[A](seq: Seq[A]): util.Collection[JavaRecord[A]] = {

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -12,7 +12,7 @@ object Dependencies {
     val circe      = "0.14.3"
     val fs2        = "3.6.1"
     val newtype    = "0.4.4"
-    val pulsar     = "2.10.5"
+    val pulsar     = "2.11.2"
     val weaver     = "0.8.3"
 
     val betterMonadicFor = "0.3.1"