[ https://issues.apache.org/jira/browse/KAFKA-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15037120#comment-15037120 ]
ASF GitHub Bot commented on KAFKA-2804: --------------------------------------- GitHub user guozhangwang reopened a pull request: https://github.com/apache/kafka/pull/579 KAFKA-2804: manage changelog topics through ZK in PartitionAssignor You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2804 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/579.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 #579 ---- commit b2aad7cb73431b923170ea3cc2dd1932222c4f10 Author: Guozhang Wang <guozhang@guozhang-macbook.local> Date: 2015-11-22T02:42:49Z comment links commit d35a1599718b831deefcb47d5d11a3e59b0c31a1 Author: wangg...@gmail.com <guozhang@guozhang-macbook.local> Date: 2015-11-22T02:51:08Z Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into K2804 commit d23db8fd8d7810dfcf7b1be2daa25cd074127eb4 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-11-23T23:23:16Z auto create topic in partition assignor and block wait on topic partition existence commit cf263fdd23eaa268c29f94cd0c1ac9455add9a0f Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-11-24T00:10:08Z fix unit tests commit dd571904bd1bb834215c51806ee1a23d6b082670 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-11-24T00:10:23Z Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into K2804 commit 3f5c1c34cc52c93758b58c7ad6f018402e06d31c Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-02T00:02:32Z Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into K2804 commit 67ef0321ae7398114c0c6bd5b71df263cfe2f4bc Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-02T00:22:11Z incoporate comments commit 0e5c7c3be8db56366895f833a0092ca177fdbda5 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-02T01:37:53Z refactor PartitionGrouper commit f76ee8b94da66104b21534cf1c75c9314d995acc Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-03T00:58:07Z add Job-Id into StreamingConfig commit 0aa06ed3e992f4dd7ea7aa72707a8f53f5b52d67 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-03T00:58:15Z Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into K2804 commit 1c9827a62dcdc8206bd1309b6bc474c68bf56952 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-03T02:31:58Z some minor fixes ---- > Create / Update changelog topics upon state store initialization > ---------------------------------------------------------------- > > Key: KAFKA-2804 > URL: https://issues.apache.org/jira/browse/KAFKA-2804 > Project: Kafka > Issue Type: Sub-task > Reporter: Guozhang Wang > Assignee: Guozhang Wang > > When state store instances that are logging-backed are initialized, we need > to check if the corresponding change log topics have been created with the > right number of partitions: > 1) If not exist, create topic > 2) If expected #.partitions < actual #.partitions, delete and re-create topic. > 3) If expected #.partitions > actual #.partitions, add partitions. -- This message was sent by Atlassian JIRA (v6.3.4#6332)