服务测试
2.2+=的版本，已经不需要依赖zookeeper来查看/创建topic，新版本使用 --bootstrap-server替换老版本的 --zookeeper-server
Topic测试
#创建topic，使用 kafka-topics.sh 创建单分区单副本的 topic test01 ./bin/kafka-topics.sh --create --bootstrap-server doris:9092 --replication-factor 1 --partitions 1 --topic test01 #查询topic列表 ./bin/kafka-topics.sh --list --bootstrap-server doris:9092 #指定查看 ./bin/kafka-topics.sh --bootstrap-server doris:9092 --describe --topic test01 #删除topic ./bin/kafka-topics.sh --bootstrap-server doris:9092 --delete --topic test01
生产测试
#开一个窗，启动生产者 ./bin/kafka-console-producer.sh --broker-list doris:9092 --topic test01
消费测试
#开一个窗，启动消费者 #旧版本 ./bin/kafka-console-consumer.sh --bootstrap-server doris:9092 --topic test01 --from-beginning #新版本 ./bin/kafka-console-consumer.sh --bootstrap-server doris:9092 --topic test01 --from-beginning #查看kafka生产最大位置偏移量 ./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list doris:9092 --topic test01 --time -1
常见问题
ZK启动失败
异常详情：Error: VM option ‘UseG1GC’ is experimental and must be enabled via -XX:+UnlockExperimentalVMOptions.
解决：
#修改./bin/kafka-run-class.sh vim ./bin/kafka-run-class.sh #KAFKA_JVM_PERFORMANCE_OPTS="-server -XX:+UseG1GC -XX:MaxGCPauseMillis=20 #直接删掉 -XX:+UseG1GC。重启zk集群，启动kafka集群即可
kafka安装部署至此结束，安装部署过程中若遇到问题欢迎留言交流
