-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/32778/
-----------------------------------------------------------
Review request for kafka.
Bugs: KAFKA-2087
https://issues.apache.org/jira/browse/KAFKA-2087
Repository: kafka
Description
-------
PATCH for KAFKA-1546
PATCH for KAFKA-1546
Brief summary of changes:
- Added a lagBegin metric inside Replica to track the lag in terms of time
since the replica did not read from the LEO
- Using lag begin value in the check for ISR expand and shrink
- Removed the max lag messages config since it is no longer necessary
- Returning the initialLogEndOffset in LogReadResult corresponding to the the
LEO before actually reading from the log.
- Unit test cases to test ISR shrinkage and expansion
Updated KAFKA-1546 patch to reflect Neha and Jun's comments
Addressing Joel's comments
Addressing Jun and Guozhang's comments
Addressing Jun's comments
Cleaning up javadoc for TopicConfigManager
Diffs
-----
core/src/main/scala/kafka/cluster/Partition.scala
c4bf48a801007ebe7497077d2018d6dffe1677d4
core/src/main/scala/kafka/cluster/Replica.scala
bd13c20338ce3d73113224440e858a12814e5adb
core/src/main/scala/kafka/log/Log.scala
06b8ecc5d11a1acfbaf3c693c42bf3ce5b2cd86d
core/src/main/scala/kafka/server/FetchDataInfo.scala
26f278f9b75b1c9c83a720ca9ebd8ab812d19d39
core/src/main/scala/kafka/server/KafkaConfig.scala
422451aec5ea0442eb2e4c1ae772885b813904a9
core/src/main/scala/kafka/server/ReplicaManager.scala
44f0026e6676d8d764dd59dbcc6bb7bb727a3ba6
core/src/main/scala/kafka/server/TopicConfigManager.scala
47295d40131492aaac786273819b7bc6e22e5486
core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala
92152358c95fa9178d71bd1c079af0a0bd8f1da8
core/src/test/scala/unit/kafka/server/KafkaConfigConfigDefTest.scala
191251d1340b5e5b2d649b37af3c6c1896d07e6e
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala
92d6b2c672f74cdd526f2e98da8f7fb3696a88e3
core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
efb457334bd87e4c5b0dd2c66ae1995993cd0bc1
Diff: https://reviews.apache.org/r/32778/diff/
Testing
-------
Thanks,
Aditya Auradkar
