python pykafka/cli/kafka_tools.py --broker_version 0.10.1 create_topic --num_partitions 3

consumer = KafkaConsumer('my-topic', bootstrap_servers='localhost:9092')
consumer2 = KafkaConsumer('my-topic', bootstrap_servers='localhost:9092')