Class PushReplicationEvent.OffsetPayload

java.lang.Object
io.confluent.kafka.replication.push.buffer.PushReplicationEvent.OffsetPayload
Enclosing class:
PushReplicationEvent<T>

public static final class PushReplicationEvent.OffsetPayload extends Object
A payload carrying a single offset value. Used by PushReplicationEvent.Type.HWM_UPDATE and PushReplicationEvent.Type.LSO_UPDATE events.
  • Constructor Details

    • OffsetPayload

      public OffsetPayload(long offset)
  • Method Details

    • offset

      public long offset()
    • toString

      public String toString()
      Overrides:
      toString in class Object