Versions Compared

Old Version 15

changes.mady.by.user Mickael Maison

Saved on

compared with

New Version 16

changes.mady.by.user Mickael Maison

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
titleCommitOffsetsResultAlterOffsetsResult.java
/**
 * 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
    languagejava
    titleCommitOffsetsOptionsAlterOffsetsOptions.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
    languagejava
    titleListOffsetsResult.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
    languagejava
    titleListOffsetsOptions.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
    languagejava
    /**  
 * 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
    languagejava
    /**
 * The isolation level 
 */
public enum IsolationLevel {
    READ_UNCOMMITTED((byte) 0),
    READ_COMMITTED((byte) 1);
}


...