java8源码-kafka-1.1.1-sourcecode:1.1.1版本kafka的源代码注释

java8 源码 Apache Kafka 1.1.1 源码注释版 源码编译调试 编译依赖：Java8 + gradle-4.8.1亲测编译成功，gradle高版本会缺少一些插件 执行gradle idea成功后，导入idea 在idea应用启动配置中配置Program arguments，指定server.properties配置文件路径 修改server.properties，指定kafka数据路径与zk路径，即可启动调试 源码注释进度 一、服务端 1. 网络层注释：已完成 SocketServer //kafka网络层的封装 |-- Acceptor //Acceptor线程的封装 |-- Processor //Processor线程的封装 Selector //对java selector的封装，封装了核心的poll，selectionkeys的遍历，事件的注册等操作 KafkaChannel //对java SocketChannel的封装，封装是实际的读写IO操作 TransportLayer //对KafkaChannel屏蔽了底层是使用Plaintext不加密通信还是