1. #创建topic
    2. $ kafka-topics.sh --create --zookeeper 10.37.16.15:2181 --replication-factor 1 --partitions 1 --topic kafka-test—topic
    4. #列出topic
    5. $ kafka-topics.sh --zookeeper 10.37.16.15:2181 --list
    7. #查看topic详情：Leader为none，选举问题（依次干掉并重启zookeeper，kafka，logstash）
    8. $ kafka-topics.sh --zookeeper  10.37.16.15:2181 --describe  --topic ops.kube-logs-fluentbit.stream.json.001
    9. Topic: ops.kube-logs-fluentbit.stream.json.001  PartitionCount: 1       ReplicationFactor: 1    Configs:
    10. Topic: ops.kube-logs-fluentbit.stream.json.001  Partition: 0    Leader: none    Replicas: 1001  Isr: 1001
    12. #查看消息内容
    13. $ kafka-console-consumer.sh --bootstrap-server 10.37.16.15:9092 --topic ops.kube-logs-fluentbit.stream.json.001  --from-beginning
    14. $ kafka-console-consumer.sh --bootstrap-server 10.37.16.15:9092 --topic ops.kube-logs-fluentbit.stream.json.001 --offset latest --partition 0 --max-messages 1
    16. #查看消费者组
    17. $ kafka-consumer-groups.sh --bootstrap-server 10.37.16.15:9092 --list
    19. #查看消费详情
    20. $ kafka-consumer-groups.sh --bootstrap-server 10.37.16.15:9092 --group logstash --describe
    21. GROUP           TOPIC                                   PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID                                     HOST            CLIENT-ID
    22. logstash        ops.kube-logs-fluentbit.stream.json.001 0          16231691        16231697        6               logstash-0-67bc3547-ee38-4252-a2a8-03ea1f13c05b /172.18.0.1     logstash-0