17
I Use This!
Very High Activity

Commits : Listings

Analyzed about 14 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: Fix warnings in streams javadoc (#15955) More... 4 days ago
KAFKA-16671 enable test for ensureInternalEndpointIsSecured (#15868) More... 4 days ago
KAFKA-15045: (KIP-924 pt. 3) Implement KafkaStreamsAssignment (#15944) More... 4 days ago
KAFKA-15045: (KIP-924 pt. 2) Implement ApplicationState and KafkaStreamsState (#15920) More... 4 days ago
KAFKA-15170: Fix rack-aware assignment in AbstractStickyAssignor (#13965) More... 4 days ago
MINOR: Add classic member session timeout to ClassicMemberMetadata (#15921) More... 5 days ago
KAFKA-16699: Have Streams treat InvalidPidMappingException like a ProducerFencedException (#15919) More... 5 days ago
MINOR: fix flaky testRecordThreadIdleRatioTwoThreads test (#15937) More... 5 days ago
KAFKA-13115; Update doSend doc about possible blocking (#11023) More... 5 days ago
MINOR; Validate at least one control record (#15912) More... 5 days ago
KAFKA-16702 Fix producer leaks in KafkaLog4jAppenderTest (#15922) More... 5 days ago
MINOR: Use ClusterTemplate in ApiVersionsRequestTest (#15936) More... 5 days ago
MINOR: Various cleanups in clients tests (#15877) More... 5 days ago
MINOR: Add coverage for MM2 heartbeats topic detection (#15932) More... 5 days ago
KAFKA-16694; Remove Rack Awareness Code from the Server Side Assignors (#15903) More... 5 days ago
MINOR: Move `group-coordinator` import control to its own file (#15934) More... 5 days ago
KAFKA-16703 Close serverChannel in SocketServer if unable to bind to a port (#15923) More... 5 days ago
KAFKA-16695: Improve expired poll logging (#15909) More... 5 days ago
KAFKA-14509: [3/4] Add integration test for consumerGroupDescribe API (#15727) More... 6 days ago
KAFKA-16735; Deprecate offsets.commit.required.acks (#15931) More... 6 days ago
KAFKA-10199: Shutdown with new remove operation in state updater (#15894) More... 6 days ago
KAFKA-14588 [2/N] ConfigCommandTest rewritten in java (#15873) More... 6 days ago
KAFKA-16696 Removed the in-memory implementation of RSM and RLMM (#15911) More... 6 days ago
KAFKA-16587: Add subscription model information to group state (#15785) More... 6 days ago
KAFKA-10199: Handle assignment with new remove operation in state updater (#15882) More... 6 days ago
KAFKA-16663; Cancel write timeout TimerTask on successful event completion (#15902) More... 6 days ago
KAFKA-16677 Replace ClusterType#ALL and ClusterType#DEFAULT by Array (#15897) More... 6 days ago
KAFKA-16679 merge unit test down to the class of integration test (#15884) More... 8 days ago
KAFKA-9401 Reduce contention for Fetch requests (#15836) More... 8 days ago
MINOR: fix LogValidatorTest#checkNonCompressed (#15904) More... 8 days ago