[jira] [Updated] (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:all-tabpanel ] Ismael Juma updated KAFKA-3486: --- Fix Version/s: (was: 0.10.1.0) > 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)
[jira] [Updated] (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:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3486: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch Available) Issue resolved by pull request 1169 [https://github.com/apache/kafka/pull/1169] > 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.1.0, 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)
[jira] [Updated] (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:all-tabpanel ] Jason Gustafson updated KAFKA-3486: --- Status: Patch Available (was: In Progress) > 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.1, 0.9.0.0 >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)
[jira] [Updated] (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:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3486: - Fix Version/s: 0.10.0.0 > 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)
