创建 topic
./kafka-topics.sh --create -zookeeper ****:2181 --topic dgaprobdomainurl --partitions 5 --replication-factor 3
查看topic
./kafka-topics.sh --zookeeper ****:2181 -describe --topic networkAccessAgent
# 开一个终端作为consumer 实时获取消息
./kafka-console-consumer.sh --bootstrap-server ****:9092 --topic test-topic --from-beginning
./kafka-console-consumer.sh --bootstrap-server ****:9092 --topic domainurlfromdw --max-messages 1 --from-beginning
删除topic
./kafka-topics.sh --delete -zookeeper ****:2181 --topic p13_anomaly_detection_topic
