scala - 如何通过手动调用单独测试回调？

Question

使用 scalatest，是否可以以某种方式手动触发回调以测试我的onComplete方法是否被调用并且不会引发异常？

由于它返回 Unit，我只想确保它被调用并且不会出错。

class CustomOffsetCallback extends OffsetCommitCallback with Logging {
   override def onComplete(offsets: util.Map[TopicPartition, OffsetAndMetadata], exception: Exception): Unit =
     if (exception != null)
       logger.error(s"...")
     else
       logger.debug(s"....")
}

标签： scalascalatest