[ https://issues.apache.org/jira/browse/KAFKA-2336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14694558#comment-14694558 ]
Joel Koshy commented on KAFKA-2336: ----------------------------------- Sorry I should not have assigned it to myself before going on an extended leave of absence. Thanks [~granthenke] [~gwenshap] [~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)