minitest from sbt

gistfile1.scala

object KafkaStreamsTest extends TestSuite[KafkaLocalServer] with Serializers {
  def setup(): KafkaLocalServer = {
    val s = KafkaLocalServer(true)
    s.start()
    s
  }

  def tearDown(server: KafkaLocalServer): Unit = {
    server.stop()
  }

  test("should count words") { server =>
    //..
  }
}