如何在运行测试之前启动 docker 容器答案

【问题标题】：How to start a docker container before run the test如何在运行测试之前启动 docker 容器
【发布时间】：2019-05-12 12:04:46
【问题描述】：

我想为Scala 项目设置一个测试环境。另外，我需要启动运行在 docker 容器中的 Kafka。在测试开始之前，它应该启动第一个 Kafka 容器。

我正在使用 Scalatest 并考虑在测试运行之前启动 TestFixture 中的 Kafka 容器。

问题是，这是在运行测试之前启动容器的推荐方式。我考虑了Docker API，但不确定它是否正确。

【问题讨论】：

添加你的代码..
你指的是哪个代码？我还没有任何代码，因为仍在尝试弄清楚，我应该怎么做。
创建一个 docker-compose 文件并为 kafka 和 test.. 创建两个服务并让 test 依赖于 kafka.. 这样 kafka 将首先运行然后测试..
看看Testcontainers-Scala 我已经在几个项目中使用过它，而且效果很好。
@zero_coding 实际上 Murtaza 提到的方式是前进的正确方式。

标签： scala docker apache-kafka automated-tests

【解决方案1】：

您可以使用testcontainers-scala，它只是testcontainers 的包装。

在你的build.sbt 添加：

libraryDependencies += "com.dimafeng" %% "testcontainers-scala" % "0.25.0" % "test"
libraryDependencies += "org.apache.kafka" % "kafka-clients" % "2.2.0"

然后你可以创建规范：

import com.dimafeng.testcontainers.{ForAllTestContainer, GenericContainer}
import org.apache.kafka.clients.consumer.KafkaConsumer
import org.apache.kafka.common.serialization.{StringDeserializer, StringSerializer}
import org.scalatest.FlatSpec
import org.testcontainers.containers.Network
import org.testcontainers.utility.Base58


class KafkaSpec extends FlatSpec with ForAllTestContainer {

  final val KafkaPort = 9093

  override val container = GenericContainer("confluentinc/cp-kafka").configure{ c =>
    c.withNetwork(Network.newNetwork())
    c.withNetworkAliases("kafka-" + Base58.randomString(6))
    c.withExposedPorts(KafkaPort)
    c.withEnv("KAFKA_LISTENERS", "PLAINTEXT://0.0.0.0:" + KafkaPort + ",BROKER://0.0.0.0:9092")
    c.withEnv("KAFKA_LISTENER_SECURITY_PROTOCOL_MAP", "BROKER:PLAINTEXT,PLAINTEXT:PLAINTEXT")
    c.withEnv("KAFKA_INTER_BROKER_LISTENER_NAME", "BROKER")
    c.withEnv("KAFKA_BROKER_ID", "1")
    c.withEnv("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1")
    c.withEnv("KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS", "1")
    c.withEnv("KAFKA_LOG_FLUSH_INTERVAL_MESSAGES", Long.MaxValue.toString)
    c.withEnv("KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS", "0")
  }


  it should "do something" in {

    val properties = new Properties()
    properties.put("bootstrap.servers", s"${container.containerIpAddress}:$KafkaPort")
    properties.put("group.id", "test")
    properties.put("key.deserializer", classOf[StringDeserializer])
    properties.put("value.deserializer", classOf[StringDeserializer])
    properties.put("key.serializer", classOf[StringSerializer])
    properties.put("value.serializer", classOf[StringSerializer])

    val kafkaConsumer = new KafkaConsumer[String, String](properties)
    ....

  }
}

【讨论】：

可能想使用最新版本的 kafka-clients？