[jira] [Created] (FLINK-19893) stop consuming in specific offset or timestamp

[Shang Yuanchun (Jira)]

zoucao created FLINK-19893:
------------------------------

             Summary: stop consuming in specific offset or timestamp
                 Key: FLINK-19893
                 URL: https://issues.apache.org/jira/browse/FLINK-19893
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka
            Reporter: zoucao


Hi all, I think something new  for kafka connector should be added.

When using flink to consume message from MQ, there exists a large number of message in topic, not been consumed, and the production rate is equal to consumption rate，such that we have a high latency. In that condition, two task need to be started, one consumes the latest message, the other consumes the earliest message and stop consuming in the current offset or timestamp. May be we should support kafak connector in stopping consuming in specific offset or timestamp.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)