dantin

package main

import (
	"database/sql"
	"flag"
	"fmt"
	"os"
	"os/signal"
	"strings"
	"sync"

dantin

version: '2'
services:
  zookeeper:
    # use official zookeeper image
    image: zookeeper
    ports:
      - "2181:2181"

  kafka:
    image: wurstmeister/kafka