Page History

...

kafka-topics.sh --zookeeper <ZK_CONNECTION_STRING> --create --namespace org.apache.kafka

List

...

List

kafka-topics will be modified to support listing namespaces, as shown below.

kafka-topics.sh --zookeeper <ZK_CONNECTION_STRING> --list --namespace <NAMESPACE>

The above command will list all the namespaces under the namespace specified, <NAMESPACE>.

Delete

kafka-topics will be modified to support deleting a namespace, as shown below.

kafka-topics.sh --zookeeper <ZK_CONNECTION_STRING> --delete --namespace <NAMESPACE>

The above command will delete all topics under <NAMESPACE>. However, if there is any namespace under <NAMESPACE>, then the command will throw a warning that there are namespaces within <NAMESPACE> and die. However, if the above command is run with a recursive option, as shown below, then all namespaces within will be deleted along with current <NAMESPACE>.

kafka-topics.sh --zookeeper <ZK_CONNECTION_STRING> --delete --namespace <NAMESPACE> --recursive

Note that the delete will essentially mark topics and namespaces for deletion, the same logic that exists today for deletion.

Changes in Storage Layouts

...