Page History

Producer (java, scala)

kafka.producer, kafka.javaapis

Jun, Neha, Jonathan, Joestein

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

Joestein, Jonathan

System Tests

/system_tests

  Joestein

API layer

kafka.server.KafkaApis, kafka.api

Jun, Joel, Joestein

This includes the protocol definition for each of the APIs as well as the request logic in KafkaApis.