jira  

Messages by Thread

• • Re: [PR] KAFKA-18913: Consider removing state-updater feature flag [kafka] via GitHub
  • Re: [PR] KAFKA-18913: Consider removing state-updater feature flag [kafka] via GitHub
  • Re: [PR] KAFKA-18913: Consider removing state-updater feature flag [kafka] via GitHub
  • Re: [PR] KAFKA-18913: Consider removing state-updater feature flag [kafka] via GitHub
  • Re: [PR] KAFKA-18913: Consider removing state-updater feature flag [kafka] via GitHub
  • Re: [PR] KAFKA-18913: Consider removing state-updater feature flag [kafka] via GitHub
• [jira] [Created] (KAFKA-19620) Move AutoTopicCreationManager to server module Kuan Po Tseng (Jira)
• Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
  • Re: [PR] KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully [kafka] via GitHub
• Re: [PR] KAFKA-19599: Reduce the frequency of ReplicaNotAvailableException thrown to clients when RLMM is not ready [kafka] via GitHub
  • Re: [PR] KAFKA-19599: Reduce the frequency of ReplicaNotAvailableException thrown to clients when RLMM is not ready [kafka] via GitHub
  • Re: [PR] KAFKA-19599: Reduce the frequency of ReplicaNotAvailableException thrown to clients when RLMM is not ready [kafka] via GitHub
• Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
  • Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
  • Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
  • Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
  • Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
  • Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
  • Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
  • Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka] via GitHub
• [PR] MINOR: Remove PartitionState [kafka] via GitHub
  • Re: [PR] MINOR: Remove PartitionState [kafka] via GitHub
• [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
• Re: [PR] MINOR: Update apacheds to 2.0.0.AM25 [kafka] via GitHub
  • Re: [PR] MINOR: Update apacheds to 2.0.0.AM25 [kafka] via GitHub
• [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] 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] 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] 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] MINOR: describeTopics should pass the timeout to the describeCluster call [kafka] via GitHub
• [PR] MINOR: Cleanups in jmh-benchmarks module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanups in jmh-benchmarks module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanups in jmh-benchmarks module [kafka] via GitHub
• [jira] [Created] (KAFKA-19619) Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation Adeshina Lasisi (Jira)
• [jira] [Commented] (KAFKA-19323) RemoteTopicCrudTest to use containsKey for topic config checks Ksolves India Limited (Jira)
• [PR] MINOR: Fix typo and docs [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo and docs [kafka] via GitHub
• Re: [PR] KAFKA-19048: Minimal movement replica balancing algorithm for reassignment [kafka] via GitHub
• [jira] [Commented] (KAFKA-18624) Add validation for advertised listeners John Luo (Jira)
• [jira] [Assigned] (KAFKA-18624) Add validation for advertised listeners John Luo (Jira)
• Re: [PR] (WIP) KAFKA-19261 Move ConnectionQuotas to server module [kafka] via GitHub
• [jira] [Assigned] (KAFKA-18447) Support SASL_SSL protocol with java.security.auth.login.config PoAn Yang (Jira)
• Re: [PR] Add `rewrite` support for `RemoveUnusedImports` [kafka] via GitHub
  • Re: [PR] Add `rewrite` support for `RemoveUnusedImports` [kafka] via GitHub
  • Re: [PR] Add `rewrite` support for `RemoveUnusedImports` [kafka] via GitHub
• [jira] [Commented] (KAFKA-17103) MockClient tight loops when no metadata is present in KafkaProducerTest Chang-Yu Huang (Jira)
• [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
  • Re: [PR] MINOR: Change LogCompactionTester topics parameter to Set<String> [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19618) the `record-size` and `throughput`arguments don't work in TestRaftServer Jhen-Yung Hsu (Jira)
• [jira] [Commented] (KAFKA-19618) the `record-size` and `throughput`arguments don't work in TestRaftServer Jhen-Yung Hsu (Jira)
• [jira] [Created] (KAFKA-19618) the `record-size` and `throughput`arguments don't work in TestRaftServer Chia-Ping Tsai (Jira)
• Re: [PR] MINOR: Cleanup Connect Module (3/n) [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Connect Module (3/n) [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Connect Module (3/n) [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Connect Module (3/n) [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Connect Module (3/n) [kafka] via GitHub
• Re: [PR] KAFKA-19144 Move DelayedProduce to server module [kafka] via GitHub
  • Re: [PR] KAFKA-19144 Move DelayedProduce to server module [kafka] via GitHub
  • Re: [PR] KAFKA-19144 Move DelayedProduce to server module [kafka] via GitHub
• [jira] [Reopened] (KAFKA-9965) Uneven distribution with RoundRobinPartitioner in AK 2.4+ Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-9965) Uneven distribution with RoundRobinPartitioner in AK 2.4+ Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-17632) Custom `partitioner.class` with an even number of partitions always writes to even partitions if use RoundRobinPartitioner Chia-Ping Tsai (Jira)
• Re: [PR] (WIP)KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] (WIP)KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
• [PR] Revert "KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)" [kafka] via GitHub
  • Re: [PR] Revert "KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)" [kafka] via GitHub
  • Re: [PR] Revert "KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)" [kafka] via GitHub
  • Re: [PR] MINOR; Revert "KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)" [kafka] via GitHub
• Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
  • Re: [PR] KAFKA-9965/KAFKA-13303: RoundRobinPartitioner broken by KIP-480 [kafka] via GitHub
• [jira] [Commented] (KAFKA-19042) Move kafka.api test cases to clients-integration-tests module Lianet Magrans (Jira)
  • [jira] [Commented] (KAFKA-19042) Move kafka.api test cases to clients-integration-tests module PoAn Yang (Jira)
• [jira] [Assigned] (KAFKA-19616) add compression type and level to log_compaction_test.py Yunchi Pang (Jira)
• [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: remove topicPartitions from TransactionMetadata constructor [kafka] via GitHub
  • Re: [PR] MINOR: update TransactionLog#readTxnRecordValue to initialize TransactionMetadata with non-empty topic partitions [kafka] via GitHub
  • Re: [PR] MINOR: update TransactionLog#readTxnRecordValue to initialize TransactionMetadata with non-empty topic partitions [kafka] via GitHub
  • Re: [PR] MINOR: update TransactionLog#readTxnRecordValue to initialize TransactionMetadata with non-empty topic partitions [kafka] via GitHub
• [jira] [Updated] (KAFKA-19610) add integration tests for Consumer#currentLag Kirk True (Jira)
  • [jira] [Updated] (KAFKA-19610) add integration tests for Consumer#currentLag Kirk True (Jira)
• [jira] [Updated] (KAFKA-19617) ConsumerPerformance#ConsumerPerfRebListener get corrupted value when the number of partitions is increased Kirk True (Jira)
• [PR] KAFKA-19613: Expose CorruptRecordException to client [kafka] via GitHub
  • Re: [PR] KAFKA-19613: Expose CorruptRecordException to client [kafka] via GitHub
  • Re: [PR] KAFKA-19613: Expose CorruptRecordException for consumer [kafka] via GitHub
  • Re: [PR] KAFKA-19613: Expose CorruptRecordException for consumer [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-18470) Race conditions when accessing RecordHeader data Ming-Yen Chung (Jira)
• [jira] [Commented] (KAFKA-18470) Race conditions when accessing RecordHeader data Ming-Yen Chung (Jira)
• [PR] MINOR: Refactor snapshottableSize method for better readability and simplicity [kafka] via GitHub
  • Re: [PR] MINOR: Refactor snapshottableSize method for better readability and simplicity [kafka] via GitHub
  • Re: [PR] MINOR: Refactor snapshottableSize method for better readability and simplicity [kafka] via GitHub
• [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
  • Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
  • Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
  • Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
  • Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
  • Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
  • Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
• [jira] [Created] (KAFKA-19617) ConsumerPerformance#ConsumerPerfRebListener get corrupted value when the number of partitions is increased Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-19617) ConsumerPerformance#ConsumerPerfRebListener get corrupted value when the number of partitions is increased Lan Ding (Jira)
• Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
  • Re: [PR] KAFKA-19498: Add include argument to ConsumerPerformance tool [kafka] via GitHub
• [PR] KIP-780: Support fine-grained compression options [kafka] via GitHub
  • Re: [PR] KIP-780: Support fine-grained compression options [kafka] via GitHub
• [jira] [Updated] (KAFKA-19616) add compression type and level to log_compaction_test.py Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19616) add compression type and level to log_compaction_test.py Chia-Ping Tsai (Jira)
• Re: [PR] MINOR: Add project icon for `IntelliJ IDEA` [kafka] via GitHub
  • Re: [PR] MINOR: Add project icon for `IntelliJ IDEA` [kafka] via GitHub
  • Re: [PR] MINOR: Add project icon for `IntelliJ IDEA` [kafka] via GitHub
• [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
  • Re: [PR] MINOR: Move RaftManager interface to raft module [kafka] via GitHub
• [jira] [Commented] (KAFKA-17302) ReplicaFetcher changes for fetching from tiered offset Abhijeet Kumar (Jira)
• Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
  • Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka] via GitHub
• [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Empty Follower Fetch Tests [kafka] via GitHub
  • Re: [PR] KAFKA-17344: Add empty replica FollowerFetch tests [kafka] via GitHub
• [PR] KAFKA-17266: Add dynamic broker config to enable follower fetch using tiered offset [kafka] via GitHub
• [PR] KAFKA-17108: Earliest pending upload offset [kafka] via GitHub
  • Re: [PR] KAFKA-17108: Earliest pending upload offset [kafka] via GitHub

• Earlier messages
• Later messages