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.
> >
>

Reply via email to