-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30775/
-----------------------------------------------------------
(Updated Feb. 9, 2015, 12:27 p.m.)
Review request for kafka.
Bugs: KAFKA-1933
https://issues.apache.org/jira/browse/KAFKA-1933
Repository: kafka
Description (updated)
-------
This patch adds finer locking when appending to log. It breaks
global append lock into 2 sequential and 1 parallel phase.
Basic idea is to allow every thread to "reserve" offsets in non
overlapping ranges, then do compression in parallel and then
"commit" write to log in the same order offsets where reserved.
Fix offset range calculation
Forgot to commit modified ByteBufferMessageSet
Diffs (updated)
-----
core/src/main/scala/kafka/log/Log.scala
ec192155bec7b643025f8044b0b6565c7b9977d1
core/src/main/scala/kafka/message/ByteBufferMessageSet.scala
788c7864bc881b935975ab4a4e877b690e65f1f1
Diff: https://reviews.apache.org/r/30775/diff/
Testing
-------
Thanks,
Maxim Ivanov
