Skip to content

ProducerBatch

Creating Instance

ProducerBatch takes the following to be created:

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

ProducerBatch is created when:

tryAppend

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

tryAppend...FIXME

tryAppend is used when: