THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * The result of the {@link AdminClient#alterOffsets(String, Map)} call. * * The API of this class is evolving, see {@link AdminClient} for details. */ @InterfaceStability.Evolving public class AlterOffsetsResult { public AlterOffsetsResult(Map<TopicPartition, KafkaFuture<Void>> futures) {} public Map<TopicPartition, KafkaFuture<Void>> values() {} public KafkaFuture<Map<TopicPartition, Void>> all() {} } |
...
AlterOffsetsOptions
Code Block language java title CommitOffsetsOptionsAlterOffsetsOptions.java /** * Options for the {@link AdminClient#alterOffsets() call. * * The API of this class is evolving, see {@link AdminClient} for details. */ @InterfaceStability.Evolving public class AlterOffsetsOptions extends AbstractOptions<AlterOffsetsOptions> { }
ListOffsetsResult
Code Block language java title ListOffsetsResult.java /** * The result of the {@link AdminClient#listOffsets(String)} call. * * The API of this class is evolving, see {@link AdminClient} for details. */ @InterfaceStability.Evolving public class ListOffsetsResult { public ListOffsetsResult(Map<TopicPartition, KafkaFuture<ListOffsetsResultInfo>> futures) {} /** * Return a map from TopicPartition to futures which can be used to retrieve the offsets */ public Map<TopicPartition, KafkaFuture<ListOffsetsResultInfo>> values() {} /** * Return a future which succeeds only if offsets for all specified partitions have been successfully * retrieved. */ public KafkaFuture<Map<TopicPartition, ListOffsetsResultInfo>> all() {} static public class ListOffsetsResultInfo { ListOffsetsResultInfo(long offset, long timestamp, Optional<Integer> leaderEpoch) {} long offset() {} long timestamp() {} Optional<Integer> leaderEpoch() {} } }
ListOffsetsOptions
Code Block language java title ListOffsetsOptions.java /** * Options for {@link AdminClient#listOffsets()}. * * The API of this class is evolving, see {@link AdminClient} for details. */ @InterfaceStability.Evolving public class ListOffsetsOptions extends AbstractOptions<ListOffsetsOptions> { private final IsolationLevel isolationLevel; // isolationLevel default to READ_UNCOMMITTED public ListOffsetsOptions() {} public ListOffsetsOptions(IsolationLevel isolationLevel) {} public IsolationLevel isolationLevel() {} }
OffsetSpec
Code Block language java /** * This class allows to specify the desired query when retrieving offsets */ public class OffsetSpec { public OffsetSpec latest() {} public OffsetSpec earliest() {} public OffsetSpec forTimestamp(long timestamp) {} }
IsolationLevel (The existing IsolationLevel class is not part of the public API, hence we are creating this new file. The old class could then be removed)
Code Block language java /** * The isolation level */ public enum IsolationLevel { READ_UNCOMMITTED((byte) 0), READ_COMMITTED((byte) 1); }
...