Skip to content

Instantly share code, notes, and snippets.

@antongorshkov

antongorshkov/Kafka Commands

Last active April 15, 2016 20:39
Show Gist options
  • Save antongorshkov/c23e880c8bbbae9c4b82b605e1543776 to your computer and use it in GitHub Desktop.
Save antongorshkov/c23e880c8bbbae9c4b82b605e1543776 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Kafka Commands
bin/kafka-topics.sh --zookeeper $KAFKAZK --describe --topic simple1
bin/kafka-topics.sh --zookeeper $KAFKAZK --alter --topic simple1 --config delete.retention.ms=5000
bin/kafka-topics.sh --zookeeper $KAFKAZK --alter --topic simple1 --config retention.ms=10000
bin/kafka-console-consumer.sh --zookeeper $KAFKAZK --topic simple1 --from-beginning
wget http://www-us.apache.org/dist/kafka/0.8.2.2/kafka_2.9.1-0.8.2.2.tgz
tar -xvf kafka_2.9.1-0.8.2.2.tgz
OR
1. Download JDK
2. Download Gradle by following instructions here: https://github.com/apache/kafka
3. https://www.sublimetext.com/3
4. download kafka-0.8.2.2-src
5. vi core/src/main/scala/kafka/tools/ProducerPerformance.scala
6. ./bin/kafka-producer-perf-test.sh --broker-list=$KAFKA -messages 10 --topic test2 --threads 10 --message-size 1000 --batch-size 100 --compression-codec 1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment