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