{"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:1725490577.0","currentOid":""},"activityList":{"items":[{"before":null,"after":"0b308b2f48bd8a2999bd3cf5407c9e81c203c736","ref":"refs/heads/gh-KAFKA-17479-relocate-xml-files","pushedAt":"2024-09-04T22:56:17.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"relocate junit XML files","shortMessageHtmlLink":"relocate junit XML files"}},{"before":"0294b1402d382dc628f42f6e41f093d4ee73ee98","after":"748d20200f9b06c2dfd7ef7df18bc42c83ef0516","ref":"refs/heads/trunk","pushedAt":"2024-09-04T20:31:59.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lianetm","name":"Lianet Magrans","path":"/lianetm","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/98415067?s=80&v=4"},"commit":{"message":"MINOR: Fix broken output layout of kafka-consumer-groups.sh (#17058)\n\nReviewers: Andrew Schofield , Lianet Magrans ","shortMessageHtmlLink":"MINOR: Fix broken output layout of kafka-consumer-groups.sh (#17058)"}},{"before":"59f5d91d8f1412c50c74a776a624879101402284","after":"0294b1402d382dc628f42f6e41f093d4ee73ee98","ref":"refs/heads/trunk","pushedAt":"2024-09-04T19:06:11.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"KAFKA-17479 Allow \":jar\" tasks to be cached [1/n] (#17066)\n\nFor several modules, we include a kafka-version.properties in the Jar file. This file includes the Git SHA of the project at the time of the build. This means that even if no source files change, the :jar task will never be UP-TO-DATE between two git commits. Ultimately, this breaks Gradle caching.\r\n\r\nThis patch marks all of the createVersionFile tasks as cacheable and also changes our Gradle invocation to override the commit ID to a dummy static value. This will allow the :jar task to be cacheable and reusable between builds.\r\n\r\nThis patch also configures the trunk build to only write to the build cache and not read from it. This will prevent any cache pollution/corruption from propagating from build to build.\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17479 Allow \":jar\" tasks to be cached [1/n] (#17066)"}},{"before":"1ddbcba161100df35725ebd3deee7f0677ea6385","after":null,"ref":"refs/heads/gh-ge-credential-expiry","pushedAt":"2024-09-04T14:51:10.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"}},{"before":"661825ad2801483f4c9f049673a89ca6686ba60b","after":"59f5d91d8f1412c50c74a776a624879101402284","ref":"refs/heads/trunk","pushedAt":"2024-09-04T13:17:00.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"MINOR increase develocity expiry to 4 hours (#17077)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR increase develocity expiry to 4 hours (#17077)"}},{"before":"005155ba5cad313d22fb84efc9959dd3fd484bf3","after":"661825ad2801483f4c9f049673a89ca6686ba60b","ref":"refs/heads/trunk","pushedAt":"2024-09-04T12:50:27.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"bbejeck","name":"Bill Bejeck","path":"/bbejeck","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/199238?s=80&v=4"},"commit":{"message":"KAFKA-16993: Flaky test shouldInvokeUserDefinedGlobalStateRestoreListener (#16970)\n\nIncreased the number of records while decreasing the restore batch size to ensure the restoration does not complete before the second Kafka Streams instance starts up.\r\n\r\nReviewers: Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-16993: Flaky test shouldInvokeUserDefinedGlobalStateRestoreList…"}},{"before":"5fd7ce2ace1e0418df033dd32a470d4306a211ea","after":"005155ba5cad313d22fb84efc9959dd3fd484bf3","ref":"refs/heads/trunk","pushedAt":"2024-09-04T09:04:40.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":"KAFKA-17406: Move ClientIdAndBroker to server-common module (#16967)\n\n\r\nReviewers: Mickael Maison , David Arthur ","shortMessageHtmlLink":"KAFKA-17406: Move ClientIdAndBroker to server-common module (#16967)"}},{"before":"f0f37409be5fe2610f988c04a96ea8a7483e8100","after":"5fd7ce2ace1e0418df033dd32a470d4306a211ea","ref":"refs/heads/trunk","pushedAt":"2024-09-04T08:12:20.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-17414 Move RequestLocal to server-common module (#16986)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17414 Move RequestLocal to server-common module (#16986)"}},{"before":"28f5ff6039be9c75f7d53e4119613acd4517ce55","after":"14e1ebee9e79f9f5950bbc0a730442a6ff97c160","ref":"refs/heads/3.9","pushedAt":"2024-09-04T07:56:21.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"chia7712","name":"Chia-Ping Tsai","path":"/chia7712","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6234750?s=80&v=4"},"commit":{"message":"KAFKA-17454 Fix failed transactions_mixed_versions_test.py when running with 3.2 (#17067)\n\nwhy https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e does not fix it?\r\n\r\nThe fix of https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e is to NOT collect the log from path `/mnt/kafka/kafka-operational-logs/debug/xxxx.log`if the task is successful. It does not change the log level. see ducktape https://github.com/confluentinc/ducktape/blob/b2ad7693f2750a2286a5099882ecc774fd7138b2/ducktape/tests/test.py#L181\r\n\r\nwhy https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e does not see the error of \"sort\"\r\n\r\nhttps://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e does NOT show the error since the number of features is only \"one\" (only metadata.version). Hence, the bug is not triggered as it does not need to \"sort\". Now, we have two features - metadata.version and krafe.version - so the sort is executed and then we see the \"hello bug\"\r\n\r\nwhy we should change the kafka.log_level to INFO?\r\n\r\nthe template of log4j.properties is controlled by `log_level` (https://github.com/apache/kafka/blob/trunk/tests/kafkatest/services/kafka/templates/log4j.properties#L16), and the bug happens in writing debug message (https://github.com/apache/kafka/blob/e4ca066680296ea29d443efb626baecc837083f6/core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala#L274). Hence, changing the log level to DEBUG can avoid triggering the bug.\r\n\r\nReviewers: Justine Olshan , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17454 Fix failed transactions_mixed_versions_test.py when runni…"}},{"before":"32f03a06be32e56cd2e4a6527482713bd35cac42","after":"f0f37409be5fe2610f988c04a96ea8a7483e8100","ref":"refs/heads/trunk","pushedAt":"2024-09-04T07:09:03.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-17454 Fix failed transactions_mixed_versions_test.py when running with 3.2 (#17067)\n\nwhy https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e does not fix it?\r\n\r\nThe fix of https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e is to NOT collect the log from path `/mnt/kafka/kafka-operational-logs/debug/xxxx.log`if the task is successful. It does not change the log level. see ducktape https://github.com/confluentinc/ducktape/blob/b2ad7693f2750a2286a5099882ecc774fd7138b2/ducktape/tests/test.py#L181\r\n\r\nwhy https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e does not see the error of \"sort\"\r\n\r\nhttps://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e does NOT show the error since the number of features is only \"one\" (only metadata.version). Hence, the bug is not triggered as it does not need to \"sort\". Now, we have two features - metadata.version and krafe.version - so the sort is executed and then we see the \"hello bug\"\r\n\r\nwhy we should change the kafka.log_level to INFO?\r\n\r\nthe template of log4j.properties is controlled by `log_level` (https://github.com/apache/kafka/blob/trunk/tests/kafkatest/services/kafka/templates/log4j.properties#L16), and the bug happens in writing debug message (https://github.com/apache/kafka/blob/e4ca066680296ea29d443efb626baecc837083f6/core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala#L274). Hence, changing the log level to DEBUG can avoid triggering the bug.\r\n\r\nReviewers: Justine Olshan , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17454 Fix failed transactions_mixed_versions_test.py when runni…"}},{"before":"19e8c447a63c6090da2d8fa303b095ce0438cc1d","after":"32f03a06be32e56cd2e4a6527482713bd35cac42","ref":"refs/heads/trunk","pushedAt":"2024-09-04T06:48:52.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-17474 fix state transition in GlobalStreamThread (#17078)\n\nKAFKA-17100 changed the behavior of GlobalStreamThread introducing a race condition for state changes, that was exposed by failing (flaky) tests in GlobalStreamThreadTest.\r\n\r\nThis PR moves the state transition to fix the race condition.\r\n\r\nReviewers: Bill Bejeck , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17474 fix state transition in GlobalStreamThread (#17078)"}},{"before":"eb9cfb06c0d7954a6c8d70dac6e835800aca4aab","after":"19e8c447a63c6090da2d8fa303b095ce0438cc1d","ref":"refs/heads/trunk","pushedAt":"2024-09-04T04:08:38.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-17137 Ensure Admin APIs are properly tested (consumer group and quota) (#16717)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17137 Ensure Admin APIs are properly tested (consumer group and…"}},{"before":"a954ad1c67ce213d40cb20c64b90b39e451645d9","after":"28f5ff6039be9c75f7d53e4119613acd4517ce55","ref":"refs/heads/3.9","pushedAt":"2024-09-03T23:12:27.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-17412: add doc for `unclean.leader.election.enable` in KRaft (#17051)\n\nReviewers: Colin P. McCabe ","shortMessageHtmlLink":"KAFKA-17412: add doc for unclean.leader.election.enable in KRaft (#…"}},{"before":"edac19ba503762aece76ee2e97068177d27336c5","after":"eb9cfb06c0d7954a6c8d70dac6e835800aca4aab","ref":"refs/heads/trunk","pushedAt":"2024-09-03T23:11:47.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":"KAFKA-17412: add doc for `unclean.leader.election.enable` in KRaft (#17051)\n\nReviewers: Colin P. McCabe ","shortMessageHtmlLink":"KAFKA-17412: add doc for unclean.leader.election.enable in KRaft (#…"}},{"before":"4d23fe92f18e5f9ec906daa09d658d1bba4a7d11","after":"edac19ba503762aece76ee2e97068177d27336c5","ref":"refs/heads/trunk","pushedAt":"2024-09-03T22:48:36.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":"KAFKA-17277: [1/2] Add version mapping command to the storage tool and feature command tool (#16973)\n\nAs a part of KIP-1022 the following has been implemented in this patch:\r\n\r\nA version-mapping command to to look up the corresponding features for a given metadata version. Using the command with no --release-version argument will return the mapping for the latest stable metadata version.\r\nThis command has been added to the FeatureCommand Tool and the Storage Tool.\r\nThe storage tools parsing method has been made more modular similar to the feature command tool\r\n\r\nReviewers: Justine Olshan ","shortMessageHtmlLink":"KAFKA-17277: [1/2] Add version mapping command to the storage tool an…"}},{"before":"b0d0956b20735575b7d4d870c2838912f4006940","after":"4d23fe92f18e5f9ec906daa09d658d1bba4a7d11","ref":"refs/heads/trunk","pushedAt":"2024-09-03T20:13:33.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":"KAFKA-16928: Test all of the request and response methods in RaftUtil (#16517)\n\nReviewers: Colin P. McCabe ","shortMessageHtmlLink":"KAFKA-16928: Test all of the request and response methods in RaftUtil ("}},{"before":"57b6c2ef98d8177ab0e43f7653c8079d4daa8789","after":"c7c3e609c009b05c29a1032a21103411c5ea1e10","ref":"refs/heads/3.7","pushedAt":"2024-09-03T19:34:35.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lianetm","name":"Lianet Magrans","path":"/lianetm","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/98415067?s=80&v=4"},"commit":{"message":"Back-port KAFKA-16230 to 3.7 branch (#16951)\n\nReviewers: Andrew Schofield , Lianet Magrans ","shortMessageHtmlLink":"Back-port KAFKA-16230 to 3.7 branch (#16951)"}},{"before":"b8ea409132366221b1c77d4f76815cc1d3260480","after":"b0d0956b20735575b7d4d870c2838912f4006940","ref":"refs/heads/trunk","pushedAt":"2024-09-03T18:46:15.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"omkreddy","name":"Manikumar Reddy","path":"/omkreddy","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8134545?s=80&v=4"},"commit":{"message":"KAFKA-17425: Improve coexistence of consumer and share groups (#17039)\n\nThis PR ensures that using the various group RPCs work properly when issued against the wrong type of group, such as DescribeConsumerGroups for a share group, or ConsumerGroupHeartbeat for a share group. There are no changes to the RPC error codes required.\r\n\r\nThe significant code changes are:\r\n\r\nMaking sure that the group coordinator does not assume that only classic and consumer groups exist. This was the cause of a ClassCastException when ConsumerGroupHeartbeat was being used against a share group.\r\nMaking sure that committing offsets to a share group fails with GroupIdNotFoundException rather than java.lang.UnsupportedOperation. This was the cause of a name collision between a share group and a consumer group when using kafka-consumer-groups.sh --reset-offsets which inadvertently created a consumer group of the same name.\r\n\r\n Reviewers: Manikumar Reddy ","shortMessageHtmlLink":"KAFKA-17425: Improve coexistence of consumer and share groups (#17039)"}},{"before":"839431e59170f162fb0da665f145919edfb16ea7","after":"b8ea409132366221b1c77d4f76815cc1d3260480","ref":"refs/heads/trunk","pushedAt":"2024-09-03T18:37:54.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: Log when a consumer group is created by the admin client (#17073)\n\nReviewers: David Jacot , Andrew Schofield , Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Log when a consumer group is created by the admin client (#17073)"}},{"before":"528e976903f3c1e46d2acbc0ef051a318decac54","after":"1ddbcba161100df35725ebd3deee7f0677ea6385","ref":"refs/heads/gh-ge-credential-expiry","pushedAt":"2024-09-03T18:34:19.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"no string needed","shortMessageHtmlLink":"no string needed"}},{"before":null,"after":"528e976903f3c1e46d2acbc0ef051a318decac54","ref":"refs/heads/gh-ge-credential-expiry","pushedAt":"2024-09-03T18:32:18.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"increase develocity expiry to 4 hours","shortMessageHtmlLink":"increase develocity expiry to 4 hours"}},{"before":"88b9ff30adf19ba43072a8b26ede07aa4bfa727d","after":"839431e59170f162fb0da665f145919edfb16ea7","ref":"refs/heads/trunk","pushedAt":"2024-09-03T18:18:47.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-17468 Move kafka/log/remote/quota classes to storage module (#17074)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17468 Move kafka/log/remote/quota classes to storage module (#1…"}},{"before":"2f9b23625917fed841a176a73bbbc02bfa330a2d","after":"88b9ff30adf19ba43072a8b26ede07aa4bfa727d","ref":"refs/heads/trunk","pushedAt":"2024-09-03T15:06:01.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-15859 Introduce remote.list.offsets.request.timeout.ms dynamic config (#17045)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-15859 Introduce remote.list.offsets.request.timeout.ms dynamic …"}},{"before":null,"after":"4dc1435fa635a85721f28a381427d8a9434cc7ab","ref":"refs/heads/gh-deflake-testMigrateTopicDeletions-2","pushedAt":"2024-09-03T13:50:47.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"increase logging","shortMessageHtmlLink":"increase logging"}},{"before":"6c997a38356412292e41b0d5d10a583c193768f7","after":"c292b43f1fe209f1d20e068e229e2049e07704d5","ref":"refs/heads/gh-deflake-testMigrateTopicDeletions","pushedAt":"2024-09-03T13:37:56.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"Revert \"increase logging\"\n\nThis reverts commit 6c997a38356412292e41b0d5d10a583c193768f7.","shortMessageHtmlLink":"Revert \"increase logging\""}},{"before":"f59d829381a7021971b0b2835fbbacb4abd996a5","after":"2f9b23625917fed841a176a73bbbc02bfa330a2d","ref":"refs/heads/trunk","pushedAt":"2024-09-03T11:05: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-17294 Handle retriable errors when fetching offsets in new consumer (#16833)\n\nThe original behavior was implemented to maintain the behavior of the Classic consumer, where the ConsumerCoordinator would do the same when handling the OffsetFetchResponse. This behavior is being updated for the legacy coordinator as part of KAFKA-17279, to retry on all retriable errors.\r\n\r\nWe should review and update the CommitRequestManager to align with this, and retry on all retriable errors, which seems sensible when fetching offsets.\r\n\r\nThe corresponding PR for classic consumer is #16826\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17294 Handle retriable errors when fetching offsets in new cons…"}},{"before":"c30615e6d7732b0214d59985ee5961bc9266b364","after":"f59d829381a7021971b0b2835fbbacb4abd996a5","ref":"refs/heads/trunk","pushedAt":"2024-09-03T10:24:12.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 TransactionLogConfig and TransactionStateManagerConfig getters out of KafkaConfig (#16665)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-15853 Move TransactionLogConfig and TransactionStateManagerConf…"}},{"before":"743e185c8bf6d1d548fe7041ce543c7c31388e68","after":"c30615e6d7732b0214d59985ee5961bc9266b364","ref":"refs/heads/trunk","pushedAt":"2024-09-03T08:11:47.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":"KAFKA-17430: Move RequestChannel.Metrics/RequestMetrics to server module (#17015)\n\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17430: Move RequestChannel.Metrics/RequestMetrics to server mod…"}},{"before":"359ddce3b2ce9288389751f5a64a965db9bf12be","after":"743e185c8bf6d1d548fe7041ce543c7c31388e68","ref":"refs/heads/trunk","pushedAt":"2024-09-03T03:31:49.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-17450 Reduced the handlers for handling ShareAcknowledgeResponse (#17061)\n\nCurrently there are 4 handler functions present for handling ShareAcknowledge responses. ShareConsumeRequestManager had an interface and the respective handlers would implement it. Instead of having 4 different handlers for this, now using AcknowledgeRequestType, we could merge the code and have only 2 handler functions, one for ShareAcknowledge success and one for ShareAcknowledge failure, eliminating the need for the interface.\r\n\r\nThis PR also fixes a bug - We were not using the time at which the response was received while handling the ShareAcknowledge response, we were using an outdated time. Now the bug is fixed.\r\n\r\nReviewers: Manikumar Reddy , Andrew Schofield , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-17450 Reduced the handlers for handling ShareAcknowledgeResponse ("}},{"before":"498711e3acc48072e7a9bce264a40e48c9e882ac","after":"6c997a38356412292e41b0d5d10a583c193768f7","ref":"refs/heads/gh-deflake-testMigrateTopicDeletions","pushedAt":"2024-09-02T18:05:05.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mumrah","name":"David Arthur","path":"/mumrah","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55116?s=80&v=4"},"commit":{"message":"increase logging","shortMessageHtmlLink":"increase logging"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAErTs9kwA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}