public class TimestampStartCursor extends Object implements StartCursor
Constructor and Description |
---|
TimestampStartCursor(long timestamp) |
Modifier and Type | Method and Description |
---|---|
CursorPosition |
position(String topic,
int partitionId) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
defaultStartCursor, earliest, fromMessageId, fromMessageId, fromMessageTime, latest, seekPosition
public CursorPosition position(String topic, int partitionId)
position
in interface StartCursor
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.