GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3082
KAFKA-5231: Protect txn metadata map with read-write lock You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K5231-read-write-lock Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3082.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 #3082 ---- commit 6b5c6cf6042c61e785e9f005ea0b85ff8e5246c1 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-16T06:12:12Z bump up producer epoch commit b7884d106b8b8c10187b8748f5120728464acfc9 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-17T00:07:11Z Jason's comments commit 8f78d601beb52c90507c1307a5073e8100e98631 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-17T19:31:07Z Jun's comments commit 7c7f4da31191fce9935eecc65b6e3273bae520d1 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-17T19:52:50Z bump up limit for class fanout to 40 for Sender class commit c3aef033207f5f7da5ccc84c5dd6f71165d94f62 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-17T20:36:05Z Jun's comments round two commit ccf8fdc51c7aa066bf2f8098f0906ebf9f937a2d Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-17T23:44:48Z rebased from trunk commit 52ef07b060f59f7e0fe342faa5c040448ed1b2be Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-17T20:19:20Z change the state lock to read-write lock commit dd11d5d457ba09ed5a2a1a0d2d35712a0420b722 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-17T23:29:22Z grab the read lock until append to local is done commit 16c1791236d8bcf851fad93ef1b7a61170f62aa5 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-05-18T01:04:18Z put the validation and return of metadata under the same lock ---- --- 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. ---