...
System | Packages | Maintainers | Notes |
---|---|---|---|
Producer (java, scala) | kafka.producer, kafka.javaapis | Jun |
|
Consumer (java, scala) | kafka.consumer, kafka.javaapis | Neha |
|
Network Layer | kafka.network | jay |
|
Log | kafka.message, kafka.log | jay, Jun |
|
Replication | kafka.controller,kafka.server | Neha, Jun |
|
Command Line Tools |
|
|
|
System Tests | /system_tests |
|
|
API layer | kafka.server.KafkaApis, kafka.api | Jun | This includes the protocol definition for each of the APIs as well as the request logic in KafkaApis. |