You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/31 06:40:25 UTC
[jira] [Commented] (KAFKA-3486) Autocommit does not execute
periodically when partitions are manually assigned
[ https://issues.apache.org/jira/browse/KAFKA-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15219334#comment-15219334 ]
ASF GitHub Bot commented on KAFKA-3486:
---------------------------------------
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/1169
KAFKA-3486: fix autocommit when partitions assigned manually
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-3486
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1169.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 #1169
----
commit 62472d1d61fe4fe653d994987087a3917f21a2a2
Author: Jason Gustafson <ja...@confluent.io>
Date: 2016-03-31T04:35:37Z
KAFKA-3486: fix autocommit when partitions assigned manually
----
> Autocommit does not execute periodically when partitions are manually assigned
> ------------------------------------------------------------------------------
>
> Key: KAFKA-3486
> URL: https://issues.apache.org/jira/browse/KAFKA-3486
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.9.0.0, 0.9.0.1
> Reporter: Jason Gustafson
> Assignee: Jason Gustafson
> Priority: Critical
> Fix For: 0.10.0.0
>
>
> We have an internal periodic task to commit offsets when autocommit is enabled, but we only start it after the consumer has joined its group. When the user is using manual partition assignment through assign(), the autocommit task never gets started, so the only time offsets would be committed is in close().
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)