{"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:1717145602.0","currentOid":""},"activityList":{"items":[{"before":"ee834d9214b9961d0afaee030c7a46487c71e543","after":"c01279b92acefd9135089588319910bac79bfd4c","ref":"refs/heads/trunk","pushedAt":"2024-06-06T22:11:43.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-16905: Fix blocking DescribeCluster call in AdminClient DescribeTopics (#16217)\n\nReviewers: Andrew Schofield , Lianet Magrans , David Arthur ","shortMessageHtmlLink":"KAFKA-16905: Fix blocking DescribeCluster call in AdminClient Describ…"}},{"before":"5d4e426f0907a960c31d1e991e008d6b931245d6","after":"c60b61886d0c08cad9873da7323e693cdc67204f","ref":"refs/heads/3.8","pushedAt":"2024-06-06T21:51:41.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)\n\nThis PR updates all of the streams task assignment code to use the new AssignmentConfigs public class.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)"}},{"before":"8a2bc3a22188fbdb506b6f4bec6d3f8eb59d4c3f","after":"ee834d9214b9961d0afaee030c7a46487c71e543","ref":"refs/heads/trunk","pushedAt":"2024-06-06T21:20:48.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)\n\nThis PR updates all of the streams task assignment code to use the new AssignmentConfigs public class.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)"}},{"before":"1b0edf4f8c42bba17e974038c0bc57b798d0452e","after":"5d4e426f0907a960c31d1e991e008d6b931245d6","ref":"refs/heads/3.8","pushedAt":"2024-06-06T19:38:43.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-16903: Consider produce error of different task (#16222)\n\nA task does not know anything about a produce error thrown\r\nby a different task. That might lead to a InvalidTxnStateException\r\nwhen a task attempts to do a transactional operation on a producer\r\nthat failed due to a different task.\r\n\r\nThis commit stores the produce exception in the streams producer\r\non completion of a send instead of the record collector since the\r\nrecord collector is on task level whereas the stream producer\r\nis on stream thread level. Since all tasks use the same streams\r\nproducer the error should be correctly propagated across tasks\r\nof the same stream thread.\r\n\r\nFor EOS alpha, this commit does not change anything because\r\neach task uses its own producer. The send error is still\r\non task level but so is also the transaction.\r\n\r\nReviewers: Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-16903: Consider produce error of different task (#16222)"}},{"before":"25ca963980371361421ab73c5cabc609ca6fe4d0","after":"1b0edf4f8c42bba17e974038c0bc57b798d0452e","ref":"refs/heads/3.8","pushedAt":"2024-06-06T19:20:48.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"dajac","name":"David Jacot","path":"/dajac","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/157182?s=80&v=4"},"commit":{"message":"KAFKA-14701; Move `PartitionAssignor` to new `group-coordinator-api` module (#16198)\n\nThis patch moves the `PartitionAssignor` interface and all the related classes to a newly created `group-coordinator/api` module, following the pattern used by the storage and tools modules.\r\n\r\nReviewers: Ritika Reddy , Jeff Kim , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-14701; Move PartitionAssignor to new group-coordinator-api …"}},{"before":"7d832cf74fd403a8bca168a83340c19f9afe1a42","after":"8a2bc3a22188fbdb506b6f4bec6d3f8eb59d4c3f","ref":"refs/heads/trunk","pushedAt":"2024-06-06T19:19:52.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-16903: Consider produce error of different task (#16222)\n\nA task does not know anything about a produce error thrown\r\nby a different task. That might lead to a InvalidTxnStateException\r\nwhen a task attempts to do a transactional operation on a producer\r\nthat failed due to a different task.\r\n\r\nThis commit stores the produce exception in the streams producer\r\non completion of a send instead of the record collector since the\r\nrecord collector is on task level whereas the stream producer\r\nis on stream thread level. Since all tasks use the same streams\r\nproducer the error should be correctly propagated across tasks\r\nof the same stream thread.\r\n\r\nFor EOS alpha, this commit does not change anything because\r\neach task uses its own producer. The send error is still\r\non task level but so is also the transaction.\r\n\r\nReviewers: Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-16903: Consider produce error of different task (#16222)"}},{"before":"79ea7d6122ac4dbc1441e9efbddae44b1a9c93f9","after":"7d832cf74fd403a8bca168a83340c19f9afe1a42","ref":"refs/heads/trunk","pushedAt":"2024-06-06T19:19:20.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-14701; Move `PartitionAssignor` to new `group-coordinator-api` module (#16198)\n\nThis patch moves the `PartitionAssignor` interface and all the related classes to a newly created `group-coordinator/api` module, following the pattern used by the storage and tools modules.\r\n\r\nReviewers: Ritika Reddy , Jeff Kim , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-14701; Move PartitionAssignor to new group-coordinator-api …"}},{"before":"a41f7a4e13bfdb21fcd84dcf0baad3f2f4511479","after":"79ea7d6122ac4dbc1441e9efbddae44b1a9c93f9","ref":"refs/heads/trunk","pushedAt":"2024-06-06T18:28:39.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 clients (#16193)\n\n\r\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Various cleanups in clients (#16193)"}},{"before":"0ed104c3dc87ba8842b1a46e3e16ff21700dfed5","after":"a41f7a4e13bfdb21fcd84dcf0baad3f2f4511479","ref":"refs/heads/trunk","pushedAt":"2024-06-06T16:06:26.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-16884 Refactor RemoteLogManagerConfig with AbstractConfig (#16199)\n\nReviewers: Greg Harris , Kamal Chandraprakash , Chia-Ping Tsai ","shortMessageHtmlLink":"KAFKA-16884 Refactor RemoteLogManagerConfig with AbstractConfig (#16199)"}},{"before":"f36a8736421179994fdff6a1383287b4c1cb4aad","after":"0ed104c3dc87ba8842b1a46e3e16ff21700dfed5","ref":"refs/heads/trunk","pushedAt":"2024-06-06T15:56:08.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: Cleanup the storage module unit tests (#16202)\n\n- Use SystemTime instead of MockTime when time is not mocked\r\n- Use static assertions to reduce the line length\r\n- Fold the lines if it exceeds the limit\r\n- rename tp0 to tpId0 when it refers to TopicIdPartition\r\n\r\nReviewers: Kuan-Po (Cooper) Tseng , Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Cleanup the storage module unit tests (#16202)"}},{"before":"226f3c57e3a19de227d6b34828fd5e3a535e6778","after":"f36a8736421179994fdff6a1383287b4c1cb4aad","ref":"refs/heads/trunk","pushedAt":"2024-06-06T15:46: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":"MINOR: Added test for ClusterConfig#displayTags (#16110)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Added test for ClusterConfig#displayTags (#16110)"}},{"before":"ebe1e964ffb7f6da770df67980de82e7931c0496","after":"226f3c57e3a19de227d6b34828fd5e3a535e6778","ref":"refs/heads/trunk","pushedAt":"2024-06-06T13:18:23.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: Code cleanup in metadata module (#16065)\n\n\r\nReviewers: Mickael Maison ","shortMessageHtmlLink":"MINOR: Code cleanup in metadata module (#16065)"}},{"before":"b74b182841a340b7b92d852142201cd5c1ee1b85","after":"ebe1e964ffb7f6da770df67980de82e7931c0496","ref":"refs/heads/trunk","pushedAt":"2024-06-06T11:40:31.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-16448: Add ProcessingExceptionHandler interface and implementations (#16187)\n\nThis PR is part of KAFKA-16448 which aims to bring a ProcessingExceptionHandler to Kafka Streams in order to deal with exceptions that occur during processing.\r\n\r\nThis PR brings ProcessingExceptionHandler interface and default implementations.\r\n\r\nCo-authored-by: Dabz \r\nCo-authored-by: sebastienviale \r\n\r\nReviewer: Bruno Cadonna ","shortMessageHtmlLink":"KAFKA-16448: Add ProcessingExceptionHandler interface and implementat…"}},{"before":"f880ad6ccfe59695634a43ae878de620d02b4f9e","after":"b74b182841a340b7b92d852142201cd5c1ee1b85","ref":"refs/heads/trunk","pushedAt":"2024-06-06T07:45:37.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-16786: Remove old assignment strategy usage in new consumer (#16214)\n\nRemove usage of the partition.assignment.strategy config in the new consumer. This config is deprecated with the new consumer protocol, so the AsyncKafkaConsumer should not use or validate the property.\r\n\r\nReviewers: Lucas Brutschy ","shortMessageHtmlLink":"KAFKA-16786: Remove old assignment strategy usage in new consumer (#1…"}},{"before":"04f7ed4c104d72b8332626b5950723698cf3b473","after":"25ca963980371361421ab73c5cabc609ca6fe4d0","ref":"refs/heads/3.8","pushedAt":"2024-06-06T06:31:44.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-16530: Fix high-watermark calculation to not assume the leader is in the voter set (#16079)\n\n1. Changing log message from error to info - We may expect the HW calculation to give us a smaller result than the current HW in the case of quorum reconfiguration. We will continue to not allow the HW to actually decrease.\r\n2. Logic for finding the updated LeaderEndOffset for updateReplicaState is changed as well. We do not assume the leader is in the voter set and check the observer states as well.\r\n3. updateLocalState now accepts an additional \"lastVoterSet\" param which allows us to update the leader state with the last known voters. any nodes in this set but not in voterStates will be added to voterStates and removed from observerStates, any nodes not in this set but in voterStates will be removed from voterStates and added to observerStates\r\n\r\nReviewers: Luke Chen , José Armando García Sancio ","shortMessageHtmlLink":"KAFKA-16530: Fix high-watermark calculation to not assume the leader …"}},{"before":"3835515feaf7cb5bb7de3c4d63794e79100eb62a","after":"f880ad6ccfe59695634a43ae878de620d02b4f9e","ref":"refs/heads/trunk","pushedAt":"2024-06-06T06:30:49.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-16530: Fix high-watermark calculation to not assume the leader is in the voter set (#16079)\n\n1. Changing log message from error to info - We may expect the HW calculation to give us a smaller result than the current HW in the case of quorum reconfiguration. We will continue to not allow the HW to actually decrease.\r\n2. Logic for finding the updated LeaderEndOffset for updateReplicaState is changed as well. We do not assume the leader is in the voter set and check the observer states as well.\r\n3. updateLocalState now accepts an additional \"lastVoterSet\" param which allows us to update the leader state with the last known voters. any nodes in this set but not in voterStates will be added to voterStates and removed from observerStates, any nodes not in this set but in voterStates will be removed from voterStates and added to observerStates\r\n\r\nReviewers: Luke Chen , José Armando García Sancio ","shortMessageHtmlLink":"KAFKA-16530: Fix high-watermark calculation to not assume the leader …"}},{"before":"7763243752d797ee4136b9090722863e034f7afc","after":"3835515feaf7cb5bb7de3c4d63794e79100eb62a","ref":"refs/heads/trunk","pushedAt":"2024-06-06T06:10:13.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"junrao","name":"Jun Rao","path":"/junrao","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/132330?s=80&v=4"},"commit":{"message":"KAFKA-16541 Fix potential leader-epoch checkpoint file corruption (#15993)\n\nA patch for KAFKA-15046 got rid of fsync on LeaderEpochFileCache#truncateFromStart/End for performance reason, but it turned out this could cause corrupted leader-epoch checkpoint file on ungraceful OS shutdown, i.e. OS shuts down in the middle when kernel is writing dirty pages back to the device.\r\n\r\nTo address this problem, this PR makes below changes: (1) Revert LeaderEpochCheckpoint#write to always fsync\r\n(2) truncateFromStart/End now call LeaderEpochCheckpoint#write asynchronously on scheduler thread\r\n(3) UnifiedLog#maybeCreateLeaderEpochCache now loads epoch entries from checkpoint file only when current cache is absent\r\n\r\nReviewers: Jun Rao ","shortMessageHtmlLink":"KAFKA-16541 Fix potential leader-epoch checkpoint file corruption (#1…"}},{"before":"e82731f0c6c332a79dc34b50acf29189ea7cb452","after":"04f7ed4c104d72b8332626b5950723698cf3b473","ref":"refs/heads/3.8","pushedAt":"2024-06-06T00:17:45.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-16814 KRaft broker cannot startup when `partition.metadata` is missing (#16165)\n\nWhen starting up kafka logManager, we'll check stray replicas to avoid some corner cases. But this check might cause broker unable to startup if partition.metadata is missing because when startup kafka, we load log from file, and the topicId of the log is coming from partition.metadata file. So, if partition.metadata is missing, the topicId will be None, and the LogManager#isStrayKraftReplica will fail with no topicID error.\r\n\r\nThe partition.metadata missing could be some storage failure, or another possible path is unclean shutdown after topic is created in the replica, but before data is flushed into partition.metadata file. This is possible because we do the flush in async way here.\r\n\r\nWhen finding a log without topicID, we should treat it as a stray log and then delete it.\r\n\r\nReviewers: Luke Chen , Gaurav Narula ","shortMessageHtmlLink":"KAFKA-16814 KRaft broker cannot startup when partition.metadata is …"}},{"before":"1f6c5dc5df47605d164b7b27fa47c2b0c06f2770","after":"e82731f0c6c332a79dc34b50acf29189ea7cb452","ref":"refs/heads/3.8","pushedAt":"2024-06-05T22:59:54.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 17) State store computation fixed (#16194)\n\nFixed the calculation of the store name list based on the subtopology being accessed.\r\n\r\nAlso added a new test to make sure this new functionality works as intended.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 17) State store computation fixed (#16194)"}},{"before":"6a55c45d776f6a3d06da169431171405df36595e","after":"c979ef2f7d0bcce0d2f5a80dffbb42ddbb84ed62","ref":"refs/heads/3.7","pushedAt":"2024-06-05T22:23:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-12317: Update FK-left-join documentation (#15689)\n\nFK left-join was changed via KIP-962. This PR updates the docs accordingly.\r\n\r\nReviewers: Ayoub Omari , Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-12317: Update FK-left-join documentation (#15689)"}},{"before":"dd6d6f4a5aa4f5109690d08d41509ded057b780d","after":"1f6c5dc5df47605d164b7b27fa47c2b0c06f2770","ref":"refs/heads/3.8","pushedAt":"2024-06-05T22:23:30.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-12317: Update FK-left-join documentation (#15689)\n\nFK left-join was changed via KIP-962. This PR updates the docs accordingly.\r\n\r\nReviewers: Ayoub Omari , Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-12317: Update FK-left-join documentation (#15689)"}},{"before":"1134520decfca990410acce2ec1a8cba5c8c2cb4","after":"7763243752d797ee4136b9090722863e034f7afc","ref":"refs/heads/trunk","pushedAt":"2024-06-05T22:22:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-12317: Update FK-left-join documentation (#15689)\n\nFK left-join was changed via KIP-962. This PR updates the docs accordingly.\r\n\r\nReviewers: Ayoub Omari , Matthias J. Sax ","shortMessageHtmlLink":"KAFKA-12317: Update FK-left-join documentation (#15689)"}},{"before":"c1accdbab9e0e71959b5a0a5959c8341a512b426","after":"dd6d6f4a5aa4f5109690d08d41509ded057b780d","ref":"refs/heads/3.8","pushedAt":"2024-06-05T22:15:34.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-16573: Specify node and store where serdes are needed (#15790)\n\nReviewers: Matthias J. Sax , Bruno Cadonna , Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-16573: Specify node and store where serdes are needed (#15790)"}},{"before":"9aad16e55dfd394eb9d7d7d3f095e91a8e855a72","after":"6a55c45d776f6a3d06da169431171405df36595e","ref":"refs/heads/3.7","pushedAt":"2024-06-05T22:11:03.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":"MINOR: Fix error in testRestartBrokerNoErrorIfMissingPartitionMetadata (#16216)\n\n\r\nReviewers: Igor Soarez ","shortMessageHtmlLink":"MINOR: Fix error in testRestartBrokerNoErrorIfMissingPartitionMetadata ("}},{"before":"896af1b2f2f2a7d579e0aef074bcb2004c0246f2","after":"1134520decfca990410acce2ec1a8cba5c8c2cb4","ref":"refs/heads/trunk","pushedAt":"2024-06-05T22:05:04.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"mjsax","name":"Matthias J. Sax","path":"/mjsax","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8959638?s=80&v=4"},"commit":{"message":"KAFKA-16573: Specify node and store where serdes are needed (#15790)\n\nReviewers: Matthias J. Sax , Bruno Cadonna , Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-16573: Specify node and store where serdes are needed (#15790)"}},{"before":"0109a3f7189d332c333cad0625b54779bf8f9cd4","after":"896af1b2f2f2a7d579e0aef074bcb2004c0246f2","ref":"refs/heads/trunk","pushedAt":"2024-06-05T20:16:59.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: Raft module Cleanup (#16205)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Raft module Cleanup (#16205)"}},{"before":"52514a89e34b28fa6564d5c93c15461c6fab3f0f","after":"0109a3f7189d332c333cad0625b54779bf8f9cd4","ref":"refs/heads/trunk","pushedAt":"2024-06-05T20:09:37.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"ableegoldman","name":"A. Sophie Blee-Goldman","path":"/ableegoldman","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4843099?s=80&v=4"},"commit":{"message":"KAFKA-15045: (KIP-924 pt. 17) State store computation fixed (#16194)\n\nFixed the calculation of the store name list based on the subtopology being accessed.\r\n\r\nAlso added a new test to make sure this new functionality works as intended.\r\n\r\nReviewers: Anna Sophie Blee-Goldman ","shortMessageHtmlLink":"KAFKA-15045: (KIP-924 pt. 17) State store computation fixed (#16194)"}},{"before":"fe7ebf085de9a92ab1542057cd011adf2efc830d","after":"c1accdbab9e0e71959b5a0a5959c8341a512b426","ref":"refs/heads/3.8","pushedAt":"2024-06-05T18:54:53.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"gharris1727","name":"Greg Harris","path":"/gharris1727","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5856969?s=80&v=4"},"commit":{"message":"KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas (#16161)\n\nSigned-off-by: Greg Harris \r\nReviewers: Chris Egerton ","shortMessageHtmlLink":"KAFKA-16858: Throw DataException from validateValue on array and map …"}},{"before":"f2aafcc66faca4d07a27e4ef90158136cb317b44","after":"52514a89e34b28fa6564d5c93c15461c6fab3f0f","ref":"refs/heads/trunk","pushedAt":"2024-06-05T18:35:32.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"gharris1727","name":"Greg Harris","path":"/gharris1727","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5856969?s=80&v=4"},"commit":{"message":"KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas (#16161)\n\nSigned-off-by: Greg Harris \r\nReviewers: Chris Egerton ","shortMessageHtmlLink":"KAFKA-16858: Throw DataException from validateValue on array and map …"}},{"before":"bd9d68f24a5aae0054fd93a1a848d2cf0dfdde30","after":"f2aafcc66faca4d07a27e4ef90158136cb317b44","ref":"refs/heads/trunk","pushedAt":"2024-06-05T14:36: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":"MINOR: Cleanups in Shell Module (#16204)\n\nReviewers: Chia-Ping Tsai ","shortMessageHtmlLink":"MINOR: Cleanups in Shell Module (#16204)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEXqjMiwA","startCursor":null,"endCursor":null}},"title":"Activity · apache/kafka"}