flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1935) Reimplement PersistentKafkaSource using high level Kafka API
Date Sat, 09 May 2015 10:46:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14536356#comment-14536356

Robert Metzger commented on FLINK-1935:

Pull request on Stephan's WIP branch opened: https://github.com/StephanEwen/incubator-flink/pull/13

> Reimplement PersistentKafkaSource using high level Kafka API
> ------------------------------------------------------------
>                 Key: FLINK-1935
>                 URL: https://issues.apache.org/jira/browse/FLINK-1935
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kafka Connector, Streaming
>    Affects Versions: 0.9
>            Reporter: Robert Metzger
>            Assignee: Robert Metzger
>             Fix For: 0.9
> The current PersistentKafkaSource in Flink has some limitations that I seek to overcome
by reimplementing it using Kafka's high level API (and manually committing the offsets to
> This approach only works when the offsets are committed to ZK directly.
> The current PersistentKafkaSource does not integrate with existing Kafka tools (for example
for monitoring the "lag"). All the communication with Zookeeper is implemented manually in
our current code. This is prone to errors and inefficiencies.

This message was sent by Atlassian JIRA

View raw message