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