KafkaBytesBuilder.withRequestHeader constructor

KafkaBytesBuilder.withRequestHeader(
  1. int apiKey,
  2. int apiVersion,
  3. int correlationId
)

Creates new builder and initializes buffer with proper request header.

Implementation

KafkaBytesBuilder.withRequestHeader(int apiKey, int apiVersion, int correlationId) {
  addInt16(apiKey);
  addInt16(apiVersion);
  addInt32(correlationId);
  addString(dartKafkaId);
}