Empty commit to trigger build (#449)

* Empty commit to trigger build

* Empty commit to trigger build

core/src/main/scala/cr/pulsar/Consumer.scala

@@ -242,5 +242,4 @@ object Consumer {
       deadLetterPolicy = None
     )
   }
-
 }

function/src/test/scala/cr/pulsar/FunctionInput.scala

@@ -115,6 +115,7 @@ object FunctionInput {
     ): S                                                                                = ???
     override def getPulsarAdmin: PulsarAdmin                                            = ???
     override def newOutputRecordBuilder[O](schema: Schema[O]): FunctionRecordBuilder[O] = ???
+    override def fatal(t: Throwable): Unit                                              = ???
   }
 
   def input[A](seq: Seq[A]): util.Collection[JavaRecord[A]] = {

function/src/test/scala/cr/pulsar/WindowContextSuite.scala

@@ -177,7 +177,7 @@ object WindowContextSuite extends SimpleIOSuite with Checkers {
           override def getOutputSchemaType: String             = ???
           override def getLogger: Logger                       = ???
           override def incrCounter(key: String, amount: Long): Unit = {
-            counters.put(key, getCounter(key) + amount)
+            val _ = counters.put(key, getCounter(key) + amount)
             ()
           }
 
@@ -244,7 +244,7 @@ object WindowContextSuite extends SimpleIOSuite with Checkers {
           override def incrCounter(key: String, amount: Long): Unit = ???
           override def getCounter(key: String): Long                = ???
           override def putState(key: String, value: ByteBuffer): Unit = {
-            state.put(key, value)
+            val _ = state.put(key, value)
             ()
           }
           override def getState(key: String): ByteBuffer                 = state.getOrElse(key, null)