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)
