下面是如何配置我的测试服。

"test payments" should {
    "Add 100 credits" in {
      runTeamTest { team =>
        withRunningKafka {
          val addCreditsRequest = AddCreditsRequest(team.id.stringify, member1Email, 100)
          TestCommon.makeRequestAndCheck(
            member1Email,
            TeamApiGenerated.addCredits().url,
            Helpers.POST,
            Json.toJson(addCreditsRequest),
            OK
          )

          val foundTeam = TestCommon.waitForFuture(TeamDao.findOneById(team.id))
          foundTeam.get.credits mustEqual initialCreditAmount + 100
        }
      }
    }

    "deduct 100 credits" in {
      runTeamTest { team =>
        withRunningKafka {
          val deductCreditsRequest = DeductCreditsRequest(team.id.stringify, member1Email, 100)
          TestCommon.makeRequestAndCheck(
            member1Email,
            TeamApiGenerated.deductCredits().url,
            Helpers.POST,
            Json.toJson(deductCreditsRequest),
            OK
          )

          val foundTeam = TestCommon.waitForFuture(TeamDao.findOneById(team.id))
          foundTeam.get.credits mustEqual initialCreditAmount - 100
        }
      }
    }

在scalatest中，最重要的套装名称是 "test payments" 在第一个测试运行后，它内部的后续测试会出现问题。如果我分别运行这两个测试中的每一个，它们将成功，但是如果我运行整个套装，第一个测试将成功，第二个测试将返回 org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. 例外。上面的代码没有显示正在测试的控制器中的代码，但是在控制器中，我有一个kafka消费者，它不断地进行轮询和测试 close() 在测试中没有调用它。