Users can manage Kafka topics on the MRS cluster client to meet service requirements. For clusters with Kerberos authentication enabled, the management permission is required.
The client has been updated.
Record the IP address of any ZooKeeper instance.
For example, if you have updated the client on the Master2 node, log in to the Master2 node to use the client. For details, see Client Management.
sudo su - omm
kinit Kafka username
For example, kinit admin
sh kafka-topics.sh --create --topic Topic name --partitions Number of partitions used by the topic --replication-factor Number of replicas of the topic --zookeeper IP address of the node where the ZooKeeper instance is located:clientPort/kafka
sh kafka-topics.sh --delete --topic Topic name --zookeeper IP address of the node where the ZooKeeper instance is located:clientPort/kafka