GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3713
MINOR: simplify state transition for Kafka Streams and stream threads You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KMinor-set-state Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3713.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 #3713 ---- commit 4da235927f9eebf2442533b44bf017454d372747 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-14T17:23:53Z perform state restoration in poll loop commit a7d6f54079ce61ec75bebbae74a2fd55701e9d53 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-16T14:18:25Z move commitAll out of StreamThread commit b35f1c7688a88ddadbf8a3e94e6c6132a4b827de Author: Damian Guy <damian....@gmail.com> Date: 2017-08-16T14:29:29Z add test for AssignedTasks#commit commit 4e2bf7e0829db11d34e0e8d2df27e21813e3ddcd Author: Damian Guy <damian....@gmail.com> Date: 2017-08-16T16:31:08Z move more task oriented code out of stream thread commit e9dae9f386a6b2c415cd2ab16cb012a8884ef320 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-17T11:09:07Z address some of guozhang's comments commit 3dbed27e661562e1af78941903f3f443ff1785a2 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-17T13:44:42Z move all metric calculations back to StreamThread commit cd3c8a6876cd535da7e33758351094213860952a Author: Damian Guy <damian....@gmail.com> Date: 2017-08-17T13:56:37Z move printing of active tasks into TaskManager commit 42785e92cafb792e01cfb91673bb8011fbff4224 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-18T08:44:24Z address comments commit 61f984d625562407b1034e284a017c26d4407963 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-18T09:19:57Z add state restore integration test commit 34142cf5afbb0bc842f9cd870cb5494e4011d48f Author: Damian Guy <damian....@gmail.com> Date: 2017-08-18T13:22:35Z fix checkstyle commit ec177b0c4464830fd9838214852887849aa24b2e Author: Damian Guy <damian....@gmail.com> Date: 2017-08-18T08:10:50Z Add MeteredWindowStore and refactor store hierarchy such that Metered is always the outer store. commit 72a510c2e56489d8a843110b9371210edadbdd89 Author: Damian Guy <damian....@gmail.com> Date: 2017-08-18T16:58:40Z address comments commit 247f9ab5167bf751be03621facdcefdccf394eca Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-19T17:38:55Z Merge branch 'kafka-5689' of https://github.com/dguy/kafka into KMinor-set-state commit a1858243b9e12085be98f95254bc727fe4b85a8f Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-19T17:44:25Z collapse setState functions commit 6d32a9f7300dd26a2f6cf484e53eabaeb047b5a7 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-21T05:18:47Z cherry-pick state diagrams into trunk commit f4c6fa81701f8a6714b9e0f604afa30cc5808b0b Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-21T17:22:45Z minor fix commit d488b9c35121d7b321937c2e5d9831491b2eb8a2 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-22T18:52:12Z rebase from trunk commit 1570586342afe62a4891ee319e8d4b5b22919bfb Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-22T19:30:32Z minor fix on unit tests commit a5703325d9b711eedf814d0c84c45d6fc6c82781 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-22T20:04:01Z minor fix commit fb5461fd16aa8ca4ca11689ea9f3d03cdc3d8479 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-08-22T20:25:58Z add log4j entries ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---