Quick start on Kafka

setup_kafka.sh

# To Setup and build Kafka:
$ git clone [email protected]:apache/kafka.git
$ cd kafka
$ git checkout -b 0.8 remotes/origin/0.8
$ ./gradlew jarAll


# Start Zookeeper
$ bin/zookeeper-server-start.sh config/zookeeper.properties

# Start Kafka
$ env JMX_PORT=9999 bin/kafka-server-start.sh config/server.properties

# Create a topic "trips"
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic trips

# List all the topics
$ bin/kafka-topics.sh --list --zookeeper localhost:2181     

# Describe a topic
$ bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic trips      

# To produce a topic
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic trips

# To consume a topic
$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic trips