{"push_id":830411108,"size":8,"distinct_size":8,"ref":"refs/heads/KAFKA-2640","head":"90bb79525c919c3d2c0d65e02cdd071a32c38a5d","before":"83eaec6a9615ff21b8aac52d8faad688363cd611","commits":[{"sha":"c50d39ea82e282d08163ebe7f0e398de2dc8c128","author":{"email":"d8dea9667c16d33d8b6afaedc830cee5640bcc4c@confluent.io","name":"Yasuhiro Matsuda"},"message":"KAFKA-2654: optimize unnecessary poll(0) away in StreamTask\n\nguozhangwang\nThis change aims to remove unnecessary ```consumer.poll(0)``` calls.\n* ```once``` after some partition is resumed\n* whenever the size of the top queue in any task is below ```BUFFERED_RECORDS_PER_PARTITION_CONFIG```\n\nAuthor: Yasuhiro Matsuda <yasuhiro@confluent.io>\n\nReviewers: Guozhang Wang\n\nCloses #315 from ymatsuda/less_poll_zero","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/c50d39ea82e282d08163ebe7f0e398de2dc8c128"},{"sha":"a4dbf9010754183965772066a9cd2c5c4a49d44a","author":{"email":"5c5b03b4d6e1a3a45d39ad15b70eab568fe0a48b@gmail.com","name":"Manikumar reddy O"},"message":"KAFKA-2295; Support dynamically loaded classes from context class loader\n\nRebased code..\n\nAuthor: Manikumar reddy O <manikumar.reddy@gmail.com>\n\nReviewers: Guozhang Wang\n\nCloses #314 from omkreddy/KAFKA-2295","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/a4dbf9010754183965772066a9cd2c5c4a49d44a"},{"sha":"50a076d1e9929d82107b3086f664a234a1c7b9f6","author":{"email":"d8dea9667c16d33d8b6afaedc830cee5640bcc4c@confluent.io","name":"Yasuhiro Matsuda"},"message":"MINOR: set up temp directories properly in StreamTaskTest\n\nguozhangwang\nStreamTaskTest did not set up a temp directory for each test. This occasionally caused interference between tests through state directory locking.\n\nAuthor: Yasuhiro Matsuda <yasuhiro@confluent.io>\n\nReviewers: Guozhang Wang\n\nCloses #317 from ymatsuda/fix_StreamTaskTest","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/50a076d1e9929d82107b3086f664a234a1c7b9f6"},{"sha":"5338f8432f74054671e9da59ba6f97abb81a03f2","author":{"email":"46c1bfc637d888408d29d0e605297333fe43a7ee@cloudera.com","name":"Ashish Singh"},"message":"KAFKA-2487: change kafka.examples.Consumer to use the new java consumer\n\nAuthor: Ashish Singh <asingh@cloudera.com>\n\nReviewers: Guozhang Wang\n\nCloses #297 from SinghAsDev/KAFKA-2487","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/5338f8432f74054671e9da59ba6f97abb81a03f2"},{"sha":"7efa12705d91e21eec527ab49033b01ca5e3e3ce","author":{"email":"4dc76a2d2ba89cde3d53c4b495e96d1a0a52059a@linkedin.com","name":"Mayuresh Gharat"},"message":"KAFKA-2120: cleaning follow-up\n\nTrivial fix to get rid of unused statements in kafkaProducer.\n\nAuthor: Mayuresh Gharat <mgharat@mgharat-ld1.linkedin.biz>\n\nReviewers: Edward Ribeiro, Guozhang Wang\n\nCloses #320 from MayureshGharat/kafka-2120-followup","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/7efa12705d91e21eec527ab49033b01ca5e3e3ce"},{"sha":"aa66b42daca0791840da3c77d47c96cf98f19ef2","author":{"email":"736c9cc8047be4fb56e22ec0e9e4e0e88905844e@aauradka-mn1.linkedin.biz","name":"Aditya Auradkar"},"message":"KAFKA-2419 - Fix to prevent background thread from getting created when not required\n\nSee here for more discussion: https://issues.apache.org/jira/browse/KAFKA-2419\nBasically, the fix involves adding a param to Metrics to indicate if it is capable of metric cleanup or not.\n\nAuthor: Aditya Auradkar <aauradka@aauradka-mn1.linkedin.biz>\n\nReviewers: Jun Rao <junrao@gmail.com>\n\nCloses #323 from auradkar/KAFKA-2419-fix","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/aa66b42daca0791840da3c77d47c96cf98f19ef2"},{"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/fpj/kafka/commits/c553249b4e6d7d385821061f9742f15f90e94def"},{"sha":"90bb79525c919c3d2c0d65e02cdd071a32c38a5d","author":{"email":"3143f522c4835f95078812226e7dab45695d0369@apache.org","name":"Flavio Junqueira"},"message":"Merge remote-tracking branch 'upstream/trunk' into KAFKA-2640","distinct":true,"url":"https://api.github.com/repos/fpj/kafka/commits/90bb79525c919c3d2c0d65e02cdd071a32c38a5d"}]}