Package org.apache.kafka.clients.admin

Class StreamsGroupMemberDescription.TaskOffset

java.lang.Object
org.apache.kafka.clients.admin.StreamsGroupMemberDescription.TaskOffset
Enclosing class:
StreamsGroupMemberDescription
public static class StreamsGroupMemberDescription.TaskOffset extends Object
The cumulative offset for one task.

  • Constructor Details

    • TaskOffset

      public TaskOffset(String subtopologyId, int partition, long offset)

  • Method Details

    • subtopologyId

      public String subtopologyId()
      The subtopology identifier.

    • partition

      public int partition()
      The partition of the task.

    • offset

      public long offset()
      The cumulative offset (sum of offsets in all input partitions).

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object