kafka.server.KafkaServer

kafka.server.KafkaServer是Kafka的核心组件之一，它是Kafka Broker的实现。Kafka Broker是Kafka集群中的一个节点，负责接收来自生产者的消息并将其存储在分布式的日志中，同时也负责从分布式日志中读取消息并将其发送给消费者。KafkaServer实现了Kafka Broker的所有功能，包括消息存储、消息复制、消息压缩、消息清理等。KafkaServerStartable是KafkaServer的启动器，它负责启动KafkaServer并提供一些管理功能，例如启动、停止、重启等。