public class TierAbortedTxnReader extends Object
Constructor and Description |
---|
TierAbortedTxnReader() |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.kafka.storage.internals.log.AbortedTxn> |
readInto(CancellationContext ctx,
InputStream inputStream,
long startOffset,
long lastOffset)
Read aborted transaction markers from the supplied inputstream
|
public static List<org.apache.kafka.storage.internals.log.AbortedTxn> readInto(CancellationContext ctx, InputStream inputStream, long startOffset, long lastOffset)