commits
Thread
Date
Earlier messages
Messages by Thread
(kafka) branch trunk updated (16186eabcdd -> 455c79c339a)
junrao
(kafka) branch 3.9 updated: KAFKA-16927; Handle expanding leader endpoints (#17363)
jsancio
(kafka) branch trunk updated (5b3027dfcbc -> 16186eabcdd)
jsancio
(kafka) branch trunk updated: KAFKA-15859: Fix the Unsupported version error when new admin connects to old broker (#17358)
kamalcph
(kafka) branch trunk updated: KAFKA-16106; Schedule timeout task to refresh classic group size metric (#17325)
dajac
(kafka) branch 3.8 updated: KAFKA-17062: handle dangling "copy_segment_start" state when deleting… (#17359)
showuon
(kafka) branch trunk updated (894c4a96914 -> c8cfb4c7f1f)
showuon
(kafka) branch trunk updated: KAFKA-17525 Convert the UnknownServerException to InvalidRequestException when altering client-metrics config at runtime (#17168)
chia7712
(kafka) branch trunk updated: KAFKA-17658 Move BootstrapControllersIntegrationTest to kafka.server (#17356)
chia7712
(kafka) branch trunk updated (dbd50ff8472 -> bbbf688f553)
chia7712
(kafka) branch trunk updated (85bfdf4127e -> dbd50ff8472)
cmccabe
(kafka) branch trunk updated (8b5d755bf67 -> 85bfdf4127e)
cmccabe
(kafka) branch trunk updated: KAFKA-17685 Define common testRuntimeOnly dependencies (#17355)
davidarthur
(kafka) branch trunk updated (d173842d364 -> 0edf5dbd204)
cmccabe
(kafka) branch trunk updated: KAFKA-17469: Move persister related classes to persister pkg. (#17349)
davidarthur
(kafka) branch trunk updated: KAFKA-17674: Fix bug on update positions of newly added partitions (#17342)
lianetm
(kafka) branch trunk updated: MINOR: Cache topic resolution in TopicIds set (#17285)
dajac
(kafka) branch trunk updated: KAFKA-17451 Remove deprecated consumer#committed (#17320)
chia7712
(kafka) branch trunk updated: KAFKA-17511 Move ElectLeadersRequestOps to ElectLeadersRequest (#17312)
chia7712
(kafka) branch trunk updated: KAFKA-17500: Metadata redirection for NOT_LEADER_OR_FOLLOWER (#17279)
manikumar
(kafka) branch trunk updated: KAFKA-17285 Consider using `Utils.closeQuietly` to replace `CoreUtils.swallow` when handling Closeable objects (#16843)
chia7712
(kafka) branch trunk updated: MINOR: producer perf improvements (#17348)
showuon
(kafka) branch trunk updated: MINOR: improve KafkaStreams.State JavaDocs (#17351)
chia7712
(kafka) branch trunk updated: KAFKA-17680 Add timeout to streams test teardown (#17346)
davidarthur
(kafka) branch trunk updated: MINOR: Fix MockAdminClient to match the server side update features handling. (#17343)
jolshan
(kafka) branch trunk updated: KAFKA-16974 KRaft support in SslAdminIntegrationTest (#17251)
chia7712
(kafka) branch trunk updated: KAFKA-17258 Migrate AdminFenceProducersIntegrationTest to ClusterTestExtensions framework (#17311)
chia7712
(kafka) branch trunk updated (12a16ecf289 -> 7b7eb6243f0)
davidarthur
(kafka) branch trunk updated (2547d750a32 -> 12a16ecf289)
davidarthur
(kafka) branch trunk updated (cfd7d941084 -> 2547d750a32)
davidarthur
(kafka-site) branch asf-site updated: MINOR: Add kamalcph to committers (#633)
kamalcph
(kafka) branch kip1071 updated: KAFKA-17125: finalize TaskId (#17300)
lucasbru
(kafka) branch trunk updated (49d7ea6c6a2 -> cfd7d941084)
chia7712
(kafka) branch trunk updated: KAFKA-16308 [3/N]: Introduce feature dependency validation to UpdateFeatures command (#16443)
jolshan
(kafka) branch trunk updated: MINOR: improve RecordCollectorImpl (#17185)
mjsax
(kafka) branch trunk updated: KAFKA-17646 Fix flaky KafkaStreamsTest.testStateGlobalThreadClose (#17310)
chia7712
(kafka) branch trunk updated: KAFKA-16769 Remove add.source.alias.to.metrics configuration (#17323)
chia7712
(kafka) branch trunk updated: KAFKA-17673 Switch back to statuses API (#17336)
davidarthur
(kafka) branch trunk updated (84bcdc95af1 -> e136d7611c0)
chia7712
(kafka) branch 3.9 updated (2cbc5bd3ca2 -> 5c95a5da31f)
jsancio
(kafka) 01/02: MINOR: Need to split the controller bootstrap servers on ',' in list comprehenson (#17183)
jsancio
(kafka) 02/02: MINOR: Fix kafkatest advertised listeners (#17294)
jsancio
(kafka) branch trunk updated: KAFKA-17540: Create script for updating a reference of latest cached trunk commit (#17204)
davidarthur
(kafka) branch trunk updated: KAFKA-17606: Include Rat errors in GitHub workflow summary (#17280)
davidarthur
(kafka) branch trunk updated (818ee8a581b -> 35f55a84fe4)
jolshan
(kafka) branch trunk updated (800de133bf6 -> 818ee8a581b)
gharris
(kafka) branch trunk updated (6ee46ea8653 -> 40360819bb9)
satishd
(kafka) branch trunk updated (40360819bb9 -> bb112570ae0)
cadonna
(kafka) branch trunk updated (9cb49092f08 -> 6ee46ea8653)
chia7712
(kafka) branch trunk updated (1b0e16ba65f -> 9cb49092f08)
chia7712
(kafka) branch trunk updated (05696037d33 -> 1b0e16ba65f)
chia7712
(kafka) branch trunk updated (e27d0dfb17f -> 800de133bf6)
chia7712
(kafka) branch trunk updated (bb112570ae0 -> e27d0dfb17f)
bbejeck
(kafka) branch trunk updated: KAFKA-12823 Remove Deprecated method KStream#through (#16761)
mjsax
(kafka) branch trunk updated: KAFKA-6197: Update Streams API and Javadoc references in documentation (#17215)
mjsax
(kafka) branch trunk updated: MINOR Don't run tests for Draft PRs (#17299)
davidarthur
(kafka) branch 3.9 updated: KAFKA-17636 Fix missing SCRAM bootstrap records (#17305)
davidarthur
(kafka) branch trunk updated: KAFKA-17636 Fix missing SCRAM bootstrap records (#17305)
davidarthur
(kafka) branch trunk updated: KAFKA-14572: Migrate EmbeddedKafkaCluster used by Streams integration tests from EmbeddedZookeeper to KRaft (#17016)
bbejeck
(kafka) branch trunk updated: KAFKA-17581: AsyncKafkaConsumer can't unsubscribe invalid topics (#17244)
lianetm
(kafka) branch trunk updated: KAFKA-17619: Remove zk type and instance from ClusterTest (#17284)
davidarthur
(kafka) branch trunk updated: MINOR: Fix a race and add JMH bench for HdrHistogram (#17221)
jeffkbkim
(kafka) branch trunk updated: MINOR: Set default group.consumer.migration.policy to BIDIRECTIONAL (#17295)
dajac
(kafka) branch trunk updated (00b1b1a1445 -> 05366d2fa7c)
davidarthur
(kafka) branch trunk updated: KAFKA-16331: remove KafkaClientSupplier from StreamsProducer (#17259)
mjsax
(kafka) branch trunk updated: KAFKA-17488: Cleanup (test) code for Kafka Streams "metric version" (#17182)
mjsax
(kafka) branch trunk updated: KAFKA-17628 New workflows for automating run approvals (#17290)
davidarthur
(kafka) branch trunk updated (be116155642 -> 6cb70a831cf)
jolshan
(kafka) branch trunk updated: MINOR: Remove duplicate method (#17291)
lianetm
(kafka) branch trunk updated: KAFKA-17608, KAFKA-17604, KAFKA-16963; KRaft controller crashes when active controller is removed (#17146)
jsancio
(kafka) branch trunk updated: KAFKA-16683 Extract security-related helpers from scala.TestUtils to java class (#16912)
chia7712
(kafka) branch trunk updated: KAFKA-17154: New consumer subscribe may join group without a call to consumer.poll (#17165)
lianetm
(kafka) branch trunk updated: KAFKA-17563 Move `RequestConvertToJson` to server module (#17223)
chia7712
(kafka) branch 3.9 updated (57b098c397c -> 89cb632acd3)
jsancio
(kafka) 02/02: KAFKA-17608, KAFKA-17604, KAFKA-16963; KRaft controller crashes when active controller is removed (#17146)
jsancio
(kafka) 01/02: KAFKA-16963: Ducktape test for KIP-853 (#17081)
jsancio
(kafka) branch trunk updated: KAFKA-17621; Reduce logging verbosity on ConsumerGroupHeartbeat path (#17288)
dajac
(kafka) branch KAFKA-17621 deleted (was 97a835fe98c)
dajac
(kafka) branch trunk updated: KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) (#16982)
lianetm
(kafka) branch KAFKA-17621 updated (3c854e8e084 -> 97a835fe98c)
dajac
(kafka) branch trunk updated: MINOR: fix failed cases in FeatureCommandTest (#17287)
davidarthur
(kafka) branch KAFKA-17621 updated: a few more
dajac
(kafka) branch KAFKA-17621 created (now 9130010f7c4)
dajac
(kafka) 01/01: KAFKA-17621; Reduce logging verbosity on ConsumerGroupHeartbeat path
dajac
(kafka) branch 3.8 updated: KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258) (#17278)
showuon
(kafka) branch trunk updated: MINOR Refactoring share fetch code (KIP-932) (#17269)
davidarthur
(kafka) branch KAFKA-17571 deleted (was 962e9876635)
dajac
(kafka) branch trunk updated: KAFKA-17571; Revert "MINOR: Log pending join members (#17219)" (#17274)
dajac
(kafka) branch trunk updated: KAFKA-17496: Add heterogeneous case to TargetAssignmentBuilderBenchmark (#17277)
dajac
(kafka) branch trunk updated (560076ba9e8 -> 3d23029d1c9)
showuon
(kafka) branch 3.9 updated: KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258)
showuon
(kafka) branch trunk updated (6b9ea764566 -> 560076ba9e8)
satishd
(kafka) branch trunk updated: KAFKA-17057: Add RETRY option to ProductionExceptionHanlder (#17163)
mjsax
(kafka) branch 3.8 updated: KAFKA-16955: fix synchronization of streams threadState (#16337)
ableegoldman
(kafka) branch trunk updated (264131cdaae -> e512b634d40)
jolshan
(kafka) branch KAFKA-17584 updated (0a2752a52b7 -> d22d58da46b)
cmccabe
(kafka) branch trunk updated: MINOR: Disable Jenkins build (#17273)
chia7712
(kafka) branch trunk updated: KAFKA-16908 Refactor `QuorumConfig` with `AbstractConfig` (#17231)
chia7712
(kafka) branch trunk updated: MINOR: Update LICENSE-binary with missing licenses (#17271)
chia7712
(kafka) branch trunk updated: KAFKA-17520 Align ducktape version in tests/docker/Dockerfile and tests/setup.py (#17240)
chia7712
(kafka) branch trunk updated: KAFKA-17602 Remove `ConfigUtils.translateDeprecatedConfigs` from JmxReporter (#17267)
chia7712
(kafka) branch trunk updated: KAFKA-17087 Deprecate `delete-config` of TopicCommand (#17222)
chia7712
(kafka) branch KAFKA-17584 updated (297e961c3a6 -> 0a2752a52b7)
cmccabe
(kafka) branch kip1071 updated (ab0df20489a -> d4fb972f45c)
lucasbru
(kafka) 01/28: Very initial (compiling) streams RPCs.
lucasbru
(kafka) 06/28: Create and inject StreamsHeartbeatRequestManager
lucasbru
(kafka) 13/28: Add streams group member
lucasbru
(kafka) 08/28: Define initial record types for the consumer offset topic
lucasbru
(kafka) 11/28: Minor: Rename TaskId to TaskIds
lucasbru
(kafka) 18/28: Rebased on AK trunk 2024-07-16
lucasbru
(kafka) 28/28: Rebase on AK trunk 2024-09-25
lucasbru
(kafka) 04/28: Specify AsyncKafkaConsumer interface with Streams for the Rebalance PoC
lucasbru
(kafka) 07/28: Minor: Test fixes
lucasbru
(kafka) 05/28: Implement StreamsInitialize request manager
lucasbru
(kafka) 25/28: Improve the Streams group initialization handler
lucasbru
(kafka) 03/28: Define RPCs to perform client-side assignment
lucasbru
(kafka) 23/28: StickyTaskAssignor
lucasbru
(kafka) 21/28: Rebase on AK trunk 2024-08-15
lucasbru
(kafka) 10/28: Add Assignment class in group coordinator for Streams
lucasbru
(kafka) 27/28: Add broker configs for streams group
lucasbru
(kafka) 22/28: Minor: Revert test changes
lucasbru
(kafka) 14/28: Define the assignor interface for streams and implement a simple assignor
lucasbru
(kafka) 09/28: Implement InitStreamsApp RPC in the group coordinator
lucasbru
(kafka) 16/28: Replay all streams-related records
lucasbru
(kafka) 20/28: Implement DescribeStreamsGroup RPC handling
lucasbru
(kafka) 02/28: StreamsInitialize RPC and some errors
lucasbru
(kafka) 12/28: Basic heartbeat RPC handler
lucasbru
(kafka) 24/28: Rename streamsHeartbeatX and streamsInitializeX to streamsGroupX
lucasbru
(kafka) branch KAFKA-17571 created (now 962e9876635)
dajac
(kafka) 01/01: KAFKA-17571; Revert "MINOR: Log pending join members (#17219)"
dajac
(kafka) branch kip1071 created (now ab0df20489a)
lucasbru
(kafka) branch trunk updated: KAFKA-17592; Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC (#17257)
dajac
(kafka) branch trunk updated: KAFKA-17578: Remove partitionRacks from TopicMetadata (#17233)
dajac
(kafka) branch trunk updated: KAFKA-17076: retain last batch in each round of cleaning (#17193)
junrao
(kafka) branch KAFKA-17584 updated (4ce9b0d664e -> 297e961c3a6)
cmccabe
(kafka) branch 3.9 updated: MINOR: Replace gt and lt char with html encoding (#17235)
jsancio
(kafka) branch trunk updated: KAFKA-17465 Refactor getMembersFromGroup to be non-blocking (#17080)
chia7712
(kafka) branch KAFKA-17584 updated (8cf31e0fcf0 -> 4ce9b0d664e)
cmccabe
(kafka) branch trunk updated: KAFKA-17585 `offsetResetStrategyTimestamp` should return `long` instead of `Long` (#17252)
chia7712
(kafka) branch trunk updated: KAFKA-17512 Move LogSegmentTest to storage module (#17174)
chia7712
(kafka) branch trunk updated: KAFKA-17530 Remove blacklist/whitelist from ReplaceField (#17237)
chia7712
(kafka) branch trunk updated: KAFKA-17469: Moved share external interfaces to share module. (#17262)
davidarthur
(kafka) branch 3.8 updated: MINOR: add a space for kafka.metrics.polling.interval.secs description (#17256)
chia7712
(kafka) branch 3.9 updated: MINOR: add a space for kafka.metrics.polling.interval.secs description (#17256)
chia7712
(kafka-site) branch asf-site updated: MINOR: add a space for kafka.metrics.polling.interval.secs description (#632)
chia7712
(kafka) branch trunk updated (34c158f67f3 -> 1bd9dc3ffc7)
chia7712
(kafka) branch trunk updated (f51fc16c169 -> 34c158f67f3)
chia7712
(kafka) branch 3.8 updated: KAFKA-17459 Stablize reassign_partitions_test.py (#17250)
chia7712
(kafka) branch 3.9 updated: KAFKA-17459 Stablize reassign_partitions_test.py (#17250)
chia7712
(kafka) branch trunk updated (42cc3c0ad51 -> f51fc16c169)
chia7712
(kafka) branch trunk updated: Update zstd-jni lib (#17253)
jlprat
(kafka) branch trunk updated: MINOR: Fix SubscriptionResponseWrapperSerializer (#17205)
mjsax
(kafka) branch KAFKA-17584 updated (b182d443245 -> 8cf31e0fcf0)
cmccabe
(kafka) branch KAFKA-17584 created (now b182d443245)
cmccabe
(kafka) 01/01: KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations
cmccabe
(kafka) branch KAFKA-17506-flaky-ZkMigrationFailoverTest deleted (was 4181969077f)
davidarthur
(kafka) branch KAFKA-17506-KRaftMigrationDriver-init-race deleted (was 879062631e5)
davidarthur
(kafka) branch deflake-testFenceMultipleBrokers deleted (was 1bea8175ca2)
davidarthur
(kafka) branch develocity-build-cache deleted (was a83ff3d0847)
davidarthur
(kafka) branch trunk updated: KAFKA-17495: Factor out assignor benchmark code into utils class (#17133)
dajac
(kafka) branch trunk updated (d0634438257 -> a407cc3a315)
chia7712
(kafka) branch trunk updated: MINOR: fixing JavaDocs and other cleanup (#17207)
chia7712
(kafka) branch trunk updated: KAFKA-16331 remove EOSv1 from StreamsProducer (#17212)
chia7712
(kafka) branch trunk updated (bf450ebe5a4 -> 8c2a0619e21)
chia7712
(kafka) branch trunk updated: MINOR: fix generics in streams-test-utils package (#17206)
chia7712
(kafka) branch trunk updated: KAFKA-16331: remove EOSv1 config from StreamsConfig (#17170)
mjsax
(kafka) branch trunk updated: KAFKA-17567 Remove TestTruncate (#17234)
chia7712
(kafka) branch trunk updated: KAFKA-16813 Add global timeout (60s) for `@ClusterTemplate`, `@ClusterTest` and `@ClusterTests` (#16957)
chia7712
(kafka) branch develocity-build-cache created (now a83ff3d0847)
davidarthur
(kafka) 01/01: try writing to the develocity build cache
davidarthur
(kafka) branch trunk updated (57013061c15 -> 3783385dc1c)
davidarthur
(kafka) branch trunk updated: MINOR Fix CI workflow for push event (#17239)
davidarthur
(kafka) branch trunk updated: MINOR Fix is-public-fork input type (#17227)
davidarthur
(kafka) branch trunk updated (ef567bcc3fe -> 8569cf102b9)
chia7712
(kafka) branch trunk updated: MINOR: Group the junit parser console logs (#17229)
chia7712
(kafka) branch trunk updated: KAFKA-17555 uncomment all checks of testCommonNameLoggingTrustManagerMixValidAndInvalidCertificates (#17220)
chia7712
(kafka) branch trunk updated: KAFKA-17579: Dynamic LogCleaner configurations are picked up on restart
clolov
(kafka) branch trunk updated: KAFKA-17553 Fix shutdown race condition in StreamThreadTest (#17191)
chia7712
(kafka) branch trunk updated (09e3c12057b -> 8f5cf9968f3)
chia7712
(kafka) branch 3.9 updated: KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)
cmccabe
(kafka) branch trunk updated: KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)
cmccabe
(kafka) branch 3.9 updated: KAFKA-17048; Update docs for KIP-853 (#17076)
cmccabe
(kafka) branch trunk updated: HOTFIX: add file that was missed from KAFKA-17048 commit
cmccabe
(kafka) branch trunk updated: KAFKA-17048; Update docs for KIP-853 (#17076)
cmccabe
(kafka) branch trunk updated: KAFKA-17559: Fix the flaky RemoteLogOffsetReader#testTaskQueueFullAndCancelTask (#17214)
satishd
(kafka) branch trunk updated: MINOR: Log pending join members (#17219)
dajac
(kafka) branch minor-log-pending-members deleted (was 6ad68fa0384)
dajac
(kafka) branch minor-log-pending-members created (now 6ad68fa0384)
dajac
(kafka) 01/01: MINOR: Log pending join members
dajac
(kafka-site) branch asf-site updated: MINOR: add Colin P. McCabe key (#631)
cmccabe
svn commit: r71713 - /release/kafka/KEYS
cmccabe
(kafka) annotated tag 3.9.0-rc0 updated (8bcdff5b8db -> f2e0955f298)
cmccabe
(kafka) branch trunk updated: KAFKA-17472 Speed Up DescribeConsumerGroupTest (#17117)
chia7712
(kafka) branch 3.9 updated: Revert "KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)" (#17218)
cmccabe
svn commit: r71697 - /release/kafka/KEYS
cmccabe
svn commit: r71694 - /release/kafka/KEYS
cmccabe
(kafka) branch trunk updated: MINOR: update documentation link to 3.9 (#17216)
cmccabe
(kafka) branch 3.9 updated: MINOR: update documentation link to 3.9 (#17216)
cmccabe
(kafka) branch trunk updated: MINOR: fix rawtype warning in StandbyTask (#17203)
mjsax
(kafka) branch trunk updated: KAFKA-16331 Remove EOSv1 from Kafka Streams integration tests (#17110)
chia7712
Earlier messages