Return-Path: 
 <issues-return-39162-apmail-flink-issues-archive=flink.apache.org@flink.apache.org>
X-Original-To: apmail-flink-issues-archive@minotaur.apache.org
Delivered-To: apmail-flink-issues-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 7B80818A69
	for <apmail-flink-issues-archive@minotaur.apache.org>;
 Mon,  7 Dec 2015 10:11:11 +0000 (UTC)
Received: (qmail 54013 invoked by uid 500); 7 Dec 2015 10:11:11 -0000
Delivered-To: apmail-flink-issues-archive@flink.apache.org
Received: (qmail 53844 invoked by uid 500); 7 Dec 2015 10:11:11 -0000
Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:issues-help@flink.apache.org>
List-Unsubscribe: <mailto:issues-unsubscribe@flink.apache.org>
List-Post: <mailto:issues@flink.apache.org>
List-Id: <issues.flink.apache.org>
Reply-To: dev@flink.apache.org
Delivered-To: mailing list issues@flink.apache.org
Received: (qmail 53801 invoked by uid 99); 7 Dec 2015 10:11:11 -0000
Received: from arcas.apache.org (HELO arcas) (140.211.11.28)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 07 Dec 2015 10:11:11 +0000
Received: from arcas.apache.org (localhost [127.0.0.1])
	by arcas (Postfix) with ESMTP id 0748C2C1F5A
	for <issues@flink.apache.org>; Mon,  7 Dec 2015 10:11:11 +0000 (UTC)
Date: Mon, 7 Dec 2015 10:11:11 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.12917661.1449079282000.288088.1449483071026@Atlassian.JIRA>
In-Reply-To: <JIRA.12917661.1449079282000@Atlassian.JIRA>
References: <JIRA.12917661.1449079282000@Atlassian.JIRA>
 <JIRA.12917661.1449079282047@arcas>
Subject: [jira] [Commented] (FLINK-3102) Allow reading from multiple topics
 with one FlinkKafkaConsumer
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394


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

ASF GitHub Bot commented on FLINK-3102:
---------------------------------------

Github user aljoscha commented on a diff in the pull request:

    https://github.com/apache/flink/pull/1437#discussion_r46804012
  
    --- Diff: flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Fetcher.java ---
    @@ -61,15 +53,15 @@
     	 *     }
     	 * }
     	 * }</pre>
    -	 * 
    +	 *
    +	 * @param <T> The type of elements produced by the fetcher and emitted to the source context.
     	 * @param sourceContext The source context to emit elements to.
     	 * @param valueDeserializer The deserializer to decode the raw values with.
    -	 * @param lastOffsets The array into which to store the offsets for which elements are emitted (operator state)
    -	 * 
    -	 * @param <T> The type of elements produced by the fetcher and emitted to the source context.
    +	 * @param lastOffsets The map into which to store the offsets for which elements are emitted (operator state)
    +*
    --- End diff --
    
    Strange formatting of `*`. Did you check whether the generic param should be before normal params or why did you move?


> Allow reading from multiple topics with one FlinkKafkaConsumer
> --------------------------------------------------------------
>
>                 Key: FLINK-3102
>                 URL: https://issues.apache.org/jira/browse/FLINK-3102
>             Project: Flink
>          Issue Type: New Feature
>          Components: Kafka Connector
>            Reporter: Robert Metzger
>            Assignee: Robert Metzger
>
> Currently, a Kafka consumer allows to read from only one topic.
> For cases where multiple topics contain messages with the same schema, it is useful to allow to subscribe to many topics using one FlinkKafkaConsumer instance.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)