{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":736695862,"defaultBranch":"trunk","name":"kafka","ownerLogin":"ghostspiders","currentUserCanPush":false,"isFork":true,"isEmpty":false,"createdAt":"2023-12-28T15:58:12.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/30502753?v=4","public":true,"private":false,"isOrgOwned":false},"refInfo":{"name":"","listCacheKey":"v0:1709747082.0","currentOid":""},"activityList":{"items":[{"before":"2f1c07b78e3cff953d31760ae70462af9a2f7090","after":"b2ad836a2c18b536dde54eca1704f3e0dcb1fc15","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-10T18:08:35.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"kraft","shortMessageHtmlLink":"kraft"}},{"before":"91c080eed49afe0854661e2ec1995239486ec410","after":"2f1c07b78e3cff953d31760ae70462af9a2f7090","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-10T17:33:32.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"kraft","shortMessageHtmlLink":"kraft"}},{"before":"6cc0619a1e609fc880025e962a90cf832ae36c9d","after":"91c080eed49afe0854661e2ec1995239486ec410","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-10T14:01:20.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KRaft support in BaseAdminIntegrationTest","shortMessageHtmlLink":"KRaft support in BaseAdminIntegrationTest"}},{"before":"0fa5207c3da70223c1c341b7204a4b690a571d03","after":"6cc0619a1e609fc880025e962a90cf832ae36c9d","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-10T13:50:48.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KRaft support in BaseAdminIntegrationTest","shortMessageHtmlLink":"KRaft support in BaseAdminIntegrationTest"}},{"before":"73f2af1f3ce4e4bd176a39f36d34ecadaded0803","after":"0fa5207c3da70223c1c341b7204a4b690a571d03","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-10T09:35:49.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"kraft","shortMessageHtmlLink":"kraft"}},{"before":"bb57804057df08fa46df6cec20c2e22450675410","after":"73f2af1f3ce4e4bd176a39f36d34ecadaded0803","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-09T17:19:30.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"kraft","shortMessageHtmlLink":"kraft"}},{"before":"bc0c73e944af69966c43d51d20417b441aa0f3f5","after":"bb57804057df08fa46df6cec20c2e22450675410","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-06T18:16:11.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KRaft support in BaseAdminIntegrationTest","shortMessageHtmlLink":"KRaft support in BaseAdminIntegrationTest"}},{"before":"bc0c73e944af69966c43d51d20417b441aa0f3f5","after":null,"ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTestKAFKA-15751","pushedAt":"2024-03-06T17:44:42.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"}},{"before":null,"after":"bc0c73e944af69966c43d51d20417b441aa0f3f5","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTest:KAFKA-15751","pushedAt":"2024-03-06T17:44:41.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-16322 upgrade jline from 3.22.0 to 3.25.1 (#15464)\n\nAn issue in the component \"GroovyEngine.execute\" of jline-groovy versions through 3.24.1 allows attackers to cause an OOM (OutofMemory) error. Please refer to https://devhub.checkmarx.com/cve-details/CVE-2023-50572 for more details\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16322 upgrade jline from 3.22.0 to 3.25.1 (apache#15464)"}},{"before":null,"after":"bc0c73e944af69966c43d51d20417b441aa0f3f5","ref":"refs/heads/KRaft-support-in-BaseAdminIntegrationTestKAFKA-15751","pushedAt":"2024-03-06T17:25:10.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-16322 upgrade jline from 3.22.0 to 3.25.1 (#15464)\n\nAn issue in the component \"GroovyEngine.execute\" of jline-groovy versions through 3.24.1 allows attackers to cause an OOM (OutofMemory) error. Please refer to https://devhub.checkmarx.com/cve-details/CVE-2023-50572 for more details\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16322 upgrade jline from 3.22.0 to 3.25.1 (apache#15464)"}},{"before":"4c012c5c23b9b5031f4cfbf932ba399afd72e156","after":"bc0c73e944af69966c43d51d20417b441aa0f3f5","ref":"refs/heads/trunk","pushedAt":"2024-03-06T17:23:21.000Z","pushType":"push","commitsCount":52,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-16322 upgrade jline from 3.22.0 to 3.25.1 (#15464)\n\nAn issue in the component \"GroovyEngine.execute\" of jline-groovy versions through 3.24.1 allows attackers to cause an OOM (OutofMemory) error. Please refer to https://devhub.checkmarx.com/cve-details/CVE-2023-50572 for more details\r\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16322 upgrade jline from 3.22.0 to 3.25.1 (apache#15464)"}},{"before":"77ba06fa620ad9cc42af92f42354661308676135","after":"5b997aa290746920f5b5cab31514a3d96cef3843","ref":"refs/heads/Fix-CoreUtils.swallow()-test-gaps","pushedAt":"2024-02-21T15:30:53.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-15610: Fix CoreUtils.swallow() test gaps","shortMessageHtmlLink":"KAFKA-15610: Fix CoreUtils.swallow() test gaps"}},{"before":"77ba06fa620ad9cc42af92f42354661308676135","after":"4c012c5c23b9b5031f4cfbf932ba399afd72e156","ref":"refs/heads/trunk","pushedAt":"2024-02-21T14:45:06.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-16278: Missing license for scala related dependencies (#15398)\n\nReviewers: Divij Vaidya ","shortMessageHtmlLink":"KAFKA-16278: Missing license for scala related dependencies (apache#1…"}},{"before":null,"after":"77ba06fa620ad9cc42af92f42354661308676135","ref":"refs/heads/Fix-CoreUtils.swallow()-test-gaps","pushedAt":"2024-02-21T14:39:38.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-16033: Commit retry logic fixes (#15357)\n\nThis change modifies the commit manager for improved retry logic & fixing bugs:\r\n\r\n- defines high level functions for each of the different types of commit: commitSync, commitAsync, autoCommitSync (used from consumer close), autoCommitAsync (on interval), autoCommitNow (before revocation).\r\n - moves retry logic to these caller functions, keeping a common response error handling that propagates errors that each caller functions retry as it needs.\r\n\r\nFixes the following issues:\r\n\r\n- auto-commit before revocation should retry with latest consumed offsets\r\n- auto-commit before revocation should only reset the timer once, when the rebalance completes\r\n- StaleMemberEpoch error (fatal) is considered retriable only when committing offsets before revocation, where it is retried with backoff if the member has a valid epoch. All other commits will fail fatally on stale epoch. Note that auto commit on the interval (autoCommitAsync) does not have any specific retry logic for the stale epoch, but will effectively retry on the next interval (as it does for any other fatal error)\r\n- fix duplicated and noisy logs for auto-commit\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16033: Commit retry logic fixes (apache#15357)"}},{"before":"71a4e6fc0ce43e907c320ed5afca95b84620b0e8","after":"77ba06fa620ad9cc42af92f42354661308676135","ref":"refs/heads/trunk","pushedAt":"2024-02-21T10:11:17.000Z","pushType":"push","commitsCount":11,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-16033: Commit retry logic fixes (#15357)\n\nThis change modifies the commit manager for improved retry logic & fixing bugs:\r\n\r\n- defines high level functions for each of the different types of commit: commitSync, commitAsync, autoCommitSync (used from consumer close), autoCommitAsync (on interval), autoCommitNow (before revocation).\r\n - moves retry logic to these caller functions, keeping a common response error handling that propagates errors that each caller functions retry as it needs.\r\n\r\nFixes the following issues:\r\n\r\n- auto-commit before revocation should retry with latest consumed offsets\r\n- auto-commit before revocation should only reset the timer once, when the rebalance completes\r\n- StaleMemberEpoch error (fatal) is considered retriable only when committing offsets before revocation, where it is retried with backoff if the member has a valid epoch. All other commits will fail fatally on stale epoch. Note that auto commit on the interval (autoCommitAsync) does not have any specific retry logic for the stale epoch, but will effectively retry on the next interval (as it does for any other fatal error)\r\n- fix duplicated and noisy logs for auto-commit\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16033: Commit retry logic fixes (apache#15357)"}},{"before":"e247bd03afe66d61426a9029220d06438dede3dc","after":"71a4e6fc0ce43e907c320ed5afca95b84620b0e8","ref":"refs/heads/trunk","pushedAt":"2024-02-19T14:27:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-15140: improve TopicCommandIntegrationTest to be less flaky (#14891)\n\nThis PR improves TopicCommandIntegrationTest by :\r\n - using TestUtils.createTopicWithAdmin\r\n - replacing \\n with lineSeperator\r\n - using waitForAllReassignmentsToComplete\r\n - adding more log when assertion fails\r\n\r\nReviewers: Luke Chen , Justine Olshan ","shortMessageHtmlLink":"KAFKA-15140: improve TopicCommandIntegrationTest to be less flaky (ap…"}},{"before":"d233eb98f7c7e55fe0dd673dbc058ddf619663a7","after":"e247bd03afe66d61426a9029220d06438dede3dc","ref":"refs/heads/trunk","pushedAt":"2024-02-18T17:10:11.000Z","pushType":"push","commitsCount":28,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"MINOR: Improve ListConsumerGroupTest.testListGroupCommand (#15382)\n\nWhile reviewing https://github.com/apache/kafka/pull/15150, I found that our tests verifying the console output are really hard to read. Here is my proposal to make it better.\r\n\r\nReviewers: Ritika Reddy , Justine Olshan ","shortMessageHtmlLink":"MINOR: Improve ListConsumerGroupTest.testListGroupCommand (apache#15382)"}},{"before":"d233eb98f7c7e55fe0dd673dbc058ddf619663a7","after":"b5cb06c5be402d834290f84a6709a9fb46d3ea13","ref":"refs/heads/KAFKA-16239-Clean-up-IntegrationTestHelper","pushedAt":"2024-02-12T05:13:37.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"Clean up references to non-existent IntegrationTestHelper","shortMessageHtmlLink":"Clean up references to non-existent IntegrationTestHelper"}},{"before":null,"after":"d233eb98f7c7e55fe0dd673dbc058ddf619663a7","ref":"refs/heads/KAFKA-16239-Clean-up-IntegrationTestHelper","pushedAt":"2024-02-12T05:11:40.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-14957: Update-Description-String (#13909)\n\nHTML code for configs is auto-generated and for Kafka Streams config `state.dir` produces a confusing default value.\r\nThis PR adds a new property `alternativeString` to set a \"default\" value which should be rendered in HTML instead of the actual default value.\r\n\r\nReviewers: Manyanda Chitimbo , @eziosudo , Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-14957: Update-Description-String (apache#13909)"}},{"before":"92a67e8571500a53cc864ba6df4cb9cfdac6a763","after":"d233eb98f7c7e55fe0dd673dbc058ddf619663a7","ref":"refs/heads/trunk","pushedAt":"2024-02-12T04:26:32.000Z","pushType":"push","commitsCount":92,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-14957: Update-Description-String (#13909)\n\nHTML code for configs is auto-generated and for Kafka Streams config `state.dir` produces a confusing default value.\r\nThis PR adds a new property `alternativeString` to set a \"default\" value which should be rendered in HTML instead of the actual default value.\r\n\r\nReviewers: Manyanda Chitimbo , @eziosudo , Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-14957: Update-Description-String (apache#13909)"}},{"before":"a8203f9c7a2c449ee59ee29d775409b2f1e00d07","after":"92a67e8571500a53cc864ba6df4cb9cfdac6a763","ref":"refs/heads/trunk","pushedAt":"2024-01-20T09:20:45.000Z","pushType":"push","commitsCount":42,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"Note that Java 11 support for broker and tools is deprecated for removal in 4.0 (#15236)\n\nReviewers: Divij Vaidya ","shortMessageHtmlLink":"Note that Java 11 support for broker and tools is deprecated for remo…"}},{"before":"22ff1acde72c461ff6a211b40ee57b696036c57a","after":"a8203f9c7a2c449ee59ee29d775409b2f1e00d07","ref":"refs/heads/trunk","pushedAt":"2024-01-11T13:02:25.000Z","pushType":"push","commitsCount":55,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"KAFKA-14505; [4/N] Wire transaction verification (#15142)\n\nThis patch wires the transaction verification in the new group coordinator. It basically calls the verification path before scheduling the write operation. If the verification fails, the error is returned to the caller.\r\n\r\nNote that the patch uses `appendForGroup`. I suppose that we will move away from using it when https://github.com/apache/kafka/pull/15087 is merged.\r\n\r\nReviewers: Justine Olshan ","shortMessageHtmlLink":"KAFKA-14505; [4/N] Wire transaction verification (apache#15142)"}},{"before":"a465fb124f95d86e87238fe2f431df7bcb01e8ef","after":"22ff1acde72c461ff6a211b40ee57b696036c57a","ref":"refs/heads/trunk","pushedAt":"2023-12-30T12:05:37.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"ghostspiders","name":null,"path":"/ghostspiders","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/30502753?s=80&v=4"},"commit":{"message":"MINOR: Close MockitoStatic in try-with-resource (#15095)\n\nMinor code cleanup to use try-with-resource so that there is no leak in case an exception is thrown before closing mocks.\r\n\r\nReviewers: Sagar Rao , Luke Chen ","shortMessageHtmlLink":"MINOR: Close MockitoStatic in try-with-resource (apache#15095)"}}],"hasNextPage":false,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEEZk0fAA","startCursor":null,"endCursor":null}},"title":"Activity · ghostspiders/kafka"}