kafka-dev 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] (KAFKA-2961) Add a Single Topic KafkaConsumer Helper Function
Date Sat, 01 Apr 2017 13:28:41 GMT

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

ASF GitHub Bot commented on KAFKA-2961:
---------------------------------------

GitHub user TimoMeijer opened a pull request:

    https://github.com/apache/kafka/pull/2785

    KAFKA-2961: Add overload for subscribing to a single partition

    This contribution is my original work and I license the work to the project under the
project's open source license.

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

    $ git pull https://github.com/TimoMeijer/kafka kafka-2961

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

    https://github.com/apache/kafka/pull/2785.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 #2785
    
----
commit e25d696812c89de22fe60ec290a550e0e00ce437
Author: Timo Meijer <timo.meijer@rabobank.nl>
Date:   2017-04-01T13:25:09Z

    KAFKA-2961: Add overload for subscribing to a single partition

----


> Add a Single Topic KafkaConsumer Helper Function
> ------------------------------------------------
>
>                 Key: KAFKA-2961
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2961
>             Project: Kafka
>          Issue Type: Bug
>          Components: consumer
>    Affects Versions: 0.9.0.0
>            Reporter: Jesse Anderson
>            Assignee: Neha Narkhede
>
> To subscribe to a single topic, you need to write more code than you should:
> consumer.subscribe(Arrays.asList(topic));
> There should be a helper function to pass in a single topic to subscribe on. Like this:
> consumer.subscribe(topic);



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message