----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30775/ -----------------------------------------------------------
Review request for kafka. Bugs: KAFKA-1933 https://issues.apache.org/jira/browse/KAFKA-1933 Repository: kafka Description ------- 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. Diffs ----- core/src/main/scala/kafka/log/Log.scala ec192155bec7b643025f8044b0b6565c7b9977d1 Diff: https://reviews.apache.org/r/30775/diff/ Testing ------- Thanks, Maxim Ivanov