17
I Use This!
Very High Activity

Commits : Listings

Analyzed about 12 hours ago. based on code collected 1 day ago.
Apr 17, 2024 — May 17, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
MINOR: log newly created processId (#15851) More... 12 days ago
KAFKA-16593 Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions (#15766) More... 12 days ago
KAFKA-16470 kafka-dump-log --offsets-decoder should support new records (#15652) More... 12 days ago
KAFKA-16539 Fix IncrementalAlterConfigs during ZK migration (#15744) More... 12 days ago
KAFKA-16608 Honour interrupted thread state on KafkaConsumer.poll (#15803) More... 12 days ago
KAFKA-16356: Remove class-name dispatch in RemoteLogMetadataSerde (#15620) More... 12 days ago
KAFKA-16646: KAFKA-16646Don't run cve scan job on forks (#15831) More... 13 days ago
MINOR: Remove `ConsumerGroupPartitionMetadataValue.Epoch` field (#15854) More... 13 days ago
KAFKA-16393 read/write sequence of buffers correctly (#15571) More... 13 days ago
KAFKA-14588 [3/N] ConfigCommandTest rewritten in java (#15850) More... 13 days ago
KAFKA-10199: Add remove operation with future to state updater (#15852) More... 13 days ago
MINOR: Replaced Utils.join() with JDK API. (#15823) More... 13 days ago
KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (2/3) (#15841) More... 13 days ago
KAFKA-16659 KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER (#15853) More... 13 days ago
MINOR: remove redundant check in KafkaClusterTestKit (#15858) More... 14 days ago
KAFKA-16207; KRaft's internal log listener to update voter set (#15671) More... 14 days ago
KAFKA-16427 KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER (#15843) More... 15 days ago
KAFKA-16655: Deflake ZKMigrationIntegrationTest.testDualWrite #15845 More... 15 days ago
MINOR: ConsumerGroup#getOrMaybeCreateMember should not add the member to the group (#15847) More... 16 days ago
KAFKA-10199: Accept only one task per element in output queue for failed tasks (#15849) More... 16 days ago
KAFKA-16572 allow defining number of disks per broker in ClusterTest (#15745) More... 16 days ago
KAFKA-16624: Don't generate useless PartitionChangeRecord on older MV (#15810) More... 17 days ago
KAFKA-14588 UserScramCredentialsCommandTest rewritten in Java (#15832) More... 17 days ago
KAFKA-16647 Remove setMetadataDirectory from BrokerNode/ControllerNode (#15833) More... 17 days ago
KAFKA-16614 Disallow @ClusterTemplate("") (#15800) More... 17 days ago
KAFKA-16588 broker shutdown hangs when log.segment.delete.delay.ms is zero (#15773) More... 18 days ago
KAFKA-16475: add more tests to TopicImageNodeTest (#15735) More... 18 days ago
MINOR: Clean up TestUtils.scala (#15808) More... 18 days ago
MINOR: Add replayRecords to CoordinatorResult (#15818) More... 19 days ago
KAFKA-16555: Consumer's RequestState has incorrect logic to determine if inflight (#15723) More... 19 days ago