Messages by Thread
-
[jira] [Created] (KAFKA-19321) Add share_consumer_performance.py and related system tests
Chirag Wadhwa (Jira)
-
[jira] [Created] (KAFKA-19320) Add share_consume_bench_test.py system tests
Chirag Wadhwa (Jira)
-
[jira] [Assigned] (KAFKA-19266) Eliminate flakiness in test SharePartitionTest.testAcquisitionLockTimeoutForBatchesPostStartOffsetMovement
Apoorv Mittal (Jira)
-
[PR] fix separator for different systems [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-18783) Extend InvalidConfigurationException related exceptions
Kaushik Raina (Jira)
-
Re: [PR] MINOR: add 3.9.1 to system tests [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19319) Don't reset election timeout for prospective on transition to prospectiveVoted
Alyssa Huang (Jira)
-
[PR] (WIP)KAFKA-19239 Rewrite IntegrationTestUtils by java [kafka]
via GitHub
-
[PR] MINOR: Cleanups in Test Common Module [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-19318) Zookeeper-Kraft failing migration - RPC got timed out before it could be sent
dennis lucero (Jira)
-
[jira] [Created] (KAFKA-19318) Zookeeper-Kraft failing migration - RPC got timed out before it could be sent
dennis lucero (Jira)
-
[PR] KAFKA-19316: added share_group_command_test.py system tests [kafka]
via GitHub
-
[PR] KAFKA-19042: [10/N] Move PlaintextConsumerAssignTest to clients-integration-tests module [kafka]
via GitHub
-
[PR] MINOR: Cleanup Shell Module [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-19317) Fix flaky test : ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()
Shivsundar R (Jira)
-
[jira] [Created] (KAFKA-19317) Fix flaky test : ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()
Shivsundar R (Jira)
-
[PR] MINOR: Cleanup Share Coordinator [kafka]
via GitHub
-
Re: [PR] MINOR Fix: API Responses missing latest version in Kafka protocol guide [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-17207) ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), leaking clients
Francis Godinho (Jira)
-
Re: [PR] KAFKA-18647: Clarify Windows support in Quick Start Guide [kafka]
via GitHub
-
Re: [PR] KAFKA-17411: Use shared cache for Task offset sums [kafka]
via GitHub
-
[PR] MINOR: Add more description to KIP-1148 [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-13610) Remove `log.cleaner.enable` and set lower bound 1 to `log.cleaner.threads`
TengYao Chi (Jira)
-
[PR] KAFKA-19313: Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET [kafka]
via GitHub
-
[PR] MINOR: Update the supported tags in docker_scan.yml [kafka]
via GitHub
-
[PR] (WIP) KAFKA-18486: Remove ReplicaManager#becomeLeaderOrFollower (2/N) [kafka]
via GitHub
-
[PR] KAFKA-7516: Attempt to dynamically load ManagementFactory [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-19316) Add share_group_command_test.py system test
Chirag Wadhwa (Jira)
-
[jira] [Created] (KAFKA-19316) Add share_consumer_group_command_test.py system test
Chirag Wadhwa (Jira)
-
[jira] [Assigned] (KAFKA-19315) Move ControllerMutationQuotaManager to server module
Chang Chi Hsu (Jira)
-
[jira] [Created] (KAFKA-19315) Move ControllerMutationQuotaManager to server module
Chia-Ping Tsai (Jira)
-
[PR] Kafka-19314: Remove unnecessary code of closing snapshotWriter [kafka]
via GitHub
-
[PR] KAFKA-15599: Move KafkaMetadataLog to the raft module [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-19314) Remove unnecessary code of closing snapshotWriter
Jing-Jia Hung (Jira)
-
[jira] [Created] (KAFKA-19314) Remove unnecessary code of closing snapshotWriter
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-17747: Replace subscription metadata with metadata hash in consumer group (wip) [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-19302) Move ReplicaState and Replica to server module
Chia-Ping Tsai (Jira)
-
Re: [PR] KAFKA-19302: Move ReplicaState and Replica to server module [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19313) Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-19313) Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET
Yu-Syuan Jheng (Jira)
-
[PR] KAFKA-19312: Avoiding concurrent execution of onComplete and tryComplete [kafka]
via GitHub
-
[PR] MINOR: update the gradle version for java 24 support [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19312) Share partition fetch locks concurrent thread release
Apoorv Mittal (Jira)
-
[PR] KAFKA-19291: Increase the timeout of remote storage share fetch requests in purgatory [kafka]
via GitHub
-
Re: [PR] KAFKA-18783 : Extend InvalidConfigurationException related exceptions [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-16355) ConcurrentModificationException in InMemoryTimeOrderedKeyValueBuffer.evictWhile
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-19311) Document the different behaviors of commitAsync between classic consumer and async consumer
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-19311) Document the different behaviors of commitAsync between classic consumer and async consumer
Ming-Yen Chung (Jira)
-
[PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete all groups) [2/N] [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19310) Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing
Abhinav Dixit (Jira)
-
Re: [PR] KAFKA-19289: Read only disk failure, ReplicaManager.scala's logManager.handleLogDirFailure(dir) not capturing exception correctly, interrupt process causing topic with multiple copies partition leader failure not switching. [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-19217) ShareConsumerTest.testComplexShareConsumer is unreliable
Apoorv Mittal (Jira)
-
[PR] MINOR: Update 3.9.1 versions [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-19226) Add test_console_share_consumer system test
Apoorv Mittal (Jira)
-
[jira] [Assigned] (KAFKA-16355) ConcurrentModificationException in InMemoryTimeOrderedKeyValueBuffer.evictWhile
Mickael Maison (Jira)
-
[jira] [Assigned] (KAFKA-19276) Trigger rebalance when assignment related configurations are updated
Uladzislau Blok (Jira)
-
[jira] [Closed] (KAFKA-19289) Read only disk failure, ReplicaManager.scala's logManager.handleLogDirFailure(dir) not capturing exception correctly, interrupt process causing topic with multiple copies partition leader failure not switching.
felixzh (Jira)
-
[jira] [Resolved] (KAFKA-17894) Additional metrics for cooperative consumption
Apoorv Mittal (Jira)
-
[jira] [Created] (KAFKA-19309) Add transaction client template code in kafka examples
Kaushik Raina (Jira)
-
[jira] [Updated] (KAFKA-19308) Improve OAuth unit testing based on code coverage analysis
Kirk True (Jira)
-
[jira] [Created] (KAFKA-19308) Improve OAuth unit testing based on code coverage analysis
Kirk True (Jira)
-
[jira] [Updated] (KAFKA-19307) Improve OAuthCompatibilityTool ergonomics
Kirk True (Jira)
-
[jira] [Created] (KAFKA-19307) Improve OAuthCompatibilityTool ergonomics
Kirk True (Jira)
-
[jira] [Assigned] (KAFKA-19306) Migrate LogCompactionTester to tool module
Yunchi Pang (Jira)
-
[jira] [Commented] (KAFKA-19306) Migrate LogCompactionTester to tool module
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-19306) Migrate LogCompactionTester to tool module
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-19305) Ensure all image classes are immutable
Chang Chi Hsu (Jira)
-
[jira] [Created] (KAFKA-19305) Ensure all image classes are immutable
Chia-Ping Tsai (Jira)
-
Re: [PR] KAFKA-19042: [9/N] Move GroupAuthorizerIntegrationTest to clients-integration-tests module [kafka]
via GitHub
-
[PR] KAFKA-18903: update-cache.sh use curl + jq to get sha contains gradle cache instead of gh cli [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-19286) RemoteIndexCacheTest.testConcurrentRemoveReadForCache1 is flaky
Uladzislau Blok (Jira)
-
[PR] KAFKA-19303 Move VerifiableProperties to server-common module [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19304) Move KafkaMetricsConfig to server module
Jira
-
[jira] [Updated] (KAFKA-19304) Move KafkaMetricsConfig to server module
Jira
-
[jira] [Created] (KAFKA-19303) Move VerifiableProperties to server-common module
Jira
-
[jira] [Updated] (KAFKA-19303) Move VerifiableProperties to server-common module
Jira
-
[jira] [Comment Edited] (KAFKA-18883) Move TransactionLog to transaction-coordinator module
TaiJuWu (Jira)
-
[jira] [Commented] (KAFKA-19276) Trigger rebalance when assignment related configurations are updated
Uladzislau Blok (Jira)
-
[jira] [Commented] (KAFKA-19261) Move ConnectionQuotas to server module
Uladzislau Blok (Jira)
-
[jira] [Commented] (KAFKA-18727) Move RequestChannel to server module
Uladzislau Blok (Jira)
-
[jira] [Commented] (KAFKA-18883) Move TransactionLog to transaction-coordinator module
Uladzislau Blok (Jira)
-
Re: [PR] MINOR: Refactor shared-group request handle methods to return CompletableFuture for consistent error handling [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19302) Move ReplicaState and Replica to server module
PoAn Yang (Jira)
-
[jira] [Created] (KAFKA-19301) Move PartitionListener, AlterPartitionListener, DelayedOperations, AssignmentState, PartitionState, and PendingPartitionChange to server module
PoAn Yang (Jira)
-
[PR] KAFKA-15370: Support Participation in 2PC (KIP-939) (K/N) [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-19300) AsyncConsumer#unsubscribe always timeout due to GroupAuthorizationException
Nick Guo (Jira)
-
[jira] [Commented] (KAFKA-19300) AsyncConsumer#unsubscribe always timeout due to GroupAuthorizationException
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-19300) AsyncConsumer#unsubscribe always timeout due to GroupAuthorizationException
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-19300) AsyncConsumer#unsubscribe always timeout due to GroupAuthorizationException
Chia-Ping Tsai (Jira)
-
[PR] Kafka 18913/cleanup state updater on failure [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer
Uladzislau Blok (Jira)
-
[jira] [Assigned] (KAFKA-19299) Fix flaky RemoteIndexCacheTest#testCacheEntryIsDeletedOnRemoval
Uladzislau Blok (Jira)
-
Re: [PR] KAFKA-4650: Add unit tests for GraphNode class [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19299) Fix flaky RemoteIndexCacheTest#testCacheEntryIsDeletedOnRemoval
PoAn Yang (Jira)
-
[jira] [Assigned] (KAFKA-19298) Move RuntimeLoggerManager to server module
Cheng Yi Chang (Jira)
-
[PR] MINOR: document group coordinator metrics [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-13333) Optimize condition for triggering rebalance after wiping out corrupted task
Colt McNealy (Jira)
-
[jira] [Created] (KAFKA-19298) Move RuntimeLoggerManager to server module
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-18573: Add support for OAuth jwt-bearer grant type [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-18139) AsyncKafkaConsumer's ConsumerNetworkThread loop requires further optimization
Kirk True (Jira)
-
[jira] [Updated] (KAFKA-18573) Add support for OAuth jwt-bearer grant type
Kirk True (Jira)
-
[jira] [Created] (KAFKA-19297) Refactor AsyncKafkaConsumer's use of Java Streams APIs in critical sections
Kirk True (Jira)
-
[jira] [Updated] (KAFKA-19296) Revise AsyncKafkaConsumer event wakeup approach
Kirk True (Jira)
-
[jira] [Created] (KAFKA-19296) Revise AsyncKafkaConsumer event wakeup approach
Kirk True (Jira)
-
[jira] [Updated] (KAFKA-19295) Remove AsyncKafkaConsumer event ID generation
Kirk True (Jira)
-
[PR] KAFKA-18345: Part two, remove exponential backoff for candidate state [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19295) Remove AsyncKafkaConsumer event ID generation
Kirk True (Jira)
-
Re: [PR] KAFKA-18847: Refactor OAuth layer to improve reusability 2/N [kafka]
via GitHub
-
Re: [PR] KAFKA-19082:[4/4] Complete Txn Client Side Changes (KIP-939) [kafka]
via GitHub