File tree Expand file tree Collapse file tree 4 files changed +7
-3
lines changed
function/src/test/scala/dev/profunktor/pulsar Expand file tree Collapse file tree 4 files changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ ThisBuild / developers := List(
2424
2525ThisBuild / scalafixDependencies += Libraries .organizeImports
2626
27- resolvers += Resolver .sonatypeRepo (" snapshots" )
27+ resolvers ++ = Resolver .sonatypeOssRepos (" snapshots" )
2828
2929Compile / run / fork := true
3030Global / semanticdbEnabled := true
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ version: '3'
33services :
44 pulsar :
55 restart : always
6- image : apachepulsar/pulsar:2.10.3
6+ image : apachepulsar/pulsar:2.11.0
77 ports :
88 - " 6650:6650"
99 - " 8080:8080"
Original file line number Diff line number Diff line change @@ -31,6 +31,7 @@ import org.apache.pulsar.functions.api.{
3131 StateStore ,
3232 WindowContext => JavaWindowContext
3333}
34+ import org .apache .pulsar .functions .api .utils .FunctionRecord
3435import org .slf4j .Logger
3536
3637object FunctionInput {
@@ -114,6 +115,9 @@ object FunctionInput {
114115 name : String
115116 ): S = ???
116117 override def getPulsarAdmin : PulsarAdmin = ???
118+ override def newOutputRecordBuilder [O ](
119+ schema : Schema [O ]
120+ ): FunctionRecord .FunctionRecordBuilder [O ] = ???
117121 }
118122
119123 def input [A ](seq : Seq [A ]): util.Collection [JavaRecord [A ]] = {
Original file line number Diff line number Diff line change @@ -9,7 +9,7 @@ object Dependencies {
99 val catsEffect = " 3.4.8"
1010 val circe = " 0.14.5"
1111 val fs2 = " 3.6.1"
12- val pulsar = " 2.10.3 "
12+ val pulsar = " 2.11.0 "
1313 val weaver = " 0.8.1"
1414
1515 val kindProjector = " 0.13.2"
You can’t perform that action at this time.
0 commit comments