{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":577465304,"defaultBranch":"trunk","name":"kafka","ownerLogin":"CalvinConfluent","currentUserCanPush":false,"isFork":true,"isEmpty":false,"createdAt":"2022-12-12T19:55:39.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/83986057?v=4","public":true,"private":false,"isOrgOwned":false},"refInfo":{"name":"","listCacheKey":"v0:1716570521.0","currentOid":""},"activityList":{"items":[{"before":"0f0c9ecbf330923ad653cc2ff4fca6c4dced1cf7","after":"92614699e6e64a631bf1f4ea35f4ff28bf17e4c9","ref":"refs/heads/trunk","pushedAt":"2024-06-13T22:59:19.000Z","pushType":"push","commitsCount":183,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"MINOR: update Kafka Streams docs with 3.3 KIP information (#16316)\n\nReviewers: Lucas Brutschy <lbrutschy@confluent.io>, Jim Galasyn <jim.galasyn@confluent.io>","shortMessageHtmlLink":"MINOR: update Kafka Streams docs with 3.3 KIP information (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2349967214\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16316\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16316/hovercard\" href=\"https://github.com/apache/kafka/pull/16316\">apache#16316</a>)"}},{"before":"4681c28946b7c5a000c6dad04456e30150fc2c27","after":"a389c1a07233f7315acb48bc586ed4cd62ac9707","ref":"refs/heads/producer-id-perf-improvement","pushedAt":"2024-05-29T17:46:49.000Z","pushType":"push","commitsCount":31,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Merge branch 'trunk' into producer-id-perf-improvement","shortMessageHtmlLink":"Merge branch 'trunk' into producer-id-perf-improvement"}},{"before":"0143c72e501afd76f89c2da9e4537be5ea11d4a0","after":"0f0c9ecbf330923ad653cc2ff4fca6c4dced1cf7","ref":"refs/heads/trunk","pushedAt":"2024-05-29T17:26:27.000Z","pushType":"push","commitsCount":30,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"KAFKA-16771 First log directory printed twice when formatting storage (#16010)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"KAFKA-16771 First log directory printed twice when formatting storage (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2307178114\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16010\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16010/hovercard\" href=\"https://github.com/apache/kafka/pull/16010\">…</a>"}},{"before":"a2e5359486f063284311d93f52ee0695e428c338","after":"4681c28946b7c5a000c6dad04456e30150fc2c27","ref":"refs/heads/producer-id-perf-improvement","pushedAt":"2024-05-28T23:14:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Address comment","shortMessageHtmlLink":"Address comment"}},{"before":"f2fec499ea4bea92128e3c49593dcbcdb7015dc4","after":"bebdaf00f0255c43b4b545d7219fc66135609b19","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-05-28T05:17:19.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Fix the bug for config removal","shortMessageHtmlLink":"Fix the bug for config removal"}},{"before":"b2fd6890735a07339de4fe701b8b7958e08cb5b8","after":"a2e5359486f063284311d93f52ee0695e428c338","ref":"refs/heads/producer-id-perf-improvement","pushedAt":"2024-05-24T18:31:01.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Minor","shortMessageHtmlLink":"Minor"}},{"before":"3ad1be51d72102be5e874ac531197159f9367a82","after":"b2fd6890735a07339de4fe701b8b7958e08cb5b8","ref":"refs/heads/producer-id-perf-improvement","pushedAt":"2024-05-24T17:09:26.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Minor","shortMessageHtmlLink":"Minor"}},{"before":null,"after":"3ad1be51d72102be5e874ac531197159f9367a82","ref":"refs/heads/producer-id-perf-improvement","pushedAt":"2024-05-24T17:08:41.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Improve producer ID expiration performance","shortMessageHtmlLink":"Improve producer ID expiration performance"}},{"before":"1b301b30207ed8fca9f0aea5cf940b0353a1abca","after":"0143c72e501afd76f89c2da9e4537be5ea11d4a0","ref":"refs/heads/trunk","pushedAt":"2024-05-24T16:42:17.000Z","pushType":"push","commitsCount":203,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"KAFKA-16815: Handle FencedInstanceId in HB response (#16047)\n\nHandle FencedInstanceIdException that a consumer may receive in the heartbeat response. This will be the case when a static consumer is removed from the group by and admin client, and another member joins with the same group.instance.id (allowed in). The first member will receive a FencedInstanceId on its next heartbeat. The expectation is that this should be handled as a fatal error.\r\n\r\nThere are no actual changes in logic with this PR, given that without being handled, the FencedInstanceId was being treated as an \"unexpected error\", which are all treated as fatal errors, so the outcome remains the same. But we're introducing this small change just for accuracy in the logic and the logs: FencedInstanceId is expected during heartbeat, a log line is shown describing the situation and why it happened (and it's treated as a fatal error, just like it was before this PR).\r\n\r\nThis PR also improves the test to ensure that the error propagated to the app thread matches the one received in the HB.\r\n\r\nReviewers: Andrew Schofield <aschofield@confluent.io>, David Jacot <djacot@confluent.io>","shortMessageHtmlLink":"KAFKA-16815: Handle FencedInstanceId in HB response (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2313075614\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/16047\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/16047/hovercard\" href=\"https://github.com/apache/kafka/pull/16047\">apache#16047</a>)"}},{"before":"16830b712c0156c2ccd5474dddf2cda04846de99","after":"d66983c40245c75ff91a51aa882c051fc3aeb89b","ref":"refs/heads/ELR-system-test","pushedAt":"2024-05-15T23:49:23.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Address comments","shortMessageHtmlLink":"Address comments"}},{"before":"bbc9956b97bfdda25b4f78034a22e07061c97b45","after":"f2fec499ea4bea92128e3c49593dcbcdb7015dc4","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-05-09T00:14:46.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Using a ordered resolver to get the pending config","shortMessageHtmlLink":"Using a ordered resolver to get the pending config"}},{"before":"3a232a93f3c673c533ae4452c38833c57a9084eb","after":"bbc9956b97bfdda25b4f78034a22e07061c97b45","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-04-29T17:01:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Testing legacyAlterConfig","shortMessageHtmlLink":"Testing legacyAlterConfig"}},{"before":"6d8b17c0a3631d819e7135335f4b3335442a8445","after":"52b468fdc570f4f21a204f19514a153fad3deb00","ref":"refs/heads/KAFKA-14563-2","pushedAt":"2024-04-24T17:47:57.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Reset kafka api","shortMessageHtmlLink":"Reset kafka api"}},{"before":"418e022eb6260e5bea1f0c8aa27402aae37b20c1","after":"6d8b17c0a3631d819e7135335f4b3335442a8445","ref":"refs/heads/KAFKA-14563-2","pushedAt":"2024-04-24T17:45:31.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Add Produce UT","shortMessageHtmlLink":"Add Produce UT"}},{"before":null,"after":"fc5a1307d402e9be64bc45c760c3108854fd88e3","ref":"refs/heads/cp-kafka-16217-3-7","pushedAt":"2024-04-23T21:58:26.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"KAFKA-16217: Stop the abort transaction try loop when closing producers (#15541)\n\nThis is a mitigation fix for the https://issues.apache.org/jira/browse/KAFKA-16217. Exceptions should not block closing the producers.\r\nThis PR reverts a part of the change #13591\r\n\r\nReviewers: Kirk True <ktrue@confluent.io>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"KAFKA-16217: Stop the abort transaction try loop when closing produce…"}},{"before":null,"after":"9c45353380b7087035787a473699a881df03ee36","ref":"refs/heads/cp-kafka-16217-3-6","pushedAt":"2024-04-23T21:56:54.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"KAFKA-16217: Stop the abort transaction try loop when closing producers (#15541)\n\nThis is a mitigation fix for the https://issues.apache.org/jira/browse/KAFKA-16217. Exceptions should not block closing the producers.\nThis PR reverts a part of the change #13591\n\nReviewers: Kirk True <ktrue@confluent.io>, Justine Olshan <jolshan@confluent.io>","shortMessageHtmlLink":"KAFKA-16217: Stop the abort transaction try loop when closing produce…"}},{"before":"f22ad6645bfec0b38e820e0090261c9f6b421a74","after":"1b301b30207ed8fca9f0aea5cf940b0353a1abca","ref":"refs/heads/trunk","pushedAt":"2024-04-23T18:46:16.000Z","pushType":"push","commitsCount":20,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"KAFKA-15853 Move socket configs into org.apache.kafka.network.SocketServerConfigs (#15772)\n\nReviewers: Chia-Ping Tsai <chia7712@gmail.com>","shortMessageHtmlLink":"KAFKA-15853 Move socket configs into org.apache.kafka.network.SocketS…"}},{"before":"a548875b03a834d53d25d24e670929d351351315","after":"418e022eb6260e5bea1f0c8aa27402aae37b20c1","ref":"refs/heads/KAFKA-14563-2","pushedAt":"2024-04-22T21:09:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Some correction","shortMessageHtmlLink":"Some correction"}},{"before":"05ee55047e0c60582024b883ca91c3e483d074fd","after":"a548875b03a834d53d25d24e670929d351351315","ref":"refs/heads/KAFKA-14563-2","pushedAt":"2024-04-22T17:03:30.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Address comments","shortMessageHtmlLink":"Address comments"}},{"before":null,"after":"16830b712c0156c2ccd5474dddf2cda04846de99","ref":"refs/heads/ELR-system-test","pushedAt":"2024-04-19T22:36:26.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Add Integration tests for the the KIP-966","shortMessageHtmlLink":"Add Integration tests for the the KIP-966"}},{"before":"a3dcbd4e28a35f79f75ec1bf316ef0b39c0df164","after":"f22ad6645bfec0b38e820e0090261c9f6b421a74","ref":"refs/heads/trunk","pushedAt":"2024-04-19T17:12:56.000Z","pushType":"push","commitsCount":8,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"KAFKA-16272: Adding new coordinator related changes for connect_distributed.py (#15594)\n\nSummary of the changes:\r\n\r\nParameterizes the tests to use new coordinator and pass in consumer group protocol. This would be applicable to sink connectors only.\r\nEnhances the sink connector creation code in system tests to accept a new optional parameter for consumer group protocol to be used.\r\nSets the consumer group protocol via consumer.override. override config when the new group coordinator is enabled.\r\nNote about testing: There are 288 tests that need to be run and running on my local takes a lot of time. I will try to post the test results once I have a full run.\r\n\r\nReviewers: Kirk True <ktrue@confluent.io>, Lucas Brutschy <lbrutschy@confluent.io>, Philip Nee <pnee@confluent.io>","shortMessageHtmlLink":"KAFKA-16272: Adding new coordinator related changes for connect_distr…"}},{"before":"961593085db5a92442994794aa9780ab666b6dc5","after":"3a232a93f3c673c533ae4452c38833c57a9084eb","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-04-17T23:34:04.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Add more tests","shortMessageHtmlLink":"Add more tests"}},{"before":"13ee2a77761ece94318fcf29c9b081fb6e025627","after":"961593085db5a92442994794aa9780ab666b6dc5","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-04-17T23:00:22.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Generate the partition records with the config records","shortMessageHtmlLink":"Generate the partition records with the config records"}},{"before":"791de6a93c9afb649ec91b450b911acb1d2cb951","after":"18226b6d140d24a7c425009ded1756b103b723b4","ref":"refs/heads/ELR-ak-Describe-topics-api-client-2","pushedAt":"2024-04-17T17:36:44.000Z","pushType":"push","commitsCount":11,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Merge branch 'trunk' into ELR-ak-Describe-topics-api-client-2","shortMessageHtmlLink":"Merge branch 'trunk' into ELR-ak-Describe-topics-api-client-2"}},{"before":"6ed3bae2c16caf72cdec2d9ac6c5ac2332c51437","after":"a3dcbd4e28a35f79f75ec1bf316ef0b39c0df164","ref":"refs/heads/trunk","pushedAt":"2024-04-17T17:36:10.000Z","pushType":"push","commitsCount":10,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"KAFKA-16073: Increment the local-log-start-offset before deleting segments in memory table (#15631)\n\nCo-authored-by: hzh0425 <642256541@qq.com>\r\n\r\nReviewers: Luke Chen <showuon@gmail.com>, Jun Rao <junrao@gmail.com>","shortMessageHtmlLink":"KAFKA-16073: Increment the local-log-start-offset before deleting seg…"}},{"before":"16344d812f614c82cbf7f9fda86dd9378964039e","after":"791de6a93c9afb649ec91b450b911acb1d2cb951","ref":"refs/heads/ELR-ak-Describe-topics-api-client-2","pushedAt":"2024-04-16T18:53:17.000Z","pushType":"push","commitsCount":27,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Populate a node for fenced broker","shortMessageHtmlLink":"Populate a node for fenced broker"}},{"before":"619f27015fbe8db6b46cb0d671395696d9725369","after":"6ed3bae2c16caf72cdec2d9ac6c5ac2332c51437","ref":"refs/heads/trunk","pushedAt":"2024-04-16T16:06:35.000Z","pushType":"push","commitsCount":25,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"MINOR: Fix a few typos in clients and core tests (#15725)\n\n\r\nReviewers: Mickael Maison <mickael.maison@gmail.com>, Luke Chen <showuon@gmail.com>, Igor Soarez<soarez@apple.com>\r\nCo-authored-by: lixinyang <nickxyli@tencent.com>","shortMessageHtmlLink":"MINOR: Fix a few typos in clients and core tests (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2244988451\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/kafka/issues/15725\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/kafka/pull/15725/hovercard\" href=\"https://github.com/apache/kafka/pull/15725\">apache#15725</a>)"}},{"before":"8cda28a268d345f4e335ff6cc3a68dc19f0e7333","after":"13ee2a77761ece94318fcf29c9b081fb6e025627","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-04-16T15:58:29.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Minor","shortMessageHtmlLink":"Minor"}},{"before":"e6db70067b4c99b05d9945b5f562deedb637f713","after":"8cda28a268d345f4e335ff6cc3a68dc19f0e7333","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-04-15T21:25:36.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Do not wait for the write event to be executed","shortMessageHtmlLink":"Do not wait for the write event to be executed"}},{"before":"47ef3ad30795fbfddd414b0bcb40bbddb7869ba0","after":"e6db70067b4c99b05d9945b5f562deedb637f713","ref":"refs/heads/ELR-config-update-2","pushedAt":"2024-04-12T00:58:59.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"CalvinConfluent","name":"Calvin Liu","path":"/CalvinConfluent","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/83986057?s=80&v=4"},"commit":{"message":"Kafka-16540: Update partitions if min isr config is changed.","shortMessageHtmlLink":"Kafka-16540: Update partitions if min isr config is changed."}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEZOp2qAA","startCursor":null,"endCursor":null}},"title":"Activity · CalvinConfluent/kafka"}