<commit_before>package whisk.docker

trait DockerKafkaService extends DockerKit with DockerZookeeperService {

  def KafkaAdvertisedPort = 9092

  val kafkaContainer = DockerContainer("wurstmeister/kafka:0.8.2.0")
    .withPorts(KafkaAdvertisedPort -> Some(KafkaAdvertisedPort))
    .withEnv(s"KAFKA_ADVERTISED_PORT=$KafkaAdvertisedPort")
    .withReadyChecker(DockerReadyChecker.LogLine(_.contains("started (kafka.server.KafkaServer)")))
    .withLinks(zookeeperContainer -> "zk")

  abstract override def dockerContainers: List[DockerContainer] = kafkaContainer :: super.dockerContainers
}<commit_msg>fix kafka container example<commit_after>package whisk.docker

trait DockerKafkaService extends DockerKit with DockerZookeeperService {

  def KafkaAdvertisedPort = 9092

  val kafkaContainer = DockerContainer("wurstmeister/kafka:0.8.2.0")
    .withPorts(9092 -> Some(KafkaAdvertisedPort))
    .withEnv(s"KAFKA_ADVERTISED_PORT=$KafkaAdvertisedPort", s"KAFKA_ADVERTISED_HOST_NAME=${docker.host}")
    .withReadyChecker(DockerReadyChecker.LogLine(_.contains("started (kafka.server.KafkaServer)")))
    .withLinks(zookeeperContainer -> "zk")

  abstract override def dockerContainers: List[DockerContainer] = kafkaContainer :: super.dockerContainers
}
{'fraction_non_alphanumeric': 0.10231814548361311, 'fraction_numerical': 0.01598721023181455, 'mean_word_length': 6.825, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 7, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 2, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6536019', 'n_tokens_mistral': 432, 'n_tokens_neox': 400, 'n_words': 60}