Not sure if this answers your question, but the entry point for handling
the FetchRequest is here:
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaApis.scala#L436
That file has the entry points for the handlers of other requests as well.
Thanks,
Apurva
On Sun, No
Hi,
I am looking for Apache Kafka documentations and related sources that
describe about Apache Kafka core module and it's implementation. Specially
interested in how kafkaConsumer fetch requests are handled in broker side
and brokers, end points and partition behaviors.
I am so grateful if someo
