Scala - как передать Callback в метод

Question

Я пытаюсь представить метод Java через Scala (от Kafka: https://kafka.apache.org/10/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html).
Это оригинальный метод Java:

public void commitAsync(OffsetCommitCallback callback)

Как передать callback методу в Scala? У меня есть что-то вроде:

 def commitAsync() = {
    consumer.commitAsync(OffsetCommitCallback callback)
  }

Спасибо.
Бонусные баллы - как бы выглядел тест на это, например. использование MockitoSugar?

Answer 1

Вы можете обработать обратный вызов следующим образом:

def commitAsync() = {
   consumer.commitAsync(new OffsetCommitCallback() {
      def onComplete(m: java.util.Map[TopicPartition, OffsetAndMetadata], e: Exception) {
        //...
      }
   })
}

OffsetCommitCallback - это интерфейс («похож» на trait в Scala), поэтому вы можете инициировать экземпляр анонимно.

Вот - это быстрое появление в проекте Spark.