Skip to main content

Re: Kafka wire protocol and Wireshark capture don't seem to align.

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

Comments