kafka.git
2 days ago  Guozhang WangKAFKA-13785: [7/N][Emit final] emit final for sliding... trunk
2 days ago  Colin Patrick... MINOR: convert some tests to KRaft (#12155)
2 days ago  Alex SorokoumovMINOR: Add upgrade tests for FK joins (#12122)
2 days ago  vamossagar12KAFKA-13746: Attempt to fix flaky test by waiting on...
2 days ago  Tom BentleyMINOR: Update release versions for upgrade tests with...
3 days ago  Colin Patrick... KAFKA-13649: Implement early.start.listeners and fix...
3 days ago  José Armando... MINOR; DeleteTopics version tests (#12141)
3 days ago  dengzimingMINOR: Fix flaky testDescribeUnderReplicatedPartitions...
3 days ago  jparagMINOR: parameter name fix for maxScalacThreads (#12151)
3 days ago  Chris EgertonKAFKA-10000: Add all public-facing config properties...
4 days ago  Ismael JumaMINOR: Remove kraft authorizer from list of missing...
4 days ago  Ismael JumaMINOR: Make TopicPartitionBookkeeper and TopicPartition...
5 days ago  Ismael JumaMINOR: reload4j build dependency fixes (#12144)
5 days ago  andymg3 KAFKA-13892: Fix bug where multiple remove records...
5 days ago  Jason GustafsonMINOR: Create case class to encapsulate fetch parameter...
5 days ago  Colin Patrick... MINOR: install Exit.exit handler in BrokerMetadataPubli...
5 days ago  dengzimingKAFKA-13862; Support Append/Subtract multiple config...
5 days ago  Bruno CadonnaMINOR: Update release versions for upgrade tests with...
5 days ago  chernKAFKA-13879: Reconnect exponential backoff is ineffecti...
5 days ago  Mickael MaisonMINOR: Small cleanups in connect/mirror (#12113)
6 days ago  JackleeMINOR: fix typo for QUORUM_FETCH_TIMEOUT_MS_DOC (#12132)
6 days ago  David JacotKAFKA-13790; ReplicaManager should be robust to all...
6 days ago  RivenSunKAFKA-13793: Add validators for configs that lack valid...
6 days ago  Chris EgertonKAFKA-13763: Refactor IncrementalCooperativeAssignor...
9 days ago  Artem LivshitsKAFKA-10888: Sticky partition leads to uneven produce...
9 days ago  John RoeslerMINOR: Fix RecordContext Javadoc (#12130)
9 days ago  Bruno CadonnaMINOR: Fix link to old doc in quickstart (#12129)
9 days ago  Luke ChenKAFKA-13804: Output the reason why broker exit unexpect...
9 days ago  Chris EgertonKAFKA-10000: Add new source connector APIs related...
10 days ago  Guozhang WangKAFKA-13785: [8/N][emit final] time-ordered session...
10 days ago  Bruno CadonnaKAFKA-10199: Implement adding active tasks to the state...
11 days ago  Lucas WangKAFKA-13815: Avoid reinitialization for a replica that...
11 days ago  Akhilesh ChagantiKAFKA-13861; Fix the validateOnly behavior for CreatePa...
11 days ago  Joel HamillMINOR: Fix typos in configuration docs (#11874)
12 days ago  Joel HamillMINOR: Improve docs about how to provide multiple log...
12 days ago  dengzimingMINOR: Remove duplicated test cases in MetadataVersionT...
12 days ago  Guozhang WangKAFKA-13785: [6/N][Emit final] Copy: Emit final for...
12 days ago  Bruno CadonnaMINOR: Note that slf4j-log4j in version 1.7.35+ should...
13 days ago  Alyssa HuangKAFKA-13854 Refactor ApiVersion to MetadataVersion...
13 days ago  Colin Patrick... MINOR: fix ClientQuotasRequestTest (#12107)
13 days ago  bozhao12KAFKA-13865: Fix ResponseSendTimeMs metric in RequestCh...
2022-04-29  Jason GustafsonMINOR: Fix event output inconsistencies in Transactiona...
2022-04-29  RivenSunMINOR: Improve document description in zero-copy (...
2022-04-29  Rajani KaruturiKAFKA-12380 shutdown Executor in Connect's Worker when...
2022-04-28  Ismael JumaKAFKA-13794: Fix comparator of inflightBatchesBySequenc...
2022-04-28  David JacotMINOR: Fix minor typos in `PartitionChangeBuilder`...
2022-04-27  Guozhang WangHOTFIX: Only measure in nano when producer metadata...
2022-04-26  Mike TobolaMINOR: fix html generation syntax errors (#12094)
2022-04-26  Jason GustafsonMINOR: Rename `AlterIsrManager` to `AlterPartitionManag...
2022-04-25  Philip NeeKAFKA-12841: Remove an additional call of onAcknowledge...
2022-04-25  Alyssa HuangMINOR; enable KRaft in ConfigCommandIntegrationTest...
2022-04-25  David JacotMINOR: Refactor `kafka.cluster.Replica` (#12081)
2022-04-25  Jason GustafsonMINOR: Change `AlterPartition` validation order in...
2022-04-24  RivenSunMINOR: Using enums for auto.offset.reset configuration...
2022-04-24  ruanliangKAFKA-13834: add test coverage for RecordAccumulatorTes...
2022-04-24  HongtenKAFKA-13852: Kafka Acl documentation bug for wildcard...
2022-04-22  David JacotMINOR: Rename `ZkVersion` to `PartitionEpoch` (#12071)
2022-04-21  Colin Patrick... KAFKA-13841: Fix a case where we were unable to place...
2022-04-21  Luke ChenMINOR: revert back to 60s session timeout for static...
2022-04-21  José Armando... MINOR; Fix partition change record noop check (#12073)
2022-04-21  Clay JohnsonMINOR: Improve Gradle Caching and Fix Deprecations...
2022-04-21  ruanliangKAFKA-13834: fix drain batch starving issue (#12066)
2022-04-21  RivenSunMINOR: cleanup for postProcessAndValidateIdempotenceCon...
2022-04-20  Matthias J... HOTFIX: fix broken trunk due to conflicting and overlap...
2022-04-20  Sayantanu DeyKAFKA-13588: consolidate `changelogFor` methods to...
2022-04-20  Hao LiKAFKA-13785: [5/N][emit final] cache for time ordered...
2022-04-20  RivenSunKAFKA-13799: Improve documentation for Kafka zero-copy...
2022-04-20  Mickael MaisonMINOR: Scala cleanups in core (#12058)
2022-04-20  Divij VaidyaKAFKA-10095: Add stricter assertion in LogCleanerManage...
2022-04-19  Colin Patrick... KAFKA-13835: Fix two bugs related to dynamic broker...
2022-04-19  Jorge Esteban... KAFKA-13654: Extend KStream process with new Processor...
2022-04-19  dengzimingKAFKA-13832: Fix flaky testAlterAssignment (#12060)
2022-04-19  Luke ChenKAFKA-8785: fix request timeout by waiting for metadata...
2022-04-18  David JacotMINOR: Fix TestDowngrade.test_upgrade_and_downgrade...
2022-04-18  RivenSunMINOR: Correct spelling errors in KafkaRaftClient ...
2022-04-15  Colin Patrick... KAFKA-13807: Fix incrementalAlterConfig and refactor...
2022-04-15  Aleksandr SorokoumovKAFKA-13769: Explicitly route FK join results to correc...
2022-04-15  Bruno CadonnaMINOR: Make link in quickstart dynamic (#12057)
2022-04-15  Xiaobing FangMINOR: update comment in LocalLog.replaceSegments(...
2022-04-15  RivenSunMINOR: Improve the description of principal under diffe...
2022-04-15  dengzimingMINOR: Move some TopicCommand and ConfigCommand integra...
2022-04-15  Bruno Cadonna[MINOR] Update upgrade documentation for 3.2 (#12055)
2022-04-15  RivenSunMINOR: ignore unused configuration when ConsumerCoordin...
2022-04-15  RivenSunMINOR: Remove redundant conditional judgments in Select...
2022-04-14  Bruno CadonnaMINOR: Update LICENSE-binary (#12051)
2022-04-14  David ArthurKAFKA-13823 Feature flag changes from KIP-778 (#12036)
2022-04-14  Lee DongjinKAFKA-12613: Fix inconsistent validation logic between...
2022-04-13  dengzimingKAFKA-13743: Prevent topics with conflicting metrics...
2022-04-13  Jason GustafsonKAFKA-13651; Add audit logging to `StandardAuthorizer...
2022-04-13  José Armando... MINOR: Verify stopReplica if broker epoch not stale...
2022-04-13  Hao LiKAFKA-13542: Add rebalance reason in Kafka Streams...
2022-04-13  David JacotKAFKA-13828; Ensure reasons sent by the consumer are...
2022-04-13  Chris EgertonMINOR: Correct Connect docs on connector/task states...
2022-04-13  RivenSunMINOR: Supplement the description of `Valid Values...
2022-04-11  Jorge Esteban... MINOR: Fix SessionStore#fetchSession parameter names...
2022-04-11  José Armando... MINOR: Re-use counter in mocking of LogSegment.size...
2022-04-11  RivenSunMINOR: Change the log output information in the KafkaCo...
2022-04-09  David JacotMINOR: A few code cleanups in DynamicBrokerConfig ...
2022-04-09  Xiaoyue XueKAFKA-13794: Follow up to fix producer batch comparator...
2022-04-08  Alok NikhilMINOR: Fix DescribeLogDirs API error handling for older...
next