The correlation ID is in the response **header**. On Sun, Oct 27, 2024 at 10:36 PM Ömer Şiar Baysal <osiarbay...@gmail.com> wrote:
> Hi, > > Could not able to find correlationID response for the Apiversions API, did > you mean Produce API? > > Maybe it is throttleTimeSize ? > > > https://github.com/a0x8o/kafka/blob/54eff6af115ee647f60129f2ce6a044cb17215d0/core/src/main/scala/kafka/api/ProducerResponse.scala#L68 > > On Sun, Oct 27, 2024, 17:42 Chain Head <mrchainh...@gmail.com> wrote: > > > (Apologies - I sent the same mail to the dev mailing list by mistake!) > > > > Hello, > > I set-up a simple Java client to publish a sample message to Kafka > broker. > > I can see API Versions request v3 and response messages. I am able to map > > all the bytes as described here > > (https://kafka.apache.org/protocol.html#The_Messages_ApiVersions) for > > API > > Versions request and response except for 1 byte as shown below. > > > > - Length - INT32 > > - Correlation ID - INT32 > > - Error code - INT16 > > - ? - 1 byte value 0x3c > > - Array of API keys, supported versions and tagged fields > > - Throttle - INT32 > > - Tagged fields. > > > > Can you please help me understand? > > > > Thanks. > > >
