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。