Linux Kafka配置后如何进行测试

Linux Kafka配置后可按以下步骤测试：

1. 基础功能测试

   • 创建主题：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

2. 服务状态验证

   • 检查Kafka进程：jps（需看到Kafka进程）
   • 检查端口监听：netstat -tulnp | grep 9092（确认9092端口被监听）

3. 性能测试（可选）

   • 生产者压测：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

4. 集群环境测试（若为集群部署）

   • 验证主题分布：bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server <任意节点IP>:9092
   • 跨节点消息传递：在一个节点生产消息，在另一个节点消费，验证消息是否正常同步。

说明：若使用KRaft模式（无ZooKeeper），需将--zookeeper参数替换为--bootstrap-server。