Kafka面试精讲：18道重点问题与解答

"这份文档包含了有关Kafka的18个面试问题和答案，主要涵盖了Kafka的基本操作和设计理念。" 1. 获取Topic主题列表的方法 Kafka提供了`bin/kafka-topics.sh`脚本用于管理和查看主题。在命令行中，你可以通过以下命令获取所有主题的列表： ``` bin/kafka-topics.sh --list --zookeeper localhost:2181 ``` 这里，`localhost:2181`是Zookeeper服务器的地址，它是Kafka集群的协调者。 2. 生产者和消费者的命令行工具 - 生产者命令： 使用`bin/kafka-console-producer.sh`脚本可以创建一个命令行生产者，向指定主题发布消息。例如： ``` bin/kafka-console-producer.sh --broker-list 192.168.43.49:9092 --topic Hello-Kafka ``` IP `192.168.43.49:9092` 是Kafka服务器的监听地址，新行会被当作一条消息发送到`Hello-Kafka`主题。 - 消费者命令： 使用`bin/kafka-console-consumer.sh`来创建一个命令行消费者，接收特定主题的消息： ``` bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic Hello-Kafka --from-beginning ``` `localhost:2181`同样是Zookeeper的地址，`--from-beginning`表示从主题的最早消息开始消费。 3. 消费者模型：推（Push）与拉（Pull） Kafka设计为producer推送消息到broker，而consumer从broker拉取消息，即Pull模式。这种设计的原因在于： - Push模式可能导致消息推送速率超过consumer的消费速率，造成consumer崩溃。 - Pull模式允许consumer自主控制消费速率和批量拉取策略，更灵活且避免了不必要的网络传输。 Pull模式的缺点是当broker无消息时，consumer可能会频繁轮询。Kafka为此提供了一个参数，让消费者在无消息时可以阻塞等待，减少不必要的网络请求。 总结：Kafka的面试题涉及到其基本操作和设计哲学，包括如何列举主题，如何使用命令行工具进行生产和消费，以及它选择Pull模式作为消费者模型的原因。理解这些概念对理解和使用Kafka至关重要。