17
I Use This!
Very High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 2 days ago.
Mar 26, 2023 — Mar 26, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
KAFKA-16415 Fix handling of "--version" option in ConsumerGroupCommand (#15592) More... 2 days ago
KAFKA-16409: DeleteRecordsCommand should use standard exception handling (#15586) More... 3 days ago
KAFKA-16386: Convert NETWORK_EXCEPTIONs from KIP-890 transaction verification (#15559) More... 3 days ago
KAFKA-16224: Do not retry committing if topic or partition deleted (#15581) More... 3 days ago
KAFKA-15950: Serialize heartbeat requests (#14903) More... 3 days ago
KAFKA-16406: Splitting consumer integration test (#15535) More... 3 days ago
KAFKA-16375: Fix for rejoin while reconciling (#15579) More... 3 days ago
KAFKA-15882: Add nightly docker image scan job (#15013) More... 3 days ago
KAFKA-16374; High watermark updates should have a higher priority (#15534) More... 3 days ago
KAFKA-16410 kafka-leader-election / LeaderElectionCommand doesn't set exit code on error (#15591) More... 4 days ago
KAFKA-16408 kafka-get-offsets / GetOffsetShell doesn't handle --version or --help (#15583) More... 4 days ago
KAFKA-16388 add production-ready test of 3.3 - 3.6 release to MetadataVersionTest.testFromVersionString (#15563) More... 5 days ago
MINOR: Tuple2 replaced with Map.Entry (#15560) More... 6 days ago
KAFKA-16381 use volatile to guarantee KafkaMetric#config visibility across threads (#15550) More... 6 days ago
KAFKA-16314: Introducing the AbortableTransactionException (#15486) More... 6 days ago
KAFKA-16276: Update transactions_test.py to support KIP-848’s group protocol config (#15567) More... 6 days ago
KAFKA-16274: Update replica_scale_test.py to support KIP-848’s group protocol config (#15577) More... 6 days ago
KAFKA-16271: Upgrade consumer_rolling_upgrade_test.py (#15578) More... 6 days ago
KAFKA-14133: Move stateDirectory mock in TaskManagerTest to Mockito (#15254) More... 6 days ago
MINOR: KRaft upgrade tests should only use latest stable mv (#15566) More... 7 days ago
KAFKA-16273: Update consumer_bench_test.py to use consumer group protocol (#15548) More... 7 days ago
KAFKA-16206: Fix unnecessary topic config deletion during ZK migration (#14206) More... 7 days ago
KAFKA-16318 : add javafoc for kafka metric (#15483) More... 7 days ago
MINOR : Removed the depreciated information about Zk to Kraft migration. (#15552) More... 8 days ago
KAFKA-16392: Stop emitting warning log message when parsing source connector offsets with null partitions (#15562) More... 8 days ago
KAFKA-16313: Offline group protocol migration (#15546) More... 8 days ago
KAFKA-14589 ConsumerGroupCommand rewritten in java (#14471) More... 8 days ago
KAFKA-16222: desanitize entity name when migrate client quotas (#15481) More... 8 days ago
KAFKA-12187 replace assertTrue(obj instanceof X) with assertInstanceOf (#15512) More... 9 days ago
KAFKA-16367; Full ConsumerGroupHeartbeat response must be sent when full request is received (#15533) More... 9 days ago