使用命令行操作kafka

项目中使用kafka，但是时间原因并没有建设一些kafka监控和操作的可视化界面。
因此，使用kafka自带的命令行进行了常见的操作，比方说创建topic，查询信息，向指定队列发送信息等。使用命令行需要进入kafka的安装目录中，能看到bin文件夹那一层即可。

• 查询kafka下所有的topic
  bin/kafka-topics.sh --list --zookeeper ip:port
  因为kafka使用zookeeper作为配置中心，一些topic信息需要查询该kafka对应的zookeeper
• 创建topic
  bin/kafka-topics.sh --create --zookeeper ip:port --replication-factor 1 --partitions 1 --topic test
  表示创建了一个test的topic，副本是1，分区也是1
• 向topic发送消息
  bin/kafka-console-producer.sh --broker-list ip:port --topic test
  表示向test的topic发送消息内容，这里的ip:port指的是kafka的ip和port，执行完这条命令后面会让你要发送的信息，输入好后回车即可。
• 查询topic内容
  bin/kafka-console-consumer.sh --bootstrap-server ip:port --topic test --from-beginning
  查询test的topic中的所有的消息