{"push_id":830590005,"size":5,"distinct_size":5,"ref":"refs/heads/trunk","head":"78a2e2f8f39b24774e5edc8cf0c1093889db2fdf","before":"aa66b42daca0791840da3c77d47c96cf98f19ef2","commits":[{"sha":"c553249b4e6d7d385821061f9742f15f90e94def","author":{"email":"9972a9c98f4ad2f4c07879e61ff8ef543017832b@gmail.com","name":"Randall Hauch"},"message":"KAFKA-2594: Add InMemoryLRUCacheStore as a preliminary method for bounding in-memory stores\n\nAdded a new `KeyValueStore` implementation called `InMemoryLRUCacheStore` that keeps a maximum number of entries in-memory, and as the size exceeds the capacity the least-recently used entry is removed from the store and the backing topic. Also added unit tests for this new store and the existing `InMemoryKeyValueStore` and `RocksDBKeyValueStore` implementations. A new `KeyValueStoreTestDriver` class simplifies all of the other tests, and can be used by other libraries to help test their own custom implementations.\n\nThis PR depends upon [KAFKA-2593](https://issues.apache.org/jira/browse/KAFKA-2593) and its PR at https://github.com/apache/kafka/pull/255. Once that PR is merged, I can rebase this PR if desired.\n\nTwo issues were uncovered when creating these new unit tests, and both are also addressed as separate (small) commits in this PR:\n* The `RocksDBKeyValueStore` initialization was not creating the file system directory if missing.\n* `MeteredKeyValueStore` was casting to `ProcessorContextImpl` to access the `RecordCollector`, which prevent using `MeteredKeyValueStore` implementations in tests where something other than `ProcessorContextImpl` was used. The fix was to introduce a `RecordCollector.Supplier` interface to define this `recordCollector()` method, and change `ProcessorContextImpl` and `MockProcessorContext` to both implement this interface. Now, `MeteredKeyValueStore` can cast to the new interface to access the record collector rather than to a single concrete implementation, making it possible to use any and all current stores inside unit tests.\n\nAuthor: Randall Hauch <rhauch@gmail.com>\n\nReviewers: Edward Ribeiro, Guozhang Wang\n\nCloses #256 from rhauch/kafka-2594","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-kafka/commits/c553249b4e6d7d385821061f9742f15f90e94def"},{"sha":"ef65d0a360ed65180ddd84d17679f24671c66e14","author":{"email":"9298de55fd47acbdd6df180ff16391dfe9d87e1e@gmail.com","name":"Liquan Pei"},"message":"KAFKA-2484: Add schema projection utilities\n\nThis PR adds schema projection utilities to copycat.\n\nAuthor: Liquan Pei <liquanpei@gmail.com>\n\nReviewers: Ewen Cheslack-Postava\n\nCloses #307 from Ishiihara/schema-projection","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-kafka/commits/ef65d0a360ed65180ddd84d17679f24671c66e14"},{"sha":"e2e5c891428e5f1288b6f4674983d924f8bdb779","author":{"email":"fae442ba222671b2ebdf7511c9ca77079c43031b@gmail.com","name":"Guozhang Wang"},"message":"KAFKA-2515: Handle oversized messages properly in new consumer\n\nAuthor: Guozhang Wang <wangguoz@gmail.com>\n\nReviewers: Dong Lin, Jun Rao\n\nCloses #318 from guozhangwang/K2515","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-kafka/commits/e2e5c891428e5f1288b6f4674983d924f8bdb779"},{"sha":"636e14a99191eeededfb933aacfe2459c7c7bb6f","author":{"email":"8fa565e409f8c7ed863709e9ebd2403d66c87d8d@linkedin.com","name":"Onur Karaman"},"message":"KAFKA-2397: add leave group request to force coordinator trigger rebalance\n\nLet's say every consumer in a group has session timeout s. Currently, if a consumer leaves the group, the worst case time to stabilize the group is 2s (s to detect the consumer failure + s for the rebalance window). If a consumer instead can declare they are leaving the group, the worst case time to stabilize the group would just be the s associated with the rebalance window.\n\nThis is a low priority optimization!\n\nAuthor: Onur Karaman <okaraman@linkedin.com>\n\nReviewers: Jason Gustafson, Guozhang Wang\n\nCloses #103 from onurkaraman/leave-group","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-kafka/commits/636e14a99191eeededfb933aacfe2459c7c7bb6f"},{"sha":"78a2e2f8f39b24774e5edc8cf0c1093889db2fdf","author":{"email":"c331eca460d53d14caa597b8b6704826efb5a0af@gmail.com","name":"Gwen Shapira"},"message":"KAFKA-2665: Add images to code github\n\n…art of the code github\n\nAuthor: Gwen Shapira <cshapi@gmail.com>\n\nReviewers: Guozhang Wang\n\nCloses #325 from gwenshap/KAFKA-2665","distinct":true,"url":"https://api.github.com/repos/ueshin/apache-kafka/commits/78a2e2f8f39b24774e5edc8cf0c1093889db2fdf"}]}