{"push_id":2316721940,"size":146,"distinct_size":146,"ref":"refs/heads/nickt.reassign-partitions-validation","head":"b7b210efc04a4ff2cdb19f17e72c070866a7c0fd","before":"2954d4c465d19436f216ad75ae4b984a3becd1cf","commits":[{"sha":"b887eeb7215351e7509993f8609846115962e594","author":{"name":"Ivan Babrou","email":"deed787dcb9bc6175653afd381fd72deac84c8b6@gmail.com"},"message":"KAFKA-4711: fix docs on unclean.leader.election.enable default","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/b887eeb7215351e7509993f8609846115962e594"},{"sha":"bfb272c5cdb227040d862f0ab7337df68f787764","author":{"name":"Ewen Cheslack-Postava","email":"b4a5ea001e047040e8c9075b67a268293138da2c@ewencp.org"},"message":"KAFKA-6311: Expose Kafka cluster ID in Connect REST API (KIP-238) (#4314)\n\nReviewers: Konstantine Karantasis <konstantine@confluent.io>, Randall Hauch <rhauch@gmail.com>, Jason Gustafson <jason@confluent.io>","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/bfb272c5cdb227040d862f0ab7337df68f787764"},{"sha":"ecf0ab42c1591be2a3784b6e107567ad883e0330","author":{"name":"Study","email":"1e50012dc1d8e2626b410d96800ed7fe8d57259a@gmail.com"},"message":"KAFKA-4335: Add batch.size to FileStreamSource connector to prevent OOM\n\nWhen the source file of `FileStreamSource` is a large file, `FileStreamSourceTask.poll()` will result in OOM. This pull request added `batch.size` parameter which can restrict the poll size.\n\n*More detailed description of your change,\nif necessary. The PR title and PR message become\nthe squashed commit message, so use a separate\ncomment to ping reviewers.*\n\n*Summary of testing strategy (including rationale)\nfor the feature or bug fix. Unit and/or integration\ntests are expected for any behaviour change and\nsystem tests should be considered for larger changes.*\n\nAuthor: Study <ph.study@gmail.com>\n\nReviewers: Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #4356 from phstudy/KAFKA-4335","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/ecf0ab42c1591be2a3784b6e107567ad883e0330"},{"sha":"3b03c9d3484f59c7a5fccb282ff77ad45734c10c","author":{"name":"Arjun Satish","email":"e295f43f869eb4e47bb424bbbd86edcfa874ba78@confluent.io"},"message":"KAFKA-6252; Close the metric group to clean up any existing metrics\n\nWe are closing the metricGroups created in a Worker, Source task and Sink task before populating them with new metrics. This helps in cases where an Exception is thrown when previously created groups were not cleaned up correctly.\n\nSigned-off-by: Arjun Satish <arjunconfluent.io>\n\nAuthor: Arjun Satish <arjun@confluent.io>\n\nReviewers: Randall Hauch <rhauch@gmail.com>, Konstantine Karantasis <konstantine@confluent.io>, Ewen Cheslack-Postava <ewen@confluent.io>\n\nCloses #4397 from wicknicks/KAFKA-6252","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/3b03c9d3484f59c7a5fccb282ff77ad45734c10c"},{"sha":"e1c5d0c119b38a9ddb2b09b6309a3817d86d8e14","author":{"name":"Matt Farmer","email":"31e7b35f7f9f5d76c1e2ef239c79b97264b2f6d0@frmr.me"},"message":"MINOR: Add documentation for KAFKA-6086 (ProductionExceptionHandler) (#4395)\n\n* Update streams documentation to describe production exception handler\r\n\r\n* Add a mention of the ProductionExceptionHandler in the upgrade guide","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/e1c5d0c119b38a9ddb2b09b6309a3817d86d8e14"},{"sha":"a7e49027b2b95bc8656ee9f419306c559ad1cb5c","author":{"name":"Romain Hardouin","email":"cd9cf190f81922cdb5b61e21f06cf471d75b06f1@yahoo.fr"},"message":"MINOR: Catch JsonMappingException subclass (#3821)\n\nHandle InvalidTypeIdException as NOT_IMPLEMENTED and add unit tests for all exceptions.\n\nReviewers: Colin P. Mccabe <cmccabe@confluent.io>, Rajini Sivaram <rajinisivaram@googlemail.com>","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/a7e49027b2b95bc8656ee9f419306c559ad1cb5c"},{"sha":"d63f94797cd3a283b2d374d24a23ac54f92c7b27","author":{"name":"Joel Hamill","email":"7d66b732d66e1abb268c86a93eb8de00c6abc11a@users.noreply.github.com"},"message":"MINOR: fix image 404s in streams doc\n\nFixes image 404s in streams docs (e.g. https://kafka.apache.org/documentation/streams/developer-guide/interactive-queries.html).\n\nRelated https://github.com/apache/kafka-site/pull/114\n\nAuthor: Joel Hamill <joel-hamill@users.noreply.github.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #4389 from joel-hamill/fix-404-streams","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/d63f94797cd3a283b2d374d24a23ac54f92c7b27"},{"sha":"e1c407973f5c4a7af6b80c1a9be92ab1635de665","author":{"name":"Ewen Cheslack-Postava","email":"b4a5ea001e047040e8c9075b67a268293138da2c@ewencp.org"},"message":"MINOR: Improve exception messages when state stores cannot be accessed. (#4383)","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/e1c407973f5c4a7af6b80c1a9be92ab1635de665"},{"sha":"26270983cd2318b00a6e20ff1d354008307fe082","author":{"name":"Joel Hamill","email":"7d66b732d66e1abb268c86a93eb8de00c6abc11a@users.noreply.github.com"},"message":"MINOR: Fix menu ordering in streams docs\n\nhttps://issues.apache.org/jira/browse/KAFKA-6419\n\nRelated: https://github.com/apache/kafka-site/pull/115\n\nAuthor: Joel Hamill <joel-hamill@users.noreply.github.com>\n\nReviewers: Guozhang Wang <wangguoz@gmail.com>\n\nCloses #4390 from joel-hamill/fix-streams-menu-order","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/26270983cd2318b00a6e20ff1d354008307fe082"},{"sha":"697a4af35a3672dd339c3a6a34d5ab27e31e0fbd","author":{"name":"Filipe Agapito","email":"05bc52f6d88bcf24b18b96015f413fc22a339352@gmail.com"},"message":"KAFKA-6363: Use MockAdminClient for any unit tests that depend on AdminClient (#4371)\n\n* Implement MockAdminClient.deleteTopics\r\n* Use MockAdminClient instead of MockKafkaAdminClientEnv in StreamsResetterTest\r\n* Rename MockKafkaAdminClientEnv to AdminClientUnitTestEnv\r\n* Use MockAdminClient instead of MockKafkaAdminClientEnv in TopicAdminTest\r\n* Rename KafkaAdminClient to AdminClientUnitTestEnv in KafkaAdminClientTest.java\r\n* Migrate StreamThreadTest to MockAdminClient\r\n* Fix style errors\r\n* Address review comments\r\n* Fix MockAdminClient call\r\n\r\nReviewers: Matthias J. Sax <matthias@confluent.io>, Konstantine Karantasis <konstantine@confluent.io>, Guozhang Wang <wangguoz@gmail.com>","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/697a4af35a3672dd339c3a6a34d5ab27e31e0fbd"},{"sha":"2900af6b33c8d6a12459dcdd0e1fb4b49676c2ff","author":{"name":"Jorge Quilcate Otoya","email":"e37fbd2bbd4ff12e92289820dcbf8f65bb60c387@gmail.com"},"message":"Updating docs for streams app reset tool (#4401)\n\nReviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com>","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/2900af6b33c8d6a12459dcdd0e1fb4b49676c2ff"},{"sha":"f2e9725ec9d88f37e0048dbd50e23f96c1e51e0e","author":{"name":"lisa2lisa","email":"bc42182baf5073ea75c1255b69b76a1a6a5c8967@users.noreply.github.com"},"message":"KAFKA-6422 Mirror maker will throw null pointer exception when the message value is null (#4387)\n\nReviewers: Manikumar Reddy <manikumar.reddy@gmail.com>, James Cheng <jylcheng@yahoo.com>, Jason Gustafson <jason@confluent.io>","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/f2e9725ec9d88f37e0048dbd50e23f96c1e51e0e"},{"sha":"6396d01957ea355c21d658c3614190458229fa5b","author":{"name":"Rajini Sivaram","email":"845649f006983e12b0a3bbde4be398021e14793f@googlemail.com"},"message":"KAFKA-6096: Add multi-threaded tests for group coordinator, txn manager (#4122)\n\nReviewers: Jason Gustafson <jason@confluent.io>","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/6396d01957ea355c21d658c3614190458229fa5b"},{"sha":"abf4c547017304c9b1e743723bdcb0b8a4df1ad0","author":{"name":"Chris Egerton","email":"3c05ab377afbb056c6d603ac8db29caf8a88479d@confluent.io"},"message":"KAFKA-4247; Prevent CLASSPATH from beginning with a single colon\n\nDifferent fix for problem addressed by https://github.com/apache/kafka/pull/1953. Should prevent the CLASSPATH environment variable from being prefixed by a single colon before the JVM is invoked in the run-class script, which will then prevent the current working directory from being unintentionally included in the classpath when using the Reflections library.\n\nIf the current working directory should still be included in the classpath, it just needs to be explicitly specified either with its fully-qualified pathname or as a single dot (\".\").\n\nAuthor: Chris Egerton <chrise@confluent.io>\n\nReviewers: Randall Hauch <rhauch@gmail.com>, Jun Rao <junrao@gmail.com>\n\nCloses #4406 from C0urante/fix-colon-prefixed-classpath","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/abf4c547017304c9b1e743723bdcb0b8a4df1ad0"},{"sha":"06597ba26b85e1efa02078753d67855b82b79a4d","author":{"name":"Joel Hamill","email":"7f4bae5541ca5dd735d31270866ebd4e6f3a688d@users.noreply.github.com"},"message":"MINOR: Menu updates and navigation (#4405)\n\n* Menu updates and navigation\r\n\r\nReviewers: Guozhang Wang <wangguoz@gmail.com>","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/06597ba26b85e1efa02078753d67855b82b79a4d"},{"sha":"874eeb88d9dc5e8fbcd681672fb90a4cd7597fec","author":{"name":"tedyu","email":"f3efda66e9dbf526c8baa4fd8c1378586ced3c51@gmail.com"},"message":"KAFKA-6412 Improve synchronization in CachingKeyValueStore methods\n\nCurrently CachingKeyValueStore methods are synchronized at method level.\n\nIt seems we can use read lock for getter and write lock for put / delete methods.\n\nFor getInternal(), if the underlying thread is streamThread, the getInternal() may trigger eviction. This can be handled by obtaining write lock at the beginning of the method for streamThread.\n\nThe jmh patch is attached to JIRA:\nhttps://issues.apache.org/jira/secure/attachment/12905140/6412-jmh.v1.txt\n\nAuthor: tedyu <yuzhihong@gmail.com>\n\nReviewers: Damian Guy <damian.guy@gmail.com>, Bill Bejeck <bill@confluent.io>\n\nCloses #4372 from tedyu/6412","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/874eeb88d9dc5e8fbcd681672fb90a4cd7597fec"},{"sha":"fa5ebc8a019f8cb24823dd29ef84d422d93624dc","author":{"name":"Guozhang Wang","email":"08d6b47f1ed933bf8f63fe549a461671f3a38d3b@gmail.com"},"message":"KAFKA-6398: fix KTable.filter that does not include its parent's queryable storename\n\n1. Include the parent's queryable store name in KTable.filter if this operator is not materialized.\n2. Augment InternalTopologyBuilder checking on null processor / store names from the enum.\n3. Unit test.\n\nAuthor: Guozhang Wang <wangguoz@gmail.com>\n\nReviewers: Damian Guy <damian.guy@gmail.com>, Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>\n\nCloses #4384 from guozhangwang/K6398-topology-builder-exception","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/fa5ebc8a019f8cb24823dd29ef84d422d93624dc"},{"sha":"92529ac6d8c117f1704d84f94f18b9497707a1b5","author":{"name":"Jun Rao","email":"d707906c197b452f1c349079d917a39232bd1114@gmail.com"},"message":"Merge pull request #3567 from bobrik/unclean-docs-clarification\n\nKAFKA-4711: fix docs onunclean.leader.election.enable default","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/92529ac6d8c117f1704d84f94f18b9497707a1b5"},{"sha":"4d544d4f08b027ce318b088b112f03dccc566098","author":{"name":"Rohan Desai","email":"c723573cbb502d63bc43de5c6c8de631b3c98668@gmail.com"},"message":"KAFKA-6383: Complete shut down for streams threads that have not started\n\n*More detailed description of your change,\nif necessary. The PR title and PR message become\nthe squashed commit message, so use a separate\ncomment to ping reviewers.*\n\n*Summary of testing strategy (including rationale)\nfor the feature or bug fix. Unit and/or integration\ntests are expected for any behaviour change and\nsystem tests should be considered for larger changes.*\n\nAuthor: Rohan Desai <desai.p.rohan@gmail.com>\n\nReviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com>\n\nCloses #4382 from rodesai/KAFKA-6383","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/4d544d4f08b027ce318b088b112f03dccc566098"},{"sha":"b8aa1761c39bd320950104fa2ddf4fbd7163fc85","author":{"name":"Richard Yu","email":"3b2b3261cd2b7bbcb898e8bb7d10f1c75dc90c23@gmail.com"},"message":"KAFKA-6265: Add #queryableStoreName() to GlobalKTable\n\nA spinoff of original pull request #4340 for resolving conflicts.\n\nAuthor: RichardYuSTUG <yohan.richard.yu2@gmail.com>\n\nReviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com>\n\nCloses #4413 from ConcurrencyPractitioner/kafka-6265-2","distinct":true,"url":"https://api.github.com/repos/nicktrav/kafka/commits/b8aa1761c39bd320950104fa2ddf4fbd7163fc85"}]}
{"actor":{"display_login":"nicktrav"}}