如何测试Ubuntu Kafka配置效果

测试Ubuntu Kafka配置效果可按以下步骤进行：

1. 检查服务状态
   • 使用sudo systemctl status kafka和sudo systemctl status zookeeper确保服务正常运行。
2. 验证配置文件
   • 检查server.properties中broker.id、listeners、advertised.listeners、zookeeper.connect等关键配置是否正确。
3. 查看日志
   • 通过tail -f /var/log/kafka/server.log查看日志，确认无错误或异常信息。
4. 测试Topic操作
   • 创建测试Topic：bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test。
   • 列出Topic验证创建成功：bin/kafka-topics.sh --list --zookeeper localhost:2181。
5. 验证消息生产与消费
   • 启动生产者发送消息：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test。
   • 启动消费者接收消息：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning，确认能收到消息。
6. 检查网络与防火墙
   • 使用ping和telnet确保Kafka端口（如9092）可达，且advertised.listeners配置正确。
7. 性能测试（可选）
   • 使用工具（如k6、JMeter）模拟负载，监控吞吐量、延迟等指标。