Class ConsumerOffsetCommitter.CommitRequest

java.lang.Object
io.confluent.parallelconsumer.internal.ConsumerOffsetCommitter.CommitRequest
Enclosing class:
ConsumerOffsetCommitter<K,V>

public static final class ConsumerOffsetCommitter.CommitRequest extends Object
Commit request message
  • Constructor Details

    • CommitRequest

      public CommitRequest()
  • Method Details

    • getId

      public UUID getId()
    • getRequestedAtMs

      public long getRequestedAtMs()
    • 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