Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
From: rmetzger <git@git.apache.org>
To: issues@flink.incubator.apache.org
Reply-To: issues@flink.incubator.apache.org
Message-ID: <git-pr-1039-flink@git.apache.org>
Subject: [GitHub] flink pull request: [FLINK-2386] Add new KafkaConsumer,
 based on K...
Content-Type: text/plain
Date: Fri, 21 Aug 2015 13:59:53 +0000 (UTC)

GitHub user rmetzger opened a pull request:

    https://github.com/apache/flink/pull/1039

    [FLINK-2386] Add new KafkaConsumer, based on Kafka's Simple Consumer API

    This pull request is based on https://github.com/apache/flink/pull/1028.
    I'm creating another pull request because I rebased everything to the current master.
    
    Since there were no -1 votes #1028, I assume that this PR is close to be mergeable.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/rmetzger/flink kafka_no_copy_rebased

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/1039.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #1039
    
----
commit cbdb7d6031486b42686d0006fe1726dd58c975c3
Author: Robert Metzger <rmetzger@apache.org>
Date:   2015-07-20T19:39:46Z

    [FLINK-2386] [kafka connector] Add new Kafka Consumer for Flink
    
    This closes #996

commit cb0bc7c9a067881c2d0113684646f302014aca79
Author: Stephan Ewen <sewen@apache.org>
Date:   2015-08-11T12:21:33Z

    [streaming] Cleanup de-/serialization schema, add TypeInformationSerializationSchema prominent, add tests.

commit a62688bd7717e3d4cc79f6378209c7e4e4c83924
Author: Stephan Ewen <sewen@apache.org>
Date:   2015-08-11T14:48:26Z

    [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport'

commit 8a8003ba86f89faa15fd96fcfe6a19b54782d875
Author: Stephan Ewen <sewen@apache.org>
Date:   2015-08-11T20:21:53Z

    [FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers

commit ac9114c76a7323c48110439e65e2f554d16c18c4
Author: Stephan Ewen <sewen@apache.org>
Date:   2015-08-16T14:52:16Z

    [tests] Reinforce StateCheckpoinedITCase to make sure actual checkpointing has happened before a failure.

commit 1ec61b4041dc7fb0e014a74f1cac502ae3c4e5d9
Author: Robert Metzger <rmetzger@apache.org>
Date:   2015-08-17T19:16:43Z

    [FLINK-2386] Remove copied Kafka code again. Implemented our own topic metadata retrieval.

----


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---