org.apache.kafka.clients.producer.internals
Class RecordAccumulator.RecordAppendResult

java.lang.Object
  org.apache.kafka.clients.producer.internals.RecordAccumulator.RecordAppendResult

Enclosing class:

RecordAccumulator

public static final class RecordAccumulator.RecordAppendResult
extends java.lang.Object

Field Summary

boolean	batchIsFull
FutureRecordMetadata	future
boolean	newBatchCreated

Constructor Summary

RecordAccumulator.RecordAppendResult(FutureRecordMetadata future, boolean batchIsFull, boolean newBatchCreated)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

future

public final FutureRecordMetadata future

batchIsFull

public final boolean batchIsFull

newBatchCreated

public final boolean newBatchCreated

Constructor Detail

RecordAccumulator.RecordAppendResult

public RecordAccumulator.RecordAppendResult(FutureRecordMetadata future,
                                            boolean batchIsFull,
                                            boolean newBatchCreated)