ProducerBatch¶

Creating Instance¶

ProducerBatch takes the following to be created:

• TopicPartition
• MemoryRecordsBuilder
• createdMs
• isSplitBatch flag (default: false)

ProducerBatch is created when:

• ProducerBatch is requested to createBatchOffAccumulatorForRecord
• RecordAccumulator is requested to append a record

tryAppend¶

FutureRecordMetadata tryAppend(
  long timestamp,
  byte[] key,
  byte[] value,
  Header[] headers,
  Callback callback,
  long now)

tryAppend...FIXME

tryAppend is used when:

• RecordAccumulator is requested to append a record