{"push_id":1093598974,"size":63,"distinct_size":63,"ref":"refs/heads/trunk","head":"a472c723e69900d2b40bddd1a715da74901a1cc4","before":"02e24cdd6071afc3af165afb9514254ad4a9e6d5","commits":[{"sha":"065ddf90195e09689512b55d0718a5ebdb3d42ad","author":{"email":"4cf7ebbe638391c4d27a10cf751b99bdbd1a1880@gmail.com","name":"Grant Henke"},"message":"KAFKA-3549: Close consumers instantiated in consumer tests\n\nAuthor: Grant Henke <granthenke@gmail.com>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1217 from granthenke/close-consumers","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/065ddf90195e09689512b55d0718a5ebdb3d42ad"},{"sha":"5236bf60debbb0c08010315a92dd3fbfa482e871","author":{"email":"9298de55fd47acbdd6df180ff16391dfe9d87e1e@gmail.com","name":"Liquan Pei"},"message":"KAFKA-3526: Return string instead of object in ConfigKeyInfo and ConfigValueInfo\n\nAuthor: Liquan Pei <liquanpei@gmail.com>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1200 from Ishiihara/config-string","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/5236bf60debbb0c08010315a92dd3fbfa482e871"},{"sha":"b1691cf49e9de850ac8a2675c487af9fb60bfdaa","author":{"email":"5c404be01b63927a28df603569da1321e84406a6@gmail.com","name":"Bill Bejeck"},"message":"KAFKA-3430: Allow users to set key in KTable.toStream and in KStream.\n\n… With KStream the method selectKey was added to enable getting a key from values before perfoming aggregation-by-key operations on original streams that have null keys.\n\nAuthor: bbejeck <bbejeck@gmail.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1222 from bbejeck/KAFKA-3430_allow_users_to_set_key_KTable_toStream","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/b1691cf49e9de850ac8a2675c487af9fb60bfdaa"},{"sha":"89c67727c2793bf56b0b005a7d758beebedb5aed","author":{"email":"68c46a606457643eab92053c1c05574abb26f861@confluent.io","name":"Jason Gustafson"},"message":"KAFKA-3506: Kafka Connect restart APIs\n\nAuthor: Jason Gustafson <jason@confluent.io>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1189 from hachikuji/KAFKA-3506","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/89c67727c2793bf56b0b005a7d758beebedb5aed"},{"sha":"03817d5a26722c6e95647f6219abf2802b187c8d","author":{"email":"68c46a606457643eab92053c1c05574abb26f861@confluent.io","name":"Jason Gustafson"},"message":"KAFKA-3529: Fix transient failure in testCommitAsync\n\nAuthor: Jason Gustafson <jason@confluent.io>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1234 from hachikuji/KAFKA-3529","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/03817d5a26722c6e95647f6219abf2802b187c8d"},{"sha":"a81ad2582ee0e533d335fe0dc5c5cc885dbf645d","author":{"email":"4cf7ebbe638391c4d27a10cf751b99bdbd1a1880@gmail.com","name":"Grant Henke"},"message":"KAFKA-3563: Maintain MessageAndMetadata constructor compatibility\n\nAuthor: Grant Henke <granthenke@gmail.com>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>, Ashish Singh <asingh@cloudera.com>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1226 from granthenke/message_constructor","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/a81ad2582ee0e533d335fe0dc5c5cc885dbf645d"},{"sha":"a5f1158c317e22a79c4186d1acb04fb25ce6e56a","author":{"email":"0794a5c7e497910d682bf2c54c66cc30760c0221@juma.me.uk","name":"Ismael Juma"},"message":"KAFKA-3558; Add compression_type parameter to benchmarks in benchmark_test.py\n\n* Use a fixed `Random` seed in `EndToEndLatency.scala` for determinism\n* Add `compression_type` to and remove `consumer_fetch_max_wait` from `end_to_end_latency.py`. The latter was never used.\n* Tweak logging of `end_to_end_latency.py` to be similar to `consumer_performance.py`.\n* Add `compression_type` to `benchmark_test.py` methods and add `snappy` to `matrix` annotation\n* Use randomly generated bytes from a restricted range for `ProducerPerformance` payload. This is a simple fix for now. It can be improved in the PR for KAFKA-3554.\n\nAuthor: Ismael Juma <ismael@juma.me.uk>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1225 from ijuma/kafka-3558-add-compression_type-benchmark_test.py","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/a5f1158c317e22a79c4186d1acb04fb25ce6e56a"},{"sha":"f89f5fb907711e4696bee8a8d7bb53c6941ed693","author":{"email":"9298de55fd47acbdd6df180ff16391dfe9d87e1e@gmail.com","name":"Liquan Pei"},"message":"KAFKA-3582; Remove references to Copcyat from Kafka Connect property files\n\njunrao\n\nAuthor: Liquan Pei <liquanpei@gmail.com>\n\nReviewers: Jun Rao <junrao@gmail.com>\n\nCloses #1236 from Ishiihara/minor-fix","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/f89f5fb907711e4696bee8a8d7bb53c6941ed693"},{"sha":"501fa37222ee7bb6c1883441af05fa883c51d93b","author":{"email":"9298de55fd47acbdd6df180ff16391dfe9d87e1e@gmail.com","name":"Liquan Pei"},"message":"KAFKA-3421: Update docs with new connector features\n\newencp gwenshap Docs. I also tried to clean up some typos. However, it seems that the we don't have two words without space in between in the source yet they showed up as no space in between in the generated doc.\n\nAuthor: Liquan Pei <liquanpei@gmail.com>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1227 from Ishiihara/config-doc","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/501fa37222ee7bb6c1883441af05fa883c51d93b"},{"sha":"0bf61039c858af17260878d4815dbe7fb1645f90","author":{"email":"ae70b74c7537d7c49c1bc7b3ab4331968a042d1a@us.ibm.com","name":"Ishita Mandhan"},"message":"MINOR: Fix typos in code comments\n\nThis patch fixes all occurances of two consecutive 'the's in the code comments.\n\nAuthor: Ishita Mandhan (imandhaus.ibm.com)\n\nAuthor: Ishita Mandhan <imandha@us.ibm.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1240 from imandhan/typofixes","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/0bf61039c858af17260878d4815dbe7fb1645f90"},{"sha":"280efe7f789d21f0c45657e14830451c1c8fc2b4","author":{"email":"b1c1d8736f20db3fb6c1c66bb1455ed43909f0d8@ewencp.org","name":"Ewen Cheslack-Postava"},"message":"MINOR: Remove RollingBounceTest since its functionality is covered by the ReplicationTest system test\n\nRollingBounceTest is a system test that cannot be run reliably in unit tests and ReplicationTest is a superset of the\nfunctionality: in addition to verifying that bouncing leaders eventually results in a new leader, ReplicationTest also\nvalidates that data continues to be produced and consumed.\n\nAuthor: Ewen Cheslack-Postava <me@ewencp.org>\n\nReviewers: Gwen Shapira\n\nCloses #1242 from ewencp/minor-remove-rolling-bounce-integration-test","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/280efe7f789d21f0c45657e14830451c1c8fc2b4"},{"sha":"c9485b78a6e43747daf1314ae9532839fb7bc810","author":{"email":"68c46a606457643eab92053c1c05574abb26f861@confluent.io","name":"Jason Gustafson"},"message":"KAFKA-2370: kafka connect pause/resume API\n\nAuthor: Jason Gustafson <jason@confluent.io>\n\nReviewers: Liquan Pei <liquanpei@gmail.com>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1087 from hachikuji/KAFKA-2370","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/c9485b78a6e43747daf1314ae9532839fb7bc810"},{"sha":"8a863ecee7e5dcdaf66a55b91040a7893ffdbf66","author":{"email":"68c46a606457643eab92053c1c05574abb26f861@confluent.io","name":"Jason Gustafson"},"message":"KAFKA-3117: handle metadata updates during consumer rebalance\n\nAuthor: Jason Gustafson <jason@confluent.io>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1247 from hachikuji/KAFKA-3117","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/8a863ecee7e5dcdaf66a55b91040a7893ffdbf66"},{"sha":"f213625fc55dd0eb9087ba6482ce67fcb737172d","author":{"email":"9298de55fd47acbdd6df180ff16391dfe9d87e1e@gmail.com","name":"Liquan Pei"},"message":"MINOR: Fix comment in DistributedHerder\n\newencp\n\nAuthor: Liquan Pei <liquanpei@gmail.com>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1243 from Ishiihara/docs","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/f213625fc55dd0eb9087ba6482ce67fcb737172d"},{"sha":"9d71489ff0e62fd1897c7a6f54671673db7b37b8","author":{"email":"2e743c5cf650e12d7db950775eab7636545b5b8c@googlemail.com","name":"Rajini Sivaram"},"message":"KAFKA-3548: Use root locale for case transformation of constant strings\n\nFor enums and other constant strings, use locale independent case conversions to enable comparisons to work regardless of the default locale.\n\nAuthor: Rajini Sivaram <rajinisivaram@googlemail.com>\n\nReviewers: Manikumar Reddy, Ismael Juma, Guozhang Wang, Gwen Shapira\n\nCloses #1220 from rajinisivaram/KAFKA-3548","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/9d71489ff0e62fd1897c7a6f54671673db7b37b8"},{"sha":"5c547475d86aa336f8b3c4bb69faff39759d5df5","author":{"email":"e388d34fd3c0456122779e95f262c0d70198a168@confluent.io","name":"Matthias J. Sax"},"message":"KAFKA-3337: Extract selector as a separate groupBy operator for KTable aggregations\n\nAuthor: Matthias J. Sax <matthias@confluent.io>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1231 from mjsax/kafka-3337-extact-key-selector-from-agg","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/5c547475d86aa336f8b3c4bb69faff39759d5df5"},{"sha":"74e6dc842559d344241c70cb6607a69291e3a20d","author":{"email":"fae442ba222671b2ebdf7511c9ca77079c43031b@gmail.com","name":"Guozhang Wang"},"message":"KAFKA-3589: set inner serializer for ChangedSerde upon initialization\n\nAuthor: Guozhang Wang <wangguoz@gmail.com>\n\nReviewers: Eno Thereska <eno.thereska@gmail.com>, Ismael Juma <ismael@juma.me.uk>\n\nCloses #1246 from guozhangwang/K3589","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/74e6dc842559d344241c70cb6607a69291e3a20d"},{"sha":"32740044972ad3bfc9539b5d76128dceddedc2ba","author":{"email":"5c5b03b4d6e1a3a45d39ad15b70eab568fe0a48b@gmail.com","name":"Manikumar reddy O"},"message":"KAFKA-3594; After calling MemoryRecords.close() method, hasRoomFor() method should return false\n\nThis exception is occurring when producer is trying to append a record to a Re-enqueued record batch in the accumulator. We should not allow to add a record to Re-enqueued record batch. This is due a bug in MemoryRecords.java/hasRoomFor() method. After calling MemoryRecords.close() method, hasRoomFor() method should return false.\n\nAuthor: Manikumar reddy O <manikumar.reddy@gmail.com>\n\nReviewers: Ismael Juma, Grant Henke, Guozhang Wang\n\nCloses #1249 from omkreddy/KAFKA-3594","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/32740044972ad3bfc9539b5d76128dceddedc2ba"},{"sha":"c7f9bd2a68ea7bb604c4dcf2a2f0b030fc019ca7","author":{"email":"9298de55fd47acbdd6df180ff16391dfe9d87e1e@gmail.com","name":"Liquan Pei"},"message":"KAFKA-3606: Traverse CLASSPATH during herder start\n\newencp Can you take a quick look?\n\nAuthor: Liquan Pei <liquanpei@gmail.com>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1252 from Ishiihara/pre-list-connectors","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/c7f9bd2a68ea7bb604c4dcf2a2f0b030fc019ca7"},{"sha":"bc5051565171cf65b4ed7dd4d9ef269d66a1021a","author":{"email":"b1c1d8736f20db3fb6c1c66bb1455ed43909f0d8@ewencp.org","name":"Ewen Cheslack-Postava"},"message":"KAFKA-3605: Return error if connector config includes mismatching connector name.\n\nAuthor: Ewen Cheslack-Postava <me@ewencp.org>\n\nReviewers: Jason Gustafson\n\nCloses #1253 from ewencp/kafka-3605-connector-name-mismatch","distinct":true,"url":"https://api.github.com/repos/rmp91/kafka/commits/bc5051565171cf65b4ed7dd4d9ef269d66a1021a"}]}