[
https://issues.apache.org/jira/browse/FLINK-19893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zoucao closed FLINK-19893.
--------------------------
Resolution: Resolved
> 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
> Priority: Major
>
> 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)
