Package org.apache.kafka.streams.query

Class PositionBound

java.lang.Object
org.apache.kafka.streams.query.PositionBound
@Evolving public class PositionBound extends Object
A class bounding the processing state Position during queries. This can be used to specify that a query should fail if the locally available partition isn't caught up to the specified bound. "Unbounded" places no restrictions on the current location of the partition.

  • Method Details

    • unbounded

      public static PositionBound unbounded()
      Creates a new PositionBound representing "no bound"

    • at

      public static PositionBound at(Position position)
      Creates a new PositionBound representing a specific position.

    • isUnbounded

      public boolean isUnbounded()
      Returns true iff this object specifies that there is no position bound.

    • position

      public Position position()
      Returns the specific position of this bound.

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

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

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object