jira  

Messages by Thread

• • Re: [PR] MINOR: Add Docker version requirement and permission warning to README [kafka] via GitHub
  • Re: [PR] MINOR: Add Docker version requirement and permission warning to README [kafka] via GitHub
• Re: [PR] [WIP] KAFKA-18279: add JDK 11 check and test for clients and streams module [kafka] via GitHub
• Re: [PR] Fix IllegalStateException for Transaction Producer [kafka] via GitHub
  • Re: [PR] Fix IllegalStateException for Transaction Producer [kafka] via GitHub
• Re: [PR] KAFKA-17411: Use shared cache for Task offset sums [kafka] via GitHub
  • Re: [PR] KAFKA-17411: Use shared cache for Task offset sums [kafka] via GitHub
• [PR] MINOR: Replace `singleton` with `Set.of` in the SubscriptionStateTest [kafka] via GitHub
  • Re: [PR] MINOR: Replace `singleton` with `Set.of` in the SubscriptionStateTest [kafka] via GitHub
  • Re: [PR] MINOR: Replace `singleton` with `Set.of` in the SubscriptionStateTest [kafka] via GitHub
  • Re: [PR] MINOR: Replace `singleton` with `Set.of` in the SubscriptionStateTest [kafka] via GitHub
• [PR] KAFKA-19416: Reduce running time of ShareConsumerTest [kafka] via GitHub
  • Re: [PR] KAFKA-19416: Reduce running time of ShareConsumerTest [kafka] via GitHub
• [PR] KAFKA-19367-Follow-up-cherry-pick-to-4.0 [kafka] via GitHub
  • Re: [PR] KAFKA-19367-Follow-up-cherry-pick-to-4.0 [kafka] via GitHub
• [jira] [Created] (KAFKA-19419) MaxMessageTimestamp JMX metric per (topic, partition) Ryan Stull (Jira)
• [jira] [Updated] (KAFKA-19415) Improve fairness of partition fetch order when clients fetch data to avoid partition starvation corkitse (Jira)
  • [jira] [Updated] (KAFKA-19415) Improve fairness of partition fetch order when clients fetch data to avoid partition starvation corkitse (Jira)
• [PR] Shuffle the order of readPartitionInfo when fetching data. [kafka] via GitHub
  • Re: [PR] KAFKA-19415 Shuffle the order of readPartitionInfo when fetching data. [kafka] via GitHub
• [jira] [Updated] (KAFKA-19308) Improve OAuth unit testing based on code coverage analysis Kirk True (Jira)
• Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
  • Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
• [jira] [Updated] (KAFKA-19418) Verifiable producer sys test should consider process name to avoid flakiness Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-19418) Verifiable producer sys test should consider process name to avoid flakiness Lianet Magrans (Jira)
• [jira] [Commented] (KAFKA-16706) Refactor ReplicationQuotaManager/RLMQuotaManager to eliminate code duplication Ksolves India Limited (Jira)
• [jira] [Comment Edited] (KAFKA-16706) Refactor ReplicationQuotaManager/RLMQuotaManager to eliminate code duplication Ksolves India Limited (Jira)
• [PR] MINOR: document deprecated remote log manager thread pool config [kafka] via GitHub
  • Re: [PR] MINOR: document deprecated remote log manager thread pool config [kafka] via GitHub
  • Re: [PR] MINOR: document deprecated remote log manager thread pool config [kafka] via GitHub
• [jira] [Updated] (KAFKA-18627) add allowed modules to JaasUtils Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18627) add allowed modules to JaasUtils Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19417) Clear static member assignment on join with different subscription Sean Quah (Jira)
• [jira] [Commented] (KAFKA-19414) Remove Public APIs from 4.1 Mickael Maison (Jira)
• [PR] KAFKA-10357 Add Internal Topic Exceptions [kafka] via GitHub
  • Re: [PR] KAFKA-10357 Add Internal Topic Exceptions [kafka] via GitHub
  • Re: [PR] KAFKA-10357: Add new Kafka Streams exception classes [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19416) Reduce running time of ShareConsumerTest Andrew Schofield (Jira)
• [jira] [Commented] (KAFKA-19416) Reduce running time of ShareConsumerTest Lan Ding (Jira)
  • [jira] [Commented] (KAFKA-19416) Reduce running time of ShareConsumerTest Mahesh Sambaram (Jira)
• [jira] [Created] (KAFKA-19416) Reduce running time of ShareConsumerTest Andrew Schofield (Jira)
• [PR] KAFKA-18926 KafkaPrincipalBuilder should extend KafkaPrincipalSerde [kafka] via GitHub
  • Re: [PR] KAFKA-18926 KafkaPrincipalBuilder should extend KafkaPrincipalSerde [kafka] via GitHub
• [PR] MINOR : Fix possible flake in ShareConsumerTest:testConsumerCloseInGroupSequential [kafka] via GitHub
  • Re: [PR] MINOR : Fix possible flake in ShareConsumerTest:testConsumerCloseInGroupSequential [kafka] via GitHub
• [jira] [Assigned] (KAFKA-18926) `KafkaPrincipalBuilder` should extend `KafkaPrincipalSerde` Szu-Yung Wang (Jira)
• [jira] [Created] (KAFKA-19415) Improve fairness of partition fetch order when clients fetch data to avoid partition starvation corkitse (Jira)
• Re: [PR] KAFKA-18966: Change controller_num_nodes_override to override_num_isolated_controllers [kafka] via GitHub
• Re: [PR] MINOR Capture heap dump after OOM on CI [kafka] via GitHub
• Re: [PR] [WIP] KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread. [kafka] via GitHub
  • Re: [PR] [WIP] KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread. [kafka] via GitHub
  • Re: [PR] [WIP] KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread. [kafka] via GitHub
  • Re: [PR] [WIP] KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread. [kafka] via GitHub
• Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
  • Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
  • Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
  • Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
  • Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
  • Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
  • Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
  • Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka] via GitHub
• Re: [PR] Bump requests from 2.31.0 to 2.32.4 in /tests [kafka] via GitHub
• Re: [PR] KAFKA-19395 - Updated Junit and mockito version and license information in NOTICE-binary for Jakarta RESTful Web Services Project [kafka] via GitHub
  • Re: [PR] KAFKA-19395 - Updated Junit and mockito version and license information in NOTICE-binary for Jakarta RESTful Web Services Project [kafka] via GitHub
  • Re: [PR] KAFKA-19395 - Updated Junit and mockito version and license information in NOTICE-binary for Jakarta RESTful Web Services Project [kafka] via GitHub
• [PR] KAFKA-19414: Remove 2PC public APIs from 4.1 until release (KIP-939) [kafka] via GitHub
  • Re: [PR] KAFKA-19414: Remove 2PC public APIs from 4.1 until release (KIP-939) [kafka] via GitHub
• [jira] [Updated] (KAFKA-19414) Remove Public APIs from 4.1 Ritika Reddy (Jira)
  • [jira] [Updated] (KAFKA-19414) Remove Public APIs from 4.1 Ritika Reddy (Jira)
  • [jira] [Updated] (KAFKA-19414) Remove Public APIs from 4.1 Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19414) Remove Public APIs from 4.1 Ritika Reddy (Jira)
• [jira] [Resolved] (KAFKA-19082) Client side changes to enable 2PC Ritika Reddy (Jira)
• Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka] via GitHub
  • Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka] via GitHub
  • Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka] via GitHub
  • Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka] via GitHub
  • Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka] via GitHub
• [PR] initial POC of disk full implementation [kafka] via GitHub
  • Re: [PR] initial POC of disk full implementation [kafka] via GitHub
• [jira] [Updated] (KAFKA-19021) Broker should not be allowed to be promoted to controller Jira
• [jira] [Updated] (KAFKA-19223) Explicit HWM replication Jira
• [jira] [Resolved] (KAFKA-18818) Significant delay in Metadata Update After Admin Client Operations in KRaft Mode Jira
• [jira] [Resolved] (KAFKA-19223) Explicit HWM replication Jira
• [jira] [Resolved] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions Jira
• [jira] [Updated] (KAFKA-18818) Significant delay in Metadata Update After Admin Client Operations in KRaft Mode Jira
• [jira] [Resolved] (KAFKA-18751) Complete delayed FETCH request when HWM is increased. Jira
• [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
  • Re: [PR] KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19350) don't propagate the error caused by CreateTopicPolicy to FatalFaultHandler Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-19078: Implement automatic controller addition to cluster metadata partition [kafka] via GitHub
  • Re: [PR] KAFKA-19078: Implement automatic controller addition to cluster metadata partition [kafka] via GitHub
• [jira] [Updated] (KAFKA-19412) Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat Matthias J. Sax (Jira)
• [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
  • Re: [PR] KAFKA-19400: Update AddRaftVoterRequest RPC to version 1 [kafka] via GitHub
• [PR] KAFKA-19413: Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe [kafka] via GitHub
  • Re: [PR] KAFKA-19413: Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe [kafka] via GitHub
  • Re: [PR] KAFKA-19413: Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe [kafka] via GitHub
• [jira] [Updated] (KAFKA-14410) Allow connect runtime to run multiple versions of a connector. Greg Harris (Jira)
  • [jira] [Updated] (KAFKA-14410) Allow connect runtime to run multiple versions of a connector. Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-14895) Move AddPartitionsToTxnManager files to java Chia-Ping Tsai (Jira)
• [PR] KAFKA-19259: Async consumer fetch intermittent delays on console consumer [kafka] via GitHub
• [PR] MINOR: Add entity types in streams group RPCs [kafka] via GitHub
  • Re: [PR] MINOR: Add entity types in streams group RPCs [kafka] via GitHub
• [jira] [Commented] (KAFKA-15207) ProducerIdManager#generateProducerId() should return different error code for newer clients Abhi (Jira)
• Re: [PR] KAFKA-19350 Don't propagate the error caused by CreateTopicPolicy to FatalFaultHandler [kafka] via GitHub
  • Re: [PR] KAFKA-19350 Don't propagate the error caused by CreateTopicPolicy to FatalFaultHandler [kafka] via GitHub
• [PR] KAFKA-19412: Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat [kafka] via GitHub
  • Re: [PR] KAFKA-19412: Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat [kafka] via GitHub
  • Re: [PR] KAFKA-19412: Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat [kafka] via GitHub
  • Re: [PR] KAFKA-19412: Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat [kafka] via GitHub
  • Re: [PR] KAFKA-19412: Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19412) Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat Lucas Brutschy (Jira)
• [jira] [Assigned] (KAFKA-19413) Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-19413) Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-19412) Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat Lucas Brutschy (Jira)
• [jira] [Commented] (KAFKA-15125) Break down SocketServer classes into separate files Ksolves India Limited (Jira)
• [jira] [Assigned] (KAFKA-19020) Handle strict max fetch records in share fetch Apoorv Mittal (Jira)
• [jira] [Commented] (KAFKA-17136) Added Documentation for Shell Methods Ksolves India Limited (Jira)
  • [jira] [Commented] (KAFKA-17136) Added Documentation for Shell Methods Ksolves India Limited (Jira)
• [jira] [Commented] (KAFKA-18838) Fix ArbitraryMemoryRecords so that they are always invalid Abhi (Jira)
• [PR] KAFKA-19362: Finalize homogeneous simple share assignor [kafka] via GitHub
  • Re: [PR] KAFKA-19362: Finalize homogeneous simple share assignor [kafka] via GitHub
  • Re: [PR] KAFKA-19362: Finalize homogeneous simple share assignor [kafka] via GitHub
  • Re: [PR] KAFKA-19362: Finalize homogeneous simple share assignor [kafka] via GitHub
  • Re: [PR] KAFKA-19362: Finalize homogeneous simple share assignor [kafka] via GitHub
• Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19381) Add a ConfigDef.ConfigKey builder Mahesh Sambaram (Jira)
• [jira] [Commented] (KAFKA-19020) Handle strict max fetch records in share fetch Jimmy Wang (Jira)
• [jira] [Assigned] (KAFKA-19406) Remove BrokerTopicStats#removeOldFollowerMetrics xuanzhang gong (Jira)
• [jira] [Commented] (KAFKA-19406) Remove BrokerTopicStats#removeOldFollowerMetrics Jimmy Wang (Jira)
  • [jira] [Commented] (KAFKA-19406) Remove BrokerTopicStats#removeOldFollowerMetrics Chia-Ping Tsai (Jira)
  • [jira] [Commented] (KAFKA-19406) Remove BrokerTopicStats#removeOldFollowerMetrics xuanzhang gong (Jira)
• Re: [PR] MINOR: describeTopics should pass the timeout to the describeCluster call [kafka] via GitHub
  • Re: [PR] MINOR: describeTopics should pass the timeout to the describeCluster call [kafka] via GitHub
  • Re: [PR] MINOR: describeTopics should pass the timeout to the describeCluster call [kafka] via GitHub
• Re: [PR] Add a SelectorProvider that reuses custom provider implementations. [kafka] via GitHub
  • Re: [PR] Add a SelectorProvider that reuses custom provider implementations. [kafka] via GitHub
• Re: [PR] MINOR: Update Protocol Buffers documentation URLs [kafka] via GitHub
• Re: [PR] Update EndToEndLatency.java [kafka] via GitHub
• [jira] [Assigned] (KAFKA-18812) Improve new consumer API errors upon background thread failures TengYao Chi (Jira)
• [PR] KAFKA-19367: Follow up bug fix [kafka] via GitHub
  • Re: [PR] KAFKA-19367: Follow up bug fix [kafka] via GitHub
  • Re: [PR] KAFKA-19367: Follow up bug fix [kafka] via GitHub
• [jira] [Assigned] (KAFKA-15307) Kafka Streams configuration docs outdated Matthias J. Sax (Jira)
• [PR] MINOR: replace test "catch exception" by assertThrows [kafka] via GitHub
  • Re: [PR] MINOR: replace test "catch exception" by assertThrows [kafka] via GitHub
  • Re: [PR] MINOR: replace test "catch exception" by assertThrows [kafka] via GitHub
  • Re: [PR] MINOR: replace test "catch exception" by assertThrows [kafka] via GitHub
  • Re: [PR] MINOR: replace test "catch exception" by assertThrows [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19410) Validate alignment of subscribed topics and assigned partitions in share consumer PoAn Yang (Jira)
• [jira] [Assigned] (KAFKA-19411) Delete ACLs records can exceed max records per user op Alyssa Huang (Jira)
• [PR] Fix deleteAcls bug which allows more deletions than max records per user op [kafka] via GitHub
  • Re: [PR] KAFKA-19411: Fix deleteAcls bug which allows more deletions than max records per user op [kafka] via GitHub
  • Re: [PR] KAFKA-19411: Fix deleteAcls bug which allows more deletions than max records per user op [kafka] via GitHub

• Earlier messages
• Later messages