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

Compare with Current View Page History

« Previous Version 2 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
    • 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
    • Combine FetchRequest/MultiFetchRequest and ProduceRequest/MultiProduceRequest
    • Add the fields required to support long poll in the fetch request (described in KAFKA-48)
  • No labels