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