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