You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 4 Next »

This wiki contains some ideas on improving the Kafka wire format. This would likely be a breaking change. The goal would be to do some or all of the following:

  • Add new fields to the request, some fields to add would be
    • Correlation Id - Long - A way to correlate requests to responses if they are sent asynchronously.
    • Response Expected - Boolean - Indicates whether a response back from the server is expected. This is described in KAFKA-49.
    • Add the fields required to support long poll in the fetch request (described in KAFKA-48). The proposed fields were a Int field indicating the tieout
  • Combine FetchRequest/MultiFetchRequest and ProduceRequest/MultiProduceRequest
  • Topic/Partition refactoring - Currently each topic/partition is sent as a separate entry which leads to the same topic being duplicated many times in the common case
  • No labels