[
https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16346938#comment-16346938
]
ASF GitHub Bot commented on KAFKA-6312:
---------------------------------------
tankhiwale closed pull request #123: KAFKA-6312: Update website documentation
for --reset-offsets option, …
URL: https://github.com/apache/kafka-site/pull/123
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/10/ops.html b/10/ops.html
index 92077df..59d7e17 100644
--- a/10/ops.html
+++ b/10/ops.html
@@ -183,6 +183,15 @@ <h4><a id="basic_ops_consumer_group"
href="#basic_ops_consumer_group">Managing C
test-foo 0 1 3 2
consumer-1-a5d61779-4d04-4c50-a6d6-fb35d942642d /127.0.0.1
consumer-1
</pre>
+ To reset offsets of a consumer group to latest offset, first make sure the
instances are inactive, then:
+
+ <pre class="brush: bash;">
+ > bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092
--reset-offsets --group consumergroup1 --topic topic1 --to-latest
+
+ TOPIC PARTITION NEW-OFFSET
+ topic1 0 0
+ </pre>
+
If you are using the old high-level consumer and storing the group metadata
in ZooKeeper (i.e. <code>offsets.storage=zookeeper</code>), pass
<code>--zookeeper</code> instead of <code>bootstrap-server</code>:
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> Add documentation about kafka-consumer-groups.sh's ability to set/change
> offsets
> --------------------------------------------------------------------------------
>
> Key: KAFKA-6312
> URL: https://issues.apache.org/jira/browse/KAFKA-6312
> Project: Kafka
> Issue Type: Improvement
> Components: documentation
> Reporter: James Cheng
> Assignee: Mayank Tankhiwale
> Priority: Major
> Labels: newbie
>
> KIP-122 added the ability for kafka-consumer-groups.sh to reset/change
> consumer offsets, at a fine grained level.
> There is documentation on it in the kafka-consumer-groups.sh usage text.
> There is no such documentation on the kafka.apache.org website. We should add
> some documentation to the website, so that users can read about the
> functionality without having the tools installed.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
