{"push_id":1153418746,"size":220,"distinct_size":220,"ref":"refs/heads/trunk","head":"eb6f04a8b12194b9e13e2a28d8ffdfa971516d68","before":"8c59565761a42984335294683c3501df8427ce62","commits":[{"sha":"7c27989860e7e063bfec3c679cb6bc8fd52abc84","author":{"name":"bbejeck","email":"cd735052505ca456aac5be887ebb94a0125946fe@gmail.com"},"message":"KAFKA-3338: Add print and writeAsText to KStream/KTable in Kafka Streams\n\n    Addresses comments from previous PR [#1187]\n    Changed print and writeAsText method return signature to void\n    Flush System.out on close\n    Changed IllegalStateException to TopologyBuilderException\n    Updated MockProcessorContext.topic method to return a String\n    Renamed KStreamPrinter to KeyValuePrinter\n    Updated the printing of null keys to 'null' to match ConsoleConsumer\n    Updated JavaDoc stating need to override toString\n\nAuthor: bbejeck <bbejeck@gmail.com>\n\nReviewers: Dan Norwood, Guozhang Wang\n\nCloses #1209 from bbejeck/KAFKA-3338_Adding_print/writeAsText_to_Streams_DSL","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/7c27989860e7e063bfec3c679cb6bc8fd52abc84"},{"sha":"c76b6e6d9bad2278076054f5175a2b053383388f","author":{"name":"Guozhang Wang","email":"08d6b47f1ed933bf8f63fe549a461671f3a38d3b@gmail.com"},"message":"HOTFIX: special handling first ever triggered punctuate\n\nAuthor: Guozhang Wang <wangguoz@gmail.com>\n\nReviewers: Anna Povzner <anna@confluent.io>\n\nCloses #1208 from guozhangwang/KPunctuate","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/c76b6e6d9bad2278076054f5175a2b053383388f"},{"sha":"411b04a3c933b5253f34342bf24f63a9473f9ab5","author":{"name":"Ewen Cheslack-Postava","email":"b4a5ea001e047040e8c9075b67a268293138da2c@ewencp.org"},"message":"MINOR: Make VerifiableProducer in system tests lookup security configuration dynamically instead of at construction.\n\nAuthor: Ewen Cheslack-Postava <me@ewencp.org>\n\nReviewers: Anna Povzner\n\nCloses #1207 from ewencp/minor-dynamic-security-config-verifiable-producer","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/411b04a3c933b5253f34342bf24f63a9473f9ab5"},{"sha":"1ec842a3ea9bbe414a5c59f90569fbc3348bdfb8","author":{"name":"Igor Stepanov","email":"e2f292fdc3d527d2445a1ee3547267f51d620304@keystonett.com"},"message":"MINOR: fix incorrect exception message in KafkaProducer\n\nWhile playing with client got the next exception:\n```java\njava.lang.IllegalArgumentException: Invalid partition given with record: 1 is not in the range [0...1].\n```\nIt's obviously incorrect, so I've fixed it.\n\nAuthor: Igor Stepanov <igor.stepanov@keystonett.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1210 from stepio/trunk","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/1ec842a3ea9bbe414a5c59f90569fbc3348bdfb8"},{"sha":"40fd456649b5df29d030da46865b5e7e0ca6db15","author":{"name":"Guozhang Wang","email":"08d6b47f1ed933bf8f63fe549a461671f3a38d3b@gmail.com"},"message":"KAFKA-3519: Refactor Transformer's transform / punctuate to return nullable values\n\nAuthor: Guozhang Wang <wangguoz@gmail.com>\n\nReviewers: Dan Norwood, Anna Povzner\n\nCloses #1204 from guozhangwang/KTransformR","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/40fd456649b5df29d030da46865b5e7e0ca6db15"},{"sha":"319c6e7195143c1fa4a1e5b34ad923c2b73f373d","author":{"name":"Ismael Juma","email":"e6abb59dc9dfc569a27afac0f1a05d72488c0302@juma.me.uk"},"message":"MINOR: Add missing `@Override` to `KStreamImpl.through`\n\nAuthor: Ismael Juma <ismael@juma.me.uk>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1216 from ijuma/add-missing-override-to-through","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/319c6e7195143c1fa4a1e5b34ad923c2b73f373d"},{"sha":"ba9456de2ebf1a34bdf5f6f62a701875822e1923","author":{"name":"Eno Thereska","email":"558d1204cdfaa2922fe8df88ce1f18639c19ca70@gmail.com"},"message":"KAFKA-3439; Added exceptions thrown\n\nAuthor: Eno Thereska <eno.thereska@gmail.com>\n\nReviewers: Guozhang Wang\n\nCloses #1213 from enothereska/KAFKA-3439-throws","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/ba9456de2ebf1a34bdf5f6f62a701875822e1923"},{"sha":"34a594472133c3bc6a2886cf58ded0065f26d28a","author":{"name":"Grant Henke","email":"92cb0c65dbf8ff1baaf010de530f6f36b8383062@gmail.com"},"message":"MINOR: Remove unused hadoop version\n\nAll dependencies on hadoop were removed with MiniKDC. This removes the left over version entry.\n\nAuthor: Grant Henke <granthenke@gmail.com>\n\nReviewers: Ismael Juma\n\nCloses #1214 from granthenke/remove-hadoop","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/34a594472133c3bc6a2886cf58ded0065f26d28a"},{"sha":"e79d9af3cfbb8884e00424f84f3c687114497998","author":{"name":"Dongjoon Hyun","email":"1bf3a3c57610939bd1558dffb564906c959abecb@apache.org"},"message":"KAFKA-3461: Fix typos in Kafka web documentations.\n\nThis PR fixes 8 typos in HTML files of `docs` module. I wrote explicitly here since Github sometimes does not highlight the corrections on long lines correctly.\n- docs/api.html: compatability => compatibility\n- docs/connect.html: simultaneoulsy => simultaneously\n- docs/implementation.html: LATIEST_TIME => LATEST_TIME, nPartions => nPartitions\n- docs/migration.html: Decomission => Decommission\n- docs/ops.html: stoping => stopping, ConumserGroupCommand => ConsumerGroupCommand, youre => you're\n\nAuthor: Dongjoon Hyun <dongjoon@apache.org>\n\nReviewers: Ismael Juma\n\nCloses #1138 from dongjoon-hyun/KAFKA-3461","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/e79d9af3cfbb8884e00424f84f3c687114497998"},{"sha":"667ff7ef737612773c50908d2b3cc829bb5132c7","author":{"name":"Eno Thereska","email":"558d1204cdfaa2922fe8df88ce1f18639c19ca70@gmail.com"},"message":"KAFKA-3504; Log compaction for changelog partition\n\nAuthor: Eno Thereska <eno.thereska@gmail.com>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>, Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1203 from enothereska/KAFKA-3504-logcompaction","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/667ff7ef737612773c50908d2b3cc829bb5132c7"},{"sha":"c1694833d5c095e47e5767f38c3e85bbe927a0a7","author":{"name":"Ismael Juma","email":"e6abb59dc9dfc569a27afac0f1a05d72488c0302@juma.me.uk"},"message":"KAFKA-3490; Multiple version support for ducktape performance tests\n\nAuthor: Ismael Juma <ismael@juma.me.uk>\nAuthor: Geoff Anderson <geoff@confluent.io>\n\nReviewers: Geoff Anderson <geoff@confluent.io>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #1173 from ijuma/kafka-3490-multiple-version-support-perf-tests","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/c1694833d5c095e47e5767f38c3e85bbe927a0a7"},{"sha":"f4d3d2865894f1a1ade9d92ac27931fd35d16cae","author":{"name":"Jason Gustafson","email":"158e602a35675d2a0b685478824aa5995557a235@confluent.io"},"message":"KAFKA-3470: treat commits as member heartbeats\n\nAuthor: Jason Gustafson <jason@confluent.io>\n\nReviewers: Ismael Juma <ismael@juma.me.uk>, Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1206 from hachikuji/KAFKA-3470","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/f4d3d2865894f1a1ade9d92ac27931fd35d16cae"},{"sha":"4fa456bc6e875c819e41aadadd1e37ba9bdb9cd0","author":{"name":"Ismael Juma","email":"e6abb59dc9dfc569a27afac0f1a05d72488c0302@juma.me.uk"},"message":"KAFKA-3557; Update rocksdb to 4.4.1 and patch updates to snappy and slf4j\n\n* The hope is that RocksDb 4.4.1 is more stable than 4.1.0 (occasional segfaults) and 4.2.0 (very frequent segfaults), release notes for 4.4.1: https://www.facebook.com/groups/rocksdb.dev/permalink/925995520832296/\n* slf4j 1.7.21 includes thread-safety fixes: http://www.slf4j.org/news.html\n* snappy 1.1.2.4 includes performance improvements requested by Spark, which apply to our usage: https://github.com/xerial/snappy-java/blob/master/Milestone.md\n\nI ran the stream tests several times and they passed every time while 4.2.0 segfaulted every time.\n\nAuthor: Ismael Juma <ismael@juma.me.uk>\n\nReviewers: Eno Thereska <eno.thereska@gmail.com>, Guozhang Wang <wangguoz@gmail.com>\n\nCloses #1219 from ijuma/kafka-3557-update-rocks-db-4.4.1-snappy-slf4j","distinct":true,"url":"https://api.github.com/repos/mrb/kafka/commits/4fa456bc6e875c819e41aadadd1e37ba9bdb9cd0"},{"sha":"065ddf90195e09689512b55d0718a5ebdb3d42ad","author":{"name":"Grant Henke","email":"92cb0c65dbf8ff1baaf010de530f6f36b8383062@gmail.com"},"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/mrb/kafka/commits/065ddf90195e09689512b55d0718a5ebdb3d42ad"},{"sha":"5236bf60debbb0c08010315a92dd3fbfa482e871","author":{"name":"Liquan Pei","email":"0be4f99e253552efea125125bc75fc5ef3aa0ac4@gmail.com"},"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/mrb/kafka/commits/5236bf60debbb0c08010315a92dd3fbfa482e871"},{"sha":"b1691cf49e9de850ac8a2675c487af9fb60bfdaa","author":{"name":"Bill Bejeck","email":"cd735052505ca456aac5be887ebb94a0125946fe@gmail.com"},"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/mrb/kafka/commits/b1691cf49e9de850ac8a2675c487af9fb60bfdaa"},{"sha":"89c67727c2793bf56b0b005a7d758beebedb5aed","author":{"name":"Jason Gustafson","email":"158e602a35675d2a0b685478824aa5995557a235@confluent.io"},"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/mrb/kafka/commits/89c67727c2793bf56b0b005a7d758beebedb5aed"},{"sha":"03817d5a26722c6e95647f6219abf2802b187c8d","author":{"name":"Jason Gustafson","email":"158e602a35675d2a0b685478824aa5995557a235@confluent.io"},"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/mrb/kafka/commits/03817d5a26722c6e95647f6219abf2802b187c8d"},{"sha":"a81ad2582ee0e533d335fe0dc5c5cc885dbf645d","author":{"name":"Grant Henke","email":"92cb0c65dbf8ff1baaf010de530f6f36b8383062@gmail.com"},"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/mrb/kafka/commits/a81ad2582ee0e533d335fe0dc5c5cc885dbf645d"},{"sha":"a5f1158c317e22a79c4186d1acb04fb25ce6e56a","author":{"name":"Ismael Juma","email":"e6abb59dc9dfc569a27afac0f1a05d72488c0302@juma.me.uk"},"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/mrb/kafka/commits/a5f1158c317e22a79c4186d1acb04fb25ce6e56a"}]}
{"actor":{"display_login":"mrb"}}