Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Hi @gyfora,
Yes, it is absolutely possible to add that. There's actually a JIRA for
that feature too
([FLINK-3123](https://issues.apache.org/jira/browse/FLINK-3123)), so I'd say we
can add that feature on top of the proposed changes here, as a separate follow
up PR after this one?
One note though, the API for that feature would need to be able to specify
offsets for partitions of different topics, since the Kafka consumers can
subscribe multiple topics. So, `Map<Integer,Long>` wouldn't fit this case,
probably would be better off having a new user-facing class as the argument to
define the offsets.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
