Simple aliases and functions for Apache Kafka commands

kafka_commands.sh

export KAFKA_HOME=<kafka installation directory>

# Start Kafka server
alias startKafka='$KAFKA_HOME/bin/kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties'

# List of topics with zookeeper of localhost
alias topics='$KAFKA_HOME/bin/kafka-topics.sh --list --zookeeper localhost:2181'

# Create a new cosnumer that reads from the starting from the topic. It uses localhost kafka broker.
# Example: readtopic topicName
readtopic () 
{
    $KAFKA_HOME/bin/kafka-console-consumer.sh --topic $1 --from-beginning --bootstrap-server localhost:9092
}

# use this to delete a topic
# Example: deletetopic topicName
deletetopic()
{
    $KAFKA_HOME/bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic $1
}

# Create a new cosnumer that reads from the current record of the topic. It uses localhost kafka broker.
# Example: readtopic topicName
readtopicnow(){
        $KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic $1
}