Package org.apache.kafka.clients.producer.internals

Interface RecordAccumulator.AppendCallbacks

All Superinterfaces:
Callback
Enclosing class:
RecordAccumulator
public static interface RecordAccumulator.AppendCallbacks extends Callback

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    setPartition(int partition)
    Called to set partition (when append is called, partition may not be calculated yet).

    Methods inherited from interface org.apache.kafka.clients.producer.Callback

    onCompletion

  • Method Details

    • setPartition

      void setPartition(int partition)
      Called to set partition (when append is called, partition may not be calculated yet).
      Parameters:
      partition - The partition