{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":259921498,"defaultBranch":"trunk","name":"kafka","ownerLogin":"rgroothuijsen","currentUserCanPush":false,"isFork":true,"isEmpty":false,"createdAt":"2020-04-29T12:39:20.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/10956280?v=4","public":true,"private":false,"isOrgOwned":false},"refInfo":{"name":"","listCacheKey":"v0:1662585262.640807","currentOid":""},"activityList":{"items":[{"before":"53c41aca7ba9469a0145023112f5fad254da4fa8","after":"52a3fa07446f9c108399d47dbfb1685989a5d6eb","ref":"refs/heads/trunk","pushedAt":"2024-03-02T10:33:18.000Z","pushType":"push","commitsCount":9,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15878: KIP-768 - Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER (#14818)\n\n# Overview\r\n* This change pertains to [SASL/OAUTHBEARER ](https://kafka.apache.org/documentation/#security_sasl_oauthbearer) mechanism of Kafka authentication. \r\n* Kafka clients can use [SASL/OAUTHBEARER ](https://kafka.apache.org/documentation/#security_sasl_oauthbearer) mechanism by overriding the [custom call back handlers](https://kafka.apache.org/documentation/#security_sasl_oauthbearer_prod) . \r\n* [KIP-768](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=186877575) available from v3.1 further extends the mechanism with a production grade implementation. \r\n* Kafka's [SASL/OAUTHBEARER ](https://kafka.apache.org/documentation/#security_sasl_oauthbearer) mechanism currently **rejects the non-JWT (i.e. opaque) tokens**. This is because of a more restrictive set of characters than what [RFC-6750](https://datatracker.ietf.org/doc/html/rfc6750#section-2.1) recommends. \r\n* This JIRA can be considered an extension of [KIP-768](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=186877575) to support the opaque tokens as well apart from the JWT tokens.\r\n \r\n# Solution\r\n* Have updated the regex in the the offending class to be compliant with the [RFC-6750](https://datatracker.ietf.org/doc/html/rfc6750#section-2.1)\r\n* Have provided a supporting test case that includes the possible character set defined in [RFC-6750](https://datatracker.ietf.org/doc/html/rfc6750#section-2.1)\r\n\r\n---------\r\n\r\nCo-authored-by: Anuj Sharma \r\nCo-authored-by: Jamie Holmes \r\nCo-authored-by: Christopher Webb <31657038+cwebbtw@users.noreply.github.com>\r\nReviewers: Manikumar Reddy , Kirk True ","shortMessageHtmlLink":"KAFKA-15878: KIP-768 - Extend support for opaque (i.e. non-JWT) token…"}},{"before":"7efdf40a77cf1c929e785ba04fa2363d4989c4c4","after":"53c41aca7ba9469a0145023112f5fad254da4fa8","ref":"refs/heads/trunk","pushedAt":"2024-02-28T11:20:22.000Z","pushType":"push","commitsCount":11,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16116: Rebalance Metrics for AsyncKafkaConsumer (#15339)\n\nAdding the following rebalance metrics to the consumer:\r\n\r\nrebalance-latency-avg\r\nrebalance-latency-max\r\nrebalance-latency-total\r\nrebalance-rate-per-hour\r\nrebalance-total\r\nfailed-rebalance-rate-per-hour\r\nfailed-rebalance-total\r\n\r\nDue to the difference in protocol, we need to redefine when rebalance starts and ends.\r\nStart of Rebalance:\r\nCurrent: Right before sending out JoinGroup\r\nConsumerGroup: When the client receives assignments from the HB\r\n\r\nEnd of Rebalance - Successful Case:\r\nCurrent: Receiving SyncGroup request after transitioning to \"COMPLETING_REBALANCE\"\r\nConsumerGroup: After completing reconciliation and right before sending out \"Ack\" heartbeat\r\n\r\nEnd of Rebalance - Failed Case:\r\nCurrent: Any failure in the JoinGroup/SyncGroup response\r\nConsumerGroup: Failure in the heartbeat\r\n\r\nNote: Afterall, we try to be consistent with the current protocol. Rebalances start and end with sending and receiving network requests. Failures in network requests signify the user failures in rebalance. And it is entirely possible to have multiple failures before having a successful one.\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16116: Rebalance Metrics for AsyncKafkaConsumer (apache#15339)"}},{"before":"ead2431c37ace9255df88ffe819bb905311af088","after":"7efdf40a77cf1c929e785ba04fa2363d4989c4c4","ref":"refs/heads/trunk","pushedAt":"2024-02-23T16:40:31.000Z","pushType":"push","commitsCount":18,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Improve test testCommitInRebalanceCallback (#15420)\n\nCommit 1442862 introduced a test with an assertion inside a listener\r\ncallback. This improves the test by checking that the listener is\r\nactually being executed, to avoid silent skipping of the assertion.\r\n\r\nReviewers: Matthias J. Sax ","shortMessageHtmlLink":"MINOR: Improve test testCommitInRebalanceCallback (apache#15420)"}},{"before":"b71999be95325f6ea54e925cbe5b426425781014","after":"ead2431c37ace9255df88ffe819bb905311af088","ref":"refs/heads/trunk","pushedAt":"2024-02-20T17:30:55.000Z","pushType":"push","commitsCount":4,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Remove unwanted debug line in LogDirFailureTest (#15371)\n\n\r\nReviewers: Mickael Maison , Justine Olshan , Igor Soarez ","shortMessageHtmlLink":"MINOR: Remove unwanted debug line in LogDirFailureTest (apache#15371)"}},{"before":"cd328d84acc956deb61964d238ca803249aa6314","after":"b71999be95325f6ea54e925cbe5b426425781014","ref":"refs/heads/trunk","pushedAt":"2024-02-19T20:26:11.000Z","pushType":"push","commitsCount":39,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Clean up core modules (#15279)\n\nThis PR cleans up: metrics, migration, network, raft, security, serializer, tools, utils, and zookeeper package classes\r\n\r\nMark methods and fields private where possible\r\nAnnotate public methods and fields\r\nRemove unused classes and methods\r\nMake sure Arrays are not printed with .toString\r\nOptimize minor warnings\r\n\r\nReviewers: Mickael Maison ","shortMessageHtmlLink":"MINOR: Clean up core modules (apache#15279)"}},{"before":"3db14ec62a462a21f9196bad2f6cc325e30754c6","after":"cd328d84acc956deb61964d238ca803249aa6314","ref":"refs/heads/trunk","pushedAt":"2024-02-08T20:15:36.000Z","pushType":"push","commitsCount":15,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15201: Allow git push to fail gracefully (#14645)\n\nReviewers: Divij Vaidya , Qichao Chu ","shortMessageHtmlLink":"KAFKA-15201: Allow git push to fail gracefully (apache#14645)"}},{"before":"4f0a40590833a141c78341ce95ffc782747c5ac8","after":"3db14ec62a462a21f9196bad2f6cc325e30754c6","ref":"refs/heads/trunk","pushedAt":"2024-02-03T14:50:32.000Z","pushType":"push","commitsCount":10,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16157: fix topic recreation handling with offline disks (#15263)\n\nIn Kraft mode, the broker fails to handle topic recreation correctly with broken disks. This is because ReplicaManager tracks HostedPartitions which are on an offline disk but it doesn't associate TopicId information with them.\r\n\r\nThis change updates HostedPartition.Offline to associate topic id information. We also update the log creation logic in Partition::createLogInAssignedDirectoryId to not just rely on targetLogDirectoryId == DirectoryId.UNASSIGNED to determine if the log to be created is \"new\".\r\n\r\nPlease refer to the comments in https://issues.apache.org/jira/browse/KAFKA-16157 for more information.\r\n\r\nReviewers: Luke Chen , Omnia Ibrahim , Gaurav Narula ","shortMessageHtmlLink":"KAFKA-16157: fix topic recreation handling with offline disks (apache…"}},{"before":"9e4a4a28218b8803a6f41b65e19a94268035ccf5","after":"4f0a40590833a141c78341ce95ffc782747c5ac8","ref":"refs/heads/trunk","pushedAt":"2024-02-01T17:45:24.000Z","pushType":"push","commitsCount":17,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15575: Begin enforcing 'tasks.max' property for connectors (#15180)\n\nReviewers: Ashwin Pankaj , Greg Harris ","shortMessageHtmlLink":"KAFKA-15575: Begin enforcing 'tasks.max' property for connectors (apa…"}},{"before":"80a1bf8f5695a8565965860400b7bafc31affa8c","after":"9e4a4a28218b8803a6f41b65e19a94268035ccf5","ref":"refs/heads/trunk","pushedAt":"2024-01-30T16:37:59.000Z","pushType":"push","commitsCount":23,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16204: Create partition dir for mockLog (#15288)\n\n\r\nReviewers: Mickael Maison , Omnia Ibrahim ","shortMessageHtmlLink":"KAFKA-16204: Create partition dir for mockLog (apache#15288)"}},{"before":"7e5ef9b509a00973d271def5f70ca2062208e778","after":"80a1bf8f5695a8565965860400b7bafc31affa8c","ref":"refs/heads/trunk","pushedAt":"2024-01-25T17:32:15.000Z","pushType":"push","commitsCount":4,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16003: Always create the /config/topics ZNode even for topics without configs (#15022)\n\n\r\nReviewers: Luke Chen ","shortMessageHtmlLink":"KAFKA-16003: Always create the /config/topics ZNode even for topics w…"}},{"before":"0ef89a7cc059b0ba9b2536e018303c9004ac9142","after":"7e5ef9b509a00973d271def5f70ca2062208e778","ref":"refs/heads/trunk","pushedAt":"2024-01-24T21:53:04.000Z","pushType":"push","commitsCount":7,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15585: Implement DescribeTopicPartitions RPC on broker (#14612)\n\nThis patch implements the new DescribeTopicPartitions RPC as defined in KIP-966 (ELR). Additionally, this patch adds a broker config \"max.request.partition.size.limit\" which limits the number of partitions returned by the new RPC.\r\n\r\nReviewers: Artem Livshits , Jason Gustafson , David Arthur ","shortMessageHtmlLink":"KAFKA-15585: Implement DescribeTopicPartitions RPC on broker (apache#…"}},{"before":"62ce551826192ef6137bc3ce670277f79bd3dee2","after":"0ef89a7cc059b0ba9b2536e018303c9004ac9142","ref":"refs/heads/trunk","pushedAt":"2024-01-23T18:13:12.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Update KIP-890 note (#15244)\n\nWe've released the fix so I updated the note. We can backport to 3.6 and 3.7 branches as well.\r\n\r\nReviewers: Ismael Juma , Divij Vaidya ","shortMessageHtmlLink":"MINOR: Update KIP-890 note (apache#15244)"}},{"before":"e45e032b8d90435de2f338f77a732c88f8cca66e","after":"62ce551826192ef6137bc3ce670277f79bd3dee2","ref":"refs/heads/trunk","pushedAt":"2024-01-22T16:29:00.000Z","pushType":"push","commitsCount":9,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15853: Move KafkaConfig.Defaults to server module (#15158)\n\n\r\nReviewers: Mickael Maison , Ismael Juma 
, David Jacot , Nikolay ","shortMessageHtmlLink":"KAFKA-15853: Move KafkaConfig.Defaults to server module (apache#15158)"}},{"before":"26465c64092868c972e2a0e4d9a4fc0ed13a7a39","after":"e45e032b8d90435de2f338f77a732c88f8cca66e","ref":"refs/heads/trunk","pushedAt":"2024-01-18T23:22:46.000Z","pushType":"push","commitsCount":11,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16087: Avoid data race which drops wrong record when errors.tolerance=all (#15154)\n\nSigned-off-by: Greg Harris \r\nReviewers: Chris Egerton ","shortMessageHtmlLink":"KAFKA-16087: Avoid data race which drops wrong record when errors.tol…"}},{"before":"055ff2b831193f5935f9efc2f7809f853f63de5f","after":"26465c64092868c972e2a0e4d9a4fc0ed13a7a39","ref":"refs/heads/trunk","pushedAt":"2024-01-17T18:27:07.000Z","pushType":"push","commitsCount":3,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16097: Disable state updater in trunk (#15204)\n\nSeveral problems are still appearing while running 3.7 with\r\nthe state updater. This change will disable the state updater\r\nby default also in trunk.\r\n\r\nReviewers: Bruno Cadonna ","shortMessageHtmlLink":"KAFKA-16097: Disable state updater in trunk (apache#15204)"}},{"before":"b16df3b103d915d33670b8156217fc6c2b473f61","after":"055ff2b831193f5935f9efc2f7809f853f63de5f","ref":"refs/heads/trunk","pushedAt":"2024-01-16T19:13:30.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15834: Remove NamedTopologyIntegrationTest case which leaks clients (#15185)\n\nSigned-off-by: Greg Harris \r\nReviewers: Anna Sophie Blee-Goldman , Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-15834: Remove NamedTopologyIntegrationTest case which leaks cli…"}},{"before":"378a01999ef3f80910f506d8c419e825d5a90a97","after":"b16df3b103d915d33670b8156217fc6c2b473f61","ref":"refs/heads/trunk","pushedAt":"2024-01-15T22:10:22.000Z","pushType":"push","commitsCount":5,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16133 - Reconciliation auto-commit fix (#15194)\n\nThis fixes an issue with the time boundaries used for the auto-commit performed when partitions are revoked.\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16133 - Reconciliation auto-commit fix (apache#15194)"}},{"before":"6b9cb5ccbfaf8fa9e76db3425a5ad08bbcda3446","after":"378a01999ef3f80910f506d8c419e825d5a90a97","ref":"refs/heads/trunk","pushedAt":"2024-01-13T16:05:20.000Z","pushType":"push","commitsCount":5,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Add isRemoteLogEnabled parameter to the Log Loader Javadoc. (#15179)\n\nAdd isRemoteLogEnabled parameter to the Log Loader Javadoc\r\n\r\nReviewers: Luke Chen , Satish Duggana ","shortMessageHtmlLink":"MINOR: Add isRemoteLogEnabled parameter to the Log Loader Javadoc. (a…"}},{"before":"6ff21ee1e009a5a2729bb105591a9bfa16c6c4c5","after":"6b9cb5ccbfaf8fa9e76db3425a5ad08bbcda3446","ref":"refs/heads/trunk","pushedAt":"2024-01-12T14:39:16.000Z","pushType":"push","commitsCount":8,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-14505; [5/N] Add `UNSTABLE_OFFSET_COMMIT` error support (#15155)\n\nThis patch adds `UNSTABLE_OFFSET_COMMIT` errors support in the new group coordinator. `UNSTABLE_OFFSET_COMMIT` errors for partitions with unstable offset commits. Here unstable means that there are ongoing transactions.\r\n\r\nReviewers: Justine Olshan ","shortMessageHtmlLink":"KAFKA-14505; [5/N] Add UNSTABLE_OFFSET_COMMIT error support (apache…"}},{"before":"fbbfafe1f556f424bf511697db6f399e5a622aa3","after":"6ff21ee1e009a5a2729bb105591a9bfa16c6c4c5","ref":"refs/heads/trunk","pushedAt":"2024-01-11T16:11:08.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Disalow using a group id with only whitespaces in the new consumer group protocol (#15173)\n\nThis patch strengthen the validation of the group id when the new consumer group protocol is used.\r\n\r\nReviewers: Divij Vaidya ","shortMessageHtmlLink":"MINOR: Disalow using a group id with only whitespaces in the new cons…"}},{"before":"c7e1fdca64dcbd8cedf8aaf826c22566b7485dad","after":"fbbfafe1f556f424bf511697db6f399e5a622aa3","ref":"refs/heads/trunk","pushedAt":"2024-01-10T18:05:23.000Z","pushType":"push","commitsCount":10,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16098: Verify pending recycle action when standby is re-assigned (#15168)\n\nWhen a standby is recycled to an active and then re-assigned as\r\na standby again, it might happen that the recycling is still\r\npending when the standby is reassigned. That causes an illegal\r\nstate exception from the main consumer since the active task\r\nthat results from the recycling is actually not assigned to\r\nthe main consumer anymore, but it was re-assigned as a\r\nstandby in the most recent rebalance.\r\n\r\nReviewer: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16098: Verify pending recycle action when standby is re-assigned ("}},{"before":"70c8b8d0af50d8982c71d7a994270961441e5af7","after":"c7e1fdca64dcbd8cedf8aaf826c22566b7485dad","ref":"refs/heads/trunk","pushedAt":"2024-01-09T20:05:38.000Z","pushType":"push","commitsCount":10,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15988: Reuse embedded clusters across test cases in Connect OffsetsApiIntegrationTest suite (#14966)\n\nReviewers: Sudesh Wasnik , Sagar Rao , Yash Mayya , Greg Harris ","shortMessageHtmlLink":"KAFKA-15988: Reuse embedded clusters across test cases in Connect Off…"}},{"before":"cce63274f2fdf9a4db014e2bae8019677b2cd7b2","after":"70c8b8d0af50d8982c71d7a994270961441e5af7","ref":"refs/heads/trunk","pushedAt":"2024-01-06T16:22:12.000Z","pushType":"push","commitsCount":3,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16059: close more kafkaApis instances (#15132)\n\nReviewers: Divij Vaidya , Justine Olshan ","shortMessageHtmlLink":"KAFKA-16059: close more kafkaApis instances (apache#15132)"}},{"before":"e6f2624c48ceab032811693e1013b70c6ee16c74","after":"cce63274f2fdf9a4db014e2bae8019677b2cd7b2","ref":"refs/heads/trunk","pushedAt":"2024-01-05T14:41:52.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16086: Fix memory leak in RocksDBStore (#15135)\n\nWe allocate an `Options` in order to list column families while opening\r\nthe `RocksDBStore`, but never explicitly `close()` it.\r\n\r\n`Options` is a RocksDB native object, which needs to be explicitly\r\nclosed to free the resources it allocates in native memory.\r\n\r\nFailing to close this causes a memory leak when repeatedly\r\nopening/closing stores.\r\n\r\nIt's an `AutoCloseable`, and all usage of it is confined to the\r\nsurrounding `try` block, so we can just hook it out to the `try` to\r\nauto-close it when done.\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16086: Fix memory leak in RocksDBStore (apache#15135)"}},{"before":"60c445bdd51c608d1212f5cab83b65533739bd61","after":"e6f2624c48ceab032811693e1013b70c6ee16c74","ref":"refs/heads/trunk","pushedAt":"2024-01-04T14:11:18.000Z","pushType":"push","commitsCount":7,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-14133: Migrate storeMetadata mock in StoreChangelogReaderTest to Mockito (#15116)\n\nReviewers: Divij Vaidya ","shortMessageHtmlLink":"KAFKA-14133: Migrate storeMetadata mock in StoreChangelogReaderTest t…"}},{"before":"e01eed32ab2a223f8231a7d7e6c4eef05a7fed6f","after":"60c445bdd51c608d1212f5cab83b65533739bd61","ref":"refs/heads/trunk","pushedAt":"2024-01-03T14:46:56.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Improve code style (#15107)\n\nReviewers: Divij Vaidya ","shortMessageHtmlLink":"MINOR: Improve code style (apache#15107)"}},{"before":"cd1eb634c506e861d7445b2b5a3f40258d77fa17","after":"e01eed32ab2a223f8231a7d7e6c4eef05a7fed6f","ref":"refs/heads/trunk","pushedAt":"2024-01-02T18:15:02.000Z","pushType":"push","commitsCount":4,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-9545: Fix IllegalStateException in updateLags (#15096)\n\nWe attempt to update lags when in state PENDING_SHUTDOWN or PARTITIONS_REVOKED. In these states,\r\nhowever, our representation of the assignment may not be up-to-date with the subscription\r\nobject inside the consumer. This can cause a bug, in particular, when we subscribe to a\r\nset of topics via a regular expression, and the underlying topic is deleted. The consumer\r\nsubscription may reflect that topic deletion already, while our internal state still\r\ncontains references to the deleted topic, because `onAssignment` has not yet been\r\nexecuted. Therefore, we will attempt to call `currentLag` on partitions that are not\r\nassigned to us any more inside the consumer, leading to an `IllegalStateException`.\r\n\r\nThis bug causes flakiness of the test\r\n`RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`.\r\n\r\nReviewers: Matthias J. Sax , Bruno Cadonna ","shortMessageHtmlLink":"KAFKA-9545: Fix IllegalStateException in updateLags (apache#15096)"}},{"before":"d5aa341a185f4df23bf587e55bcda4f16fc511f1","after":"cd1eb634c506e861d7445b2b5a3f40258d77fa17","ref":"refs/heads/trunk","pushedAt":"2024-01-01T20:38:45.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-15816: Fix leaked sockets in runtime tests (#14764)\n\nThis commit fixes to prevent socket leaks, mostly through clients that are left open.\r\n\r\nReviewers: Mickael Maison ","shortMessageHtmlLink":"KAFKA-15816: Fix leaked sockets in runtime tests (apache#14764)"}},{"before":"b3664119fd32272772577a00ccd09110cbb7bd98","after":"d5aa341a185f4df23bf587e55bcda4f16fc511f1","ref":"refs/heads/trunk","pushedAt":"2023-12-31T14:45:30.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"MINOR: Fix flaky test GroupMetadataManagerTest.testStaticMemberGetsBackAssignmentUponRejoin (#15100)\n\nReviewers: Divij Vaidya \r\n\r\n---------\r\n\r\nCo-authored-by: Sagar Rao ","shortMessageHtmlLink":"MINOR: Fix flaky test GroupMetadataManagerTest.testStaticMemberGetsBa…"}},{"before":"0600ac00e9b7a96c67d6a954123eae4b7ec6f392","after":"b3664119fd32272772577a00ccd09110cbb7bd98","ref":"refs/heads/trunk","pushedAt":"2023-12-30T21:10:44.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"rgroothuijsen","name":"Rens Groothuijsen","path":"/rgroothuijsen","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10956280?s=80&v=4"},"commit":{"message":"KAFKA-16064: Improve ControllerApiTest (#15091)\n\nThis commit refactors ControllerApiTest to close an instance of ControllerApis in a tearDown method.\r\n\r\nReviewers: Divij Vaidya ","shortMessageHtmlLink":"KAFKA-16064: Improve ControllerApiTest (apache#15091)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAECnUOzAA","startCursor":null,"endCursor":null}},"title":"Activity · rgroothuijsen/kafka"}