Linux Kafka配置后如何进行测试
Linux Kafka配置后可按以下步骤测试:
-
基础功能测试
- 创建主题:
bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
- 查看主题列表:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
- 生产消息:
echo "Hello Kafka" | bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092
- 消费消息:新终端执行
bin/kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092
- 创建主题:
-
服务状态验证
- 检查Kafka进程:
jps
(需看到Kafka
进程) - 检查端口监听:
netstat -tulnp | grep 9092
(确认9092端口被监听)
- 检查Kafka进程:
-
性能测试(可选)
- 生产者压测:
bin/kafka-producer-perf-test.sh --topic perf-test --num-records 1000000 --record-size 1024 --throughput 5000 --producer-props bootstrap.servers=localhost:9092
- 消费者吞吐测试:
bin/kafka-consumer-perf-test.sh --topic perf-test --messages 1000000 --bootstrap-server localhost:9092
- 生产者压测:
-
集群环境测试(若为集群部署)
- 验证主题分布:
bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server <任意节点IP>:9092
- 跨节点消息传递:在一个节点生产消息,在另一个节点消费,验证消息是否正常同步。
- 验证主题分布:
说明:若使用KRaft模式(无ZooKeeper),需将--zookeeper
参数替换为--bootstrap-server
。
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权请联系我们,一经查实立即删除!