flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1553) Kafka connectors rework
Date Mon, 23 Feb 2015 13:11:12 GMT

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

ASF GitHub Bot commented on FLINK-1553:

GitHub user gaborhermann opened a pull request:


    [FLINK-1553] [streaming] Reworked Kafka connectors

    I refactored the Kafka connectors. It works parallelly: output gets distributed between
Kafka partitions by default, and users can also add a custom partitioning function.

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

    $ git pull https://github.com/mbalassi/flink kafka-connector

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


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

    This closes #433
commit bf92467c9c7644f3b6294cffc76b1c6d129cc77f
Author: Gábor Hermann <reckoner42@gmail.com>
Date:   2015-02-20T17:10:21Z

    [FLINK-1553] [streaming] Reworked Kafka connectors


> Kafka connectors rework
> -----------------------
>                 Key: FLINK-1553
>                 URL: https://issues.apache.org/jira/browse/FLINK-1553
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Gábor Hermann
>            Assignee: Gábor Hermann
> The Kafka connectors should be reworked and tested because it is not fully functioning
(e.g. the partitioner does not work correctly).

This message was sent by Atlassian JIRA

View raw message