Apache Kafka Deleting a Topic

posted on Nov 20th, 2016

Apache Kafka

Apache Kafka is an open-source message broker project developed by the Apache Software Foundation written in Scala. The project aims to provide a unified, high-throughput, low-latency platform for handling real-time data feeds. It is, in its essence, a "massively scalable pub/sub message queue architected as a distributed transaction log," making it highly valuable for enterprise infrastructures to process streaming data.

Pre Requirements

1) A machine with Ubuntu 14.04 LTS operating system

2) Apache Kakfa 2.9.2-0.8.1.1 software installed. (How to install kafka on ubuntu)

Deleting a Kafka Topic

The following steps to delete a topic.

Steps to follow

Step 1 - Open a new terminal (CTRL + ALT + T) and change the directory to /usr/local/kafka

$ cd /usr/local/kafka

Step 2 - Start the zookeeper

$ ./bin/zookeeper-server-start.sh config/zookeeper.properties

Step 3 - Open a new terminal (CTRL + ALT + T) and change the directory to /usr/local/kafka

$ cd /usr/local/kafka

Step 4 - Start the kafka server

$ ./bin/kafka-server-start.sh config/server.properties

Step 5 - Open a new terminal (CTRL + ALT + T) and just type 'jps' (without quotes). It shows all the java processes that are running.

Apache Kafka Deleting a Topic

Here Kafka is the kafka server and QuorumPeerMain is zookeeper process.

Step 6 - Open a new terminal (CTRL + ALT + T) and change the directory to /usr/local/kafka

$ cd /usr/local/kafka

Step 7 - Create a topic.

$ ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Hello-Kafka

Step 8 - List topics. (optional)

$ ./bin/kafka-topics.sh --list --zookeeper localhost:2181

Step 9 - Delete a topic.

$ ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic Hello-kafka

NOTE

To delete a topic, the below propery must be true in /usr/local/kafka/config/server.properties file.

delete.topic.enable = true

Please share this blog post and follow me for latest updates on

facebook             google+             twitter             feedburner

Previous Post                                                                                          Next Post

Labels : Apache Kafka Installation on Ubuntu   Kafka Single Node Single Broker Configuration   Kafka Single Node Multiple Brokers Configuration   Kafka Java API usage   Creating a Kafka topic   Modifying a Kafka topic