Last active
April 15, 2016 20:39
-
-
Save antongorshkov/c23e880c8bbbae9c4b82b605e1543776 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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