{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":2211243,"defaultBranch":"trunk","name":"kafka","ownerLogin":"apache","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2011-08-15T18:06:16.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/47359?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1714079292.0","currentOid":""},"activityList":{"items":[{"before":"ec151c82783f75de3ee755c80ba9ccfbe338c512","after":"636e65aa6b3558a7ae239ce69579b62ab3377fcb","ref":"refs/heads/trunk","pushedAt":"2024-04-29T09:56:36.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lucasbru","name":"Lucas Brutschy","path":"/lucasbru","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1628637?s=80&v=4"},"commit":{"message":"KAFKA-16465: Fix consumer sys test revocation validation (#15778)\n\nThis fixes a consumer system test that was failing for the new protocol. The failure was because the test was expecting the eager behaviour of partitions being revoked on every rebalance, and it was wrongfully applying it to the runs with the new protocol too.\r\nThis same situation was previously identified and fixed in other parts of the sys test with #15661.\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16465: Fix consumer sys test revocation validation (#15778)"}},{"before":"14626837b36c1ae7f757ffa4bcb6d19f8e101701","after":"fa517816d5cb88227c416a8c3f175f88cf236a63","ref":"refs/heads/3.7","pushedAt":"2024-04-29T09:47:07.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"showuon","name":"Luke Chen","path":"/showuon","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/43372967?s=80&v=4"},"commit":{"message":"KAFKA-16563: retry pollEvent in KRaftMigrationDriver for retriable errors (#15732)\n\nWhen running ZK migrating to KRaft process, we encountered an issue that the migrating is hanging and the ZkMigrationState cannot move to MIGRATION state. And it is because the pollEvent didn't retry with the retriable MigrationClientException (ZK client retriable errors) while it should. This PR fixes it and add test. And because of this, the poll event will not poll anymore, which causes the KRaftMigrationDriver hanging.\r\n\r\nReviewers: Luke Chen , Igor Soarez, Akhilesh C ","shortMessageHtmlLink":"KAFKA-16563: retry pollEvent in KRaftMigrationDriver for retriable er…"}},{"before":"a9b4b88e54a5e70b0b17f827fb3a97237d18c66a","after":"ec151c82783f75de3ee755c80ba9ccfbe338c512","ref":"refs/heads/trunk","pushedAt":"2024-04-29T09:44:47.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"showuon","name":"Luke Chen","path":"/showuon","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/43372967?s=80&v=4"},"commit":{"message":"KAFKA-16563: retry pollEvent in KRaftMigrationDriver for retriable errors (#15732)\n\nWhen running ZK migrating to KRaft process, we encountered an issue that the migrating is hanging and the ZkMigrationState cannot move to MIGRATION state. And it is because the pollEvent didn't retry with the retriable MigrationClientException (ZK client retriable errors) while it should. This PR fixes it and add test. And because of this, the poll event will not poll anymore, which causes the KRaftMigrationDriver hanging.\r\n\r\nReviewers: Luke Chen , Igor Soarez, Akhilesh C ","shortMessageHtmlLink":"KAFKA-16563: retry pollEvent in KRaftMigrationDriver for retriable er…"}},{"before":"994077e43e2415261bd17443568723f35c3e29d9","after":"a9b4b88e54a5e70b0b17f827fb3a97237d18c66a","ref":"refs/heads/trunk","pushedAt":"2024-04-29T08:58:12.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"showuon","name":"Luke Chen","path":"/showuon","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/43372967?s=80&v=4"},"commit":{"message":"MINOR: Remove unneccessary version from excluded dependencies of clients (#15804)\n\nSmall cleanup: removed version when excluding shaded dependencies from clients library as it's not needed.\r\n\r\nReviewers: Luke Chen , Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Remove unneccessary version from excluded dependencies of clie…"}},{"before":"5de5d967adffd864bad3ec729760a430253abf38","after":"994077e43e2415261bd17443568723f35c3e29d9","ref":"refs/heads/trunk","pushedAt":"2024-04-29T07:43:49.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"MINOR: Fix the flaky testConsumerGroupHeartbeatWithStableClassicGroup by sorting the topic partition list (#15816)\n\nWe are seeing flaky test in `testConsumerGroupHeartbeatWithStableClassicGroup` where the error is caused by the different ordering in the expected and actual values. The patch sorts the topic partition list in the records to fix the issue.\r\n\r\nReviewers: Jeff Kim , Igor Soarez , David Jacot ","shortMessageHtmlLink":"MINOR: Fix the flaky testConsumerGroupHeartbeatWithStableClassicGroup…"}},{"before":"4060d4370ecda867f8a3ac338c617dc8ee71a4d6","after":"5de5d967adffd864bad3ec729760a430253abf38","ref":"refs/heads/trunk","pushedAt":"2024-04-27T18:00:56.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-16560 Refactor/cleanup BrokerNode/ControllerNode/ClusterConfig (#15761)\n\n* Make ClusterConfig immutable\r\n* Make BrokerNode immutable\r\n* Refactor out build argument in ControllerNode\r\n* Add setPrefix and replace put property with set map in ClusterConfig\r\n* Remove rollingBrokerRestart from ClusterInstance interface\r\n* Refactor KRaftClusterTest#doOnStartedKafkaCluster\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16560 Refactor/cleanup BrokerNode/ControllerNode/ClusterConfig (#…"}},{"before":"cc5955d5b2848c9e235e69bc44f2f511bc4ae4a7","after":"4060d4370ecda867f8a3ac338c617dc8ee71a4d6","ref":"refs/heads/trunk","pushedAt":"2024-04-27T00:00:29.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-6527 Enable DynamicBrokerReconfigurationTest.testDefaultTopicConfig (#15796)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-6527 Enable DynamicBrokerReconfigurationTest.testDefaultTopicCo…"}},{"before":"c287ad5dbe34995dcfc630065a0f9937da163c58","after":"cc5955d5b2848c9e235e69bc44f2f511bc4ae4a7","ref":"refs/heads/trunk","pushedAt":"2024-04-26T23:16:29.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: Various cleanups in generator (#15807)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Various cleanups in generator (#15807)"}},{"before":"d88c15fc3ed0d13e380b29df3559591c59fbf4c5","after":"c287ad5dbe34995dcfc630065a0f9937da163c58","ref":"refs/heads/trunk","pushedAt":"2024-04-26T23:11:11.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: refine DeleteOffsetsConsumerGroupCommandIntegrationTest#produceRecord (#15802)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: refine DeleteOffsetsConsumerGroupCommandIntegrationTest#produc…"}},{"before":"ba6a73776b65603b4c866f8d2db966d826031e74","after":"d88c15fc3ed0d13e380b29df3559591c59fbf4c5","ref":"refs/heads/trunk","pushedAt":"2024-04-26T23:02:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-15853 Move KRAFT configs out of KafkaConfig (#15775)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-15853 Move KRAFT configs out of KafkaConfig (#15775)"}},{"before":"e7792258df934a5c8470c2925c5d164c7d5a8e6c","after":"ba6a73776b65603b4c866f8d2db966d826031e74","ref":"refs/heads/trunk","pushedAt":"2024-04-26T22:53:19.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"MINOR: Change the documentation of the Brokers field. (#15809)\n\nChange the documentation of the Brokers field to make it clear that it doesn't always have all the\r\nbrokers that are listed as replicas.\r\n\r\nReviewer: Colin P. McCabe ","shortMessageHtmlLink":"MINOR: Change the documentation of the Brokers field. (#15809)"}},{"before":"2db87f04b807b6ea6ba6cdd43fc05852cb1938e9","after":"e7792258df934a5c8470c2925c5d164c7d5a8e6c","ref":"refs/heads/trunk","pushedAt":"2024-04-26T13:20:10.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"MINOR: Various cleanups in raft (#15805)\n\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Various cleanups in raft (#15805)"}},{"before":"21faf874c037966b73bb85d39c6b2dc93dd26048","after":"2db87f04b807b6ea6ba6cdd43fc05852cb1938e9","ref":"refs/heads/trunk","pushedAt":"2024-04-26T08:28:57.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lucasbru","name":"Lucas Brutschy","path":"/lucasbru","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1628637?s=80&v=4"},"commit":{"message":"KAFKA-16298: Ensure rebalance listener exceptions are propagated to the user on consumer poll (#15742)\n\nWhen user-defined rebalance listeners fail with an exception, the expectation is that the error should be propagated to the user as a KafkaException and break the poll loop (behavior in the legacy coordinator). The new consumer executes callbacks in the application thread, and sends an event to the background with the callback result and error if any, passing the error along with the event here to the background thread, but does not seem to propagate the exception to the user.\r\n\r\nReviewers: Lianet Magrans , Kirk True , Bruno Cadonna ","shortMessageHtmlLink":"KAFKA-16298: Ensure rebalance listener exceptions are propagated to t…"}},{"before":"82844c01d8e0111e9d0eb5cb37293e3b248b147b","after":"21faf874c037966b73bb85d39c6b2dc93dd26048","ref":"refs/heads/trunk","pushedAt":"2024-04-26T08:21:22.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lucasbru","name":"Lucas Brutschy","path":"/lucasbru","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1628637?s=80&v=4"},"commit":{"message":"KAFKA-16565: IncrementalAssignmentConsumerEventHandler throws error when attempting to remove a partition that isn't assigned (#15737)\n\nChecking that the TopicPartition is in assignment before attempting to remove it.\r\n\r\nAlso added some logging and refactoring.\r\n\r\nReviewers: Lucas Brutschy , Lianet Magrans ","shortMessageHtmlLink":"KAFKA-16565: IncrementalAssignmentConsumerEventHandler throws error w…"}},{"before":"49587777c1cf5673598c7458512c608117baefd3","after":"82844c01d8e0111e9d0eb5cb37293e3b248b147b","ref":"refs/heads/trunk","pushedAt":"2024-04-26T07:29:59.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"cadonna","name":"Bruno Cadonna","path":"/cadonna","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1042170?s=80&v=4"},"commit":{"message":"KAFKA-16528: Client HB timing fix (#15698)\n\nFix for resetting HB timer when the request is sent, rather than when a response is received. This ensures a more accurate timing of the HB, so that a member always sends HB on the interval (not in the interval + any delay in receiving the response).\r\nThis change, along with the logic already in place for checking in-flights, ensures that if the interval expires but there is a HB in-flight, the next HB is only send after the response for the in-flight is received, without waiting for another full interval. This is btw consistent with the timer reset & inflight behaviour for the auto-commit interval.\r\n\r\nReviewers: Kirk True , Bruno Cadonna ","shortMessageHtmlLink":"KAFKA-16528: Client HB timing fix (#15698)"}},{"before":"025f9816f1a15d14aab25c9e8e5b03a87f0cefe2","after":"49587777c1cf5673598c7458512c608117baefd3","ref":"refs/heads/trunk","pushedAt":"2024-04-26T07:04:05.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: fix timeouts of EosIntegrationTest (#15811)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: fix timeouts of EosIntegrationTest (#15811)"}},{"before":"df4ef5a6210c01661a068123d52af7bf8ba6769d","after":"025f9816f1a15d14aab25c9e8e5b03a87f0cefe2","ref":"refs/heads/trunk","pushedAt":"2024-04-26T00:31:53.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: fix javadoc warnings (#15527)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: fix javadoc warnings (#15527)"}},{"before":"6feae817d25d3ffd97916f53c0183f88494a23c3","after":"df4ef5a6210c01661a068123d52af7bf8ba6769d","ref":"refs/heads/trunk","pushedAt":"2024-04-25T21:50:41.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: Various cleanups in metadata (#15806)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Various cleanups in metadata (#15806)"}},{"before":"6feae817d25d3ffd97916f53c0183f88494a23c3","after":"65d96aeaf50b6076b982b4b2e69fec0803c4be83","ref":"refs/heads/KAFKA-16624","pushedAt":"2024-04-25T21:08:51.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"KAFKA-16624: Don't generate useless PartitionChangeRecord on older MV\n\nFix a case where we could generate useless PartitionChangeRecords on metadata versions older than\n3.6-IV0. This could happen in the case where we had an ISR with only one broker in it, and we were\ntrying to go down to a fully empty ISR. In this case, PartitionChangeBuilder would block the record\nto going down to a fully empty ISR (since that is not valid in these pre-KIP-966 metadata\nversions), but it would still emit the record, even though it had no effect.","shortMessageHtmlLink":"KAFKA-16624: Don't generate useless PartitionChangeRecord on older MV"}},{"before":null,"after":"6feae817d25d3ffd97916f53c0183f88494a23c3","ref":"refs/heads/KAFKA-16624","pushedAt":"2024-04-25T21:08:12.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"cmccabe","name":"Colin Patrick McCabe","path":"/cmccabe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1095624?s=80&v=4"},"commit":{"message":"MINOR: Rename RaftConfig to QuorumConfig (#15797)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Rename RaftConfig to QuorumConfig (#15797)"}},{"before":"ce9026f597edfcdbcd8f3b4fe2a6701036462047","after":"6feae817d25d3ffd97916f53c0183f88494a23c3","ref":"refs/heads/trunk","pushedAt":"2024-04-25T19:08:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: Rename RaftConfig to QuorumConfig (#15797)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Rename RaftConfig to QuorumConfig (#15797)"}},{"before":"8013657f5da99277e7a21177c77d2ef172792aee","after":"ce9026f597edfcdbcd8f3b4fe2a6701036462047","ref":"refs/heads/trunk","pushedAt":"2024-04-25T18:32:11.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"MINOR: Modified System.getProperty(\"line.separator\") to java.lang.System.lineSeparator() (#15782)\n\nReviewers: Igor Soarez , Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Modified System.getProperty(\"line.separator\") to java.lang.Sys…"}},{"before":"79c9d0de405fd62a9580dc68aa1df98ba1111395","after":"14626837b36c1ae7f757ffa4bcb6d19f8e101701","ref":"refs/heads/3.7","pushedAt":"2024-04-25T17:20:17.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"jolshan","name":"Justine Olshan","path":"/jolshan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/25566826?s=80&v=4"},"commit":{"message":"cherrypick KAFKA-16386: Convert NETWORK_EXCEPTIONs from KIP-890 transaction verification (#15755)\n\n* KAFKA-16386: Convert NETWORK_EXCEPTIONs from KIP-890 transaction verification (#15559)\r\n\r\nKIP-890 Part 1 introduced verification of transactions with the\r\ntransaction coordinator on the `Produce` and `TxnOffsetCommit` paths.\r\nThis introduced the possibility of new errors when responding to those\r\nrequests. For backwards compatibility with older clients, a choice was\r\nmade to convert some of the new retriable errors to existing errors that\r\nare expected and retried correctly by older clients.\r\n\r\n`NETWORK_EXCEPTION` was forgotten about and not converted, but can occur\r\nif, for example, the transaction coordinator is temporarily refusing\r\nconnections. Now, we convert it to:\r\n * `NOT_ENOUGH_REPLICAS` on the `Produce` path, just like the other\r\n retriable errors that can arise from transaction verification.\r\n * `COORDINATOR_LOAD_IN_PROGRESS` on the `TxnOffsetCommit` path. This\r\n error does not force coordinator lookup on clients, unlike\r\n `COORDINATOR_NOT_AVAILABLE`. Note that this deviates from KIP-890,\r\n which says that retriable errors should be converted to\r\n `COORDINATOR_NOT_AVAILABLE`.\r\n\r\nReviewers: Artem Livshits , David Jacot , Justine Olshan \r\n Conflicts:\r\n\tcore/src/main/scala/kafka/server/ReplicaManager.scala\r\n\tgroup-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java\r\n\tgroup-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorServiceTest.java\r\n\r\nThere were some conflicts in the how the code path changed. We have three paths.\r\n\r\n1. Produce -- In appendEntries we have the callback just for produce requests. I've included the error and the comment there.\r\n2. Old Group Coordinator -- In GroupMetadataManager, we handle the conversion in maybeConvertOffsetCommitError 3. This path is separate from the produce path.\r\nNew Group Coordinator -- Not supported in 3.7 so it is removed\r\n\r\n---------\r\n\r\nCo-authored-by: Sean Quah ","shortMessageHtmlLink":"cherrypick KAFKA-16386: Convert NETWORK_EXCEPTIONs from KIP-890 trans…"}},{"before":"0a6d5ff23cd3792ed6401f1fffa8189d0f2f05ca","after":"8013657f5da99277e7a21177c77d2ef172792aee","ref":"refs/heads/trunk","pushedAt":"2024-04-25T14:46:45.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16568: JMH Benchmarks for Server Side Rebalances (#15717)\n\nThis patch add three benchmarks for the client assignors, the server assignors and the target assignment builder.\r\n\r\nReviewers: David Jacot ","shortMessageHtmlLink":"KAFKA-16568: JMH Benchmarks for Server Side Rebalances (#15717)"}},{"before":"dc1d8fc330b35f517c8e939b80d6fab4244fa052","after":"0a6d5ff23cd3792ed6401f1fffa8189d0f2f05ca","ref":"refs/heads/trunk","pushedAt":"2024-04-25T14:45:01.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mimaison","name":"Mickael Maison","path":"/mimaison","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/903615?s=80&v=4"},"commit":{"message":"MINOR: Various cleanups in core (#15786)\n\n\r\nReviewers: Chia-Ping Tsai , Omnia Ibrahim ","shortMessageHtmlLink":"MINOR: Various cleanups in core (#15786)"}},{"before":"bed23b79788c31aaf4ec67db7097ec5ad4b84d07","after":"dc1d8fc330b35f517c8e939b80d6fab4244fa052","ref":"refs/heads/trunk","pushedAt":"2024-04-25T14:44:26.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-16554: Online downgrade triggering and group type conversion (#15721)\n\nOnline downgrade from a consumer group to a classic group is triggered when the last consumer that uses the consumer protocol leaves the group. A rebalance is manually triggered after the group conversion. This patch adds consumer group downgrade validation and conversion.\r\n\r\nReviewers: David Jacot ","shortMessageHtmlLink":"KAFKA-16554: Online downgrade triggering and group type conversion (#…"}},{"before":"dcdf8128807b661ac98bfefeea5425ef4770b8c3","after":"bed23b79788c31aaf4ec67db7097ec5ad4b84d07","ref":"refs/heads/trunk","pushedAt":"2024-04-25T14:10:30.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"jlprat","name":"Josep Prat","path":"/jlprat","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/3337739?s=80&v=4"},"commit":{"message":"MINOR: skip 'zinc' phase from gradle dependency-check plugin (#15054)\n\nThis avoids `gradle dependencyCheckAggregate` from reporting on\nadvisories in build-time dependencies (e.g. CVE-2023-46122) which\ntypically should not affect us.\n\nI checked that this does not prevent advisories in 'regular'\ndependencies from being reported (but there currently are none).\n\nReviewers: Josep Prat ","shortMessageHtmlLink":"MINOR: skip 'zinc' phase from gradle dependency-check plugin (#15054)"}},{"before":"4e23378aa811ae2aae0b7aa37ff9c5bb7c450fb0","after":"dcdf8128807b661ac98bfefeea5425ef4770b8c3","ref":"refs/heads/trunk","pushedAt":"2024-04-25T09:12:42.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lucasbru","name":"Lucas Brutschy","path":"/lucasbru","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1628637?s=80&v=4"},"commit":{"message":"KAFKA-16609: Update parse_describe_topic to support new topic describe output (#15799)\n\nThe format of the 'describe topic' output was changed as part of KAFKA-15585 which required an update in the parsing logic used by system tests.\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16609: Update parse_describe_topic to support new topic describ…"}},{"before":"864744ffd4ddc3b0d216a3049ee0c61e9c0d3ad1","after":"4e23378aa811ae2aae0b7aa37ff9c5bb7c450fb0","ref":"refs/heads/trunk","pushedAt":"2024-04-25T06:23:34.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"showuon","name":"Luke Chen","path":"/showuon","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/43372967?s=80&v=4"},"commit":{"message":"HOTFIX: make sure all ConsumerGroupServices get closed (#15801)\n\nSome services are not closed, so our CI print following error.\r\n\r\norg.opentest4j.AssertionFailedError: Found 16 unexpected threads during @BeforeAll: `kafka-admin-client-thread | adminclient-287,kafka-admin-client-thread | adminclient-276,kafka-admin-client-thread | adminclient-271,kafka-admin-client-thread | adminclient-293,kafka-admin-client-thread | adminclient-281,kafka-admin-client-thread | adminclient-302,kafka-admin-client-thread | adminclient-334,kafka-admin-client-thread | adminclient-323,kafka-admin-client-thread | adminclient-257,kafka-admin-client-thread | adminclient-336,kafka-admin-client-thread | adminclient-308,kafka-admin-client-thread | adminclient-263,kafka-admin-client-thread | adminclient-273,kafka-admin-client-thread | adminclient-278,kafka-admin-client-thread | adminclient-283,kafka-admin-client-thread | adminclient-317` ==> expected: but was: \r\n\r\n#15679 use AfterEach to release service. However, the test cases having multi consumerConfigs will create a lot of services in testing. Hence, the intermediate servers are not closed.\r\n\r\nReviewers: Luke Chen ","shortMessageHtmlLink":"HOTFIX: make sure all ConsumerGroupServices get closed (#15801)"}},{"before":"a7ceacdd35961b2c641880a262ad8f6778e8135d","after":"864744ffd4ddc3b0d216a3049ee0c61e9c0d3ad1","ref":"refs/heads/trunk","pushedAt":"2024-04-25T00:52:24.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"soarez","name":"Igor Soarez","path":"/soarez","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1357510?s=80&v=4"},"commit":{"message":"KAFKA-16610 Replace \"Map#entrySet#forEach\" by \"Map#forEach\" (#15795)\n\n\r\nReviewers: Apoorv Mittal , Igor Soarez ","shortMessageHtmlLink":"KAFKA-16610 Replace \"Map#entrySet#forEach\" by \"Map#forEach\" (#15795)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEPM_skQA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}