...
To start Shell you need to have a running Kafka Cluster built from the given patch (attached under KAFKA-1694) and build the Shell itself.
Get the code.
Get the KAFKA-1772_1802_1775_1774_v2.latest patch attached to KAFKA-1694.
The patch was built against trunk, on top of revision 7e9368b 01f20e0 (for patch KAFKA-1694_2015-03-12_13:04:37.patch). So reset to this commit and then run to apply the patch:git am KAFKA-1772_1802_1775_1774_v21694_latest.patch
Build the code. Run:
./gradlew releaseTarGz_2_10_4
- Start somewhere Kafka Cluster from archive under
./core/build/distributions/kafka_2.10-0.8.3-SNAPSHOT.tgz
- Unpack build archive and start Shell:
#cd <kafka_home>/core/build/distributions/ && rm -rf kafka_2.10-0.8.3-SNAPSHOT && tar -xf kafka_2.10-0.8.3-SNAPSHOT.tgz
- Start the Shell:
sudo <kafka_home>/core/build/distributions/kafka_2.10-0.8.3-SNAPSHOT/bin/kafka.sh --shell --broker <host : port>
Where <host : port> is location of one of the running brokers from the Cluster. - To get Shell help run:
sudo <kafka_home>/core/build/distributions/kafka_2.10-0.8.3-SNAPSHOT/bin/kafka.sh --help
...