[
https://issues.apache.org/jira/browse/KAFKA-3176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340461#comment-15340461
]
ASF GitHub Bot commented on KAFKA-3176:
---------------------------------------
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/922
KAFKA-3176: Add partition/offset options to the new consumer
With this pull request the new console consumer can be provided with
optional --partition and --offset arguments so only messages from a particular
partition and starting from a particular offset are consumed.
The following rules are also implemented to avoid invalid combinations of
arguments:
- If --partition or --offset is provided --new-consumer has to be provided
too.
- If --partition is provided --topic has to be provided too.
- If --offset is provided --partition has to be provided too.
- --offset and --from-beginning cannot be used at the same time.
This patch is co-authored with @rajinisivaram.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-3176
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/922.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 #922
----
commit 5058e4f1c81ed8f47f021248490cf8d3ad1ecc3c
Author: Vahid Hashemian <[email protected]>
Date: 2016-02-16T13:24:38Z
KAFKA-3176: Add partition/offset options to the new console consumer
With this feature the new console consumer can be provided with optional
--partition and --offset arguments so messages from a particular partition and
starting from a particular offset are consumed.
The following rules are also implemented to avoid invalid combinations of
arguments:
- If --partition and/or --offset are provided --new-consumer has to be
provided too.
- If --partition is provided --topic has to be provided too.
- If --offset is provided --partition has to be provided too.
- --offset and --from-beginning cannot be used at the same time.
----
> Allow console consumer to consume from particular partitions when new
> consumer is used.
> ---------------------------------------------------------------------------------------
>
> Key: KAFKA-3176
> URL: https://issues.apache.org/jira/browse/KAFKA-3176
> Project: Kafka
> Issue Type: New Feature
> Components: tools
> Affects Versions: 0.9.0.0
> Reporter: Jiangjie Qin
> Assignee: Vahid Hashemian
> Fix For: 0.10.1.0
>
>
> Previously we have simple consumer shell which can consume from a particular
> partition. Moving forward we will deprecate simple consumer, it would be
> useful to allow console consumer to consumer from a particular partition when
> new consumer is used.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
