要测试Ubuntu上的Kafka配置是否正确,可以按照以下步骤进行操作:
启动Kafka和Zookeeper服务:
/opt/kafka_2.13-3.5.2/bin/zookeeper-server-start.sh /opt/kafka_2.13-3.5.2/config/zookeeper.properties
/opt/kafka_2.13-3.5.2/bin/kafka-server-start.sh /opt/kafka_2.13-3.5.2/config/server.properties
验证Kafka是否启动成功:
netstat -tulnp | grep 9092
tcp 0 0 0.0.0.0:9092 0.0.0.0:* LISTEN
创建一个测试Topic:
test
的Topic,副本因子为1,分区数为1:/opt/kafka_2.13-3.5.2/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
验证Topic是否创建成功:
test
Topic已创建:/opt/kafka_2.13-3.5.2/bin/kafka-topics.sh --list --zookeeper localhost:2181
测试生产者和消费者:
/opt/kafka_2.13-3.5.2/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
/opt/kafka_2.13-3.5.2/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
通过以上步骤,你可以验证Kafka是否配置正确并且能够正常运行。如果生产者和消费者能够成功地发送和接收消息,说明Kafka配置成功。