##相关资料

是sohu的adyliu开源的Kafka的完整Java实现(Kafka本身是用Scala的)。没有学习Scala的计划，又想研究研究MQ，那就不妨从Jafka入手了。

关于Jafka有个slides，地址：

##包结构

• api

  封装了消息等C/S通讯的对象。

• cluster

  将zk中的配置信息封装为对象。Partition=>Broker=>Cluster。

• common

  定义了一些异常和注解。几个注解@ThreadSafe、ServerSide等都是表示型的注解，没有特殊功能。

• console

  各种从控制台的启动方法。

• log

  log就是log了，没啥好说的。不过DailyRollingStrategy这些都是Log4j已有的功能，可以细看一下有什么更改。

• mx

  JMX相关。

• message

  消息体存储、压缩相关类。

• network

  网络传输相关。

• producer

  就是producer。

• server

  就是server。应该是对应broker。

• consumer

  就是consumer。

待续。