[
https://issues.apache.org/jira/browse/KAFKA-2336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2336:
--------------------------------
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
+1 and pushed to trunk.
Thanks for your contribution [~granthenke] and for the review [~becket_qin]!
> Changing offsets.topic.num.partitions after the offset topic is created
> breaks consumer group partition assignment
> -------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-2336
> URL: https://issues.apache.org/jira/browse/KAFKA-2336
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.8.2.1
> Reporter: Grant Henke
> Assignee: Grant Henke
> Fix For: 0.8.3
>
> Attachments: KAFKA-2336.patch, KAFKA-2336.patch,
> KAFKA-2336_2015-07-16_13:04:02.patch, KAFKA-2336_2015-08-11_10:37:41.patch
>
>
> Currently adjusting offsets.topic.num.partitions after the offset topic is
> created is not supported. Meaning that the number of partitions will not
> change once the topic has been created.
> However, changing the value in the configuration should not cause issues and
> instead simply be ignored. Currently this is not the case.
> When the value of offsets.topic.num.partitions is changed after the offset
> topic is created the consumer group partition assignment completely changes
> even though the number of partitions does not change.
> This is because _kafka.server.OffsetManager.partitionFor(group: String)_ uses
> the configured value and not the value of the actual topic.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
