Hi team! I am planning to stop the Flink job after reading a specific flag for a partition in Kafka. Is it possible for us to define the ending boundary of kafka?