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.
---
