jira  

Messages by Thread

• • Re: [PR] MINOR: Add project icon for `IntelliJ IDEA` [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19530) RemoteLogManager should record lag stats when remote storage is offline Kamal Chandraprakash (Jira)
• [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Trogdor Module [kafka] via GitHub
• Re: [PR] KAFKA-19340: Move DelayedRemoteFetch to the storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19340: Move DelayedRemoteFetch to the storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19340: Move DelayedRemoteFetch to the storage module [kafka] via GitHub
• [PR] KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes [kafka] via GitHub
  • Re: [PR] KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes [kafka] via GitHub
  • Re: [PR] KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes [kafka] via GitHub
  • Re: [PR] KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes [kafka] via GitHub
  • Re: [PR] KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes [kafka] via GitHub
• Re: [PR] KAFKA-19272: Add initPid Response handling when keepPrepared is set to true (KIP-939) [kafka] via GitHub
  • Re: [PR] KAFKA-19272: Add initPid Response handling when keepPrepared is set to true (KIP-939) [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees Shashank (Jira)
• [jira] [Assigned] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees Shashank (Jira)
• [jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees Shashank (Jira)
  • [jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees Shashank (Jira)
  • [jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees Shashank (Jira)
• [PR] KAFKA-10840: Expose authentication failures in KafkaConsumer.poll() [kafka] via GitHub
  • Re: [PR] KAFKA-10840: Expose authentication failures in KafkaConsumer.poll() [kafka] via GitHub
  • Re: [PR] KAFKA-10840: Expose authentication failures in KafkaConsumer.poll() [kafka] via GitHub
  • Re: [PR] KAFKA-10840: Expose authentication failures in KafkaConsumer.poll() [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch Kevin Wu (Jira)
  • [jira] [Assigned] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch Kevin Wu (Jira)
  • [jira] [Assigned] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch Kevin Wu (Jira)
  • [jira] [Assigned] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch tony tang (Jira)
• [jira] [Commented] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch Kevin Wu (Jira)
  • [jira] [Commented] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch Tony tang (Jira)
• [jira] [Created] (KAFKA-19532) Kafka request metric discrepancies Jess (Jira)
• [PR] KAFKA-19527: improve the docs of LogDirDescription for remote storage [kafka] via GitHub
  • Re: [PR] KAFKA-19527: improve the docs of LogDirDescription for remote storage [kafka] via GitHub
  • Re: [PR] KAFKA-19527: improve the docs of LogDirDescription for remote storage [kafka] via GitHub
  • Re: [PR] KAFKA-19527: improve the docs of LogDirDescription for remote storage [kafka] via GitHub
• [PR] MINOR: fix test method [kafka] via GitHub
  • Re: [PR] MINOR: Fix StreamThreadTest [kafka] via GitHub
• Re: [PR] KAFKA-19276: Trigger rebalance for streams config update [kafka] via GitHub
  • Re: [PR] KAFKA-19276: Trigger rebalance for streams config update [kafka] via GitHub
  • Re: [PR] KAFKA-19276: Trigger rebalance for streams config update [kafka] via GitHub
  • Re: [PR] KAFKA-19276: Trigger rebalance for streams config update [kafka] via GitHub
• Re: [PR] WIP: Optimizing the sticky assingor [kafka] via GitHub
  • Re: [PR] WIP: Optimizing the sticky assingor [kafka] via GitHub
• [jira] [Commented] (KAFKA-19487) Improve consistency of command-line arguments ally heev (Jira)
  • [jira] [Commented] (KAFKA-19487) Improve consistency of command-line arguments Andrew Schofield (Jira)
  • [jira] [Commented] (KAFKA-19487) Improve consistency of command-line arguments ally heev (Jira)
  • [jira] [Commented] (KAFKA-19487) Improve consistency of command-line arguments ally heev (Jira)
  • [jira] [Commented] (KAFKA-19487) Improve consistency of command-line arguments Andrew Schofield (Jira)
• Re: [PR] KAFKA-19478 [3/N]: Use heaps to discover the least loaded process [kafka] via GitHub
  • Re: [PR] KAFKA-19478 [3/N]: Use heaps to discover the least loaded process [kafka] via GitHub
  • Re: [PR] KAFKA-19478 [3/N]: Use heaps to discover the least loaded process [kafka] via GitHub
  • Re: [PR] KAFKA-19478 [3/N]: Use heaps to discover the least loaded process [kafka] via GitHub
• [jira] [Commented] (KAFKA-19531) Add an end-to-end integration test for the DLQ feature Mahesh Sambaram (Jira)
• [jira] [Created] (KAFKA-19531) Add an end-to-end integration test for the DLQ feature Lucas Brutschy (Jira)
• [jira] [Commented] (KAFKA-19530) RemoteLogManager should record lag stats when remote storage is offline Jira
  • [jira] [Commented] (KAFKA-19530) RemoteLogManager should record lag stats when remote storage is offline Kamal Chandraprakash (Jira)
• [PR] MINOR: Change log level for cold snapshot log. [kafka] via GitHub
  • Re: [PR] MINOR: Change log level for cold snapshot log. [kafka] via GitHub
• [jira] [Created] (KAFKA-19530) RemoteLogManager should record lag stats when remote storage is offline Kamal Chandraprakash (Jira)
• [jira] [Assigned] (KAFKA-19399) The version and source link in the `NOTICE-binary` file for `Mockito` are inconsistent Palak Kapoor (Jira)
• [jira] [Comment Edited] (KAFKA-19528) Release script does not handle doing multiple release candidates Mahesh Sambaram (Jira)
• [jira] [Commented] (KAFKA-19528) Release script does not handle doing multiple release candidates Mahesh Sambaram (Jira)
  • [jira] [Commented] (KAFKA-19528) Release script does not handle doing multiple release candidates Mahesh Sambaram (Jira)
  • [jira] [Commented] (KAFKA-19528) Release script does not handle doing multiple release candidates Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-19528) Release script does not handle doing multiple release candidates Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-19529) State updater does not always seem to remove all metrics Lucas Brutschy (Jira)
  • [jira] [Updated] (KAFKA-19529) State updater does not always seem to remove all metrics Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-19529) State updater does not always seem to remove all metrics Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-19529) State updater does not always seem to remove all metrics Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-19528) Release script does not handle doing multiple release candidates Mickael Maison (Jira)
• Re: [PR] KAFKA-19493: Incorrect rate metric with larger window size [kafka] via GitHub
  • Re: [PR] KAFKA-19493: Incorrect rate metric with larger window size [kafka] via GitHub
  • Re: [PR] KAFKA-19493: Incorrect rate metric with larger window size [kafka] via GitHub
  • Re: [PR] KAFKA-19493: Incorrect rate metric with larger window size [kafka] via GitHub
  • Re: [PR] KAFKA-19493: Incorrect rate metric with larger window size [kafka] via GitHub
• [PR] KAFKA-19503: Deprecate MX4j support [kafka] via GitHub
  • Re: [PR] KAFKA-19503: Deprecate MX4j support [kafka] via GitHub
  • Re: [PR] KAFKA-19503: Deprecate MX4j support [kafka] via GitHub
  • Re: [PR] KAFKA-19503: Deprecate MX4j support [kafka] via GitHub
  • Re: [PR] KAFKA-19503: Deprecate MX4j support [kafka] via GitHub
  • Re: [PR] KAFKA-19503: Deprecate MX4j support [kafka] via GitHub
• [PR] KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19476) Improve state transition handling in SharePartition Apoorv Mittal (Jira)
• [jira] [Commented] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests Ksolves India Limited (Jira)
  • [jira] [Commented] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests Ksolves India Limited (Jira)
  • [jira] [Commented] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests Evgeny Ushakov (Jira)
  • [jira] [Commented] (KAFKA-16801) Streams upgrade :test target doesn't find any junit tests Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-19503) Deprecate MX4j support Federico Valeri (Jira)
  • [jira] [Updated] (KAFKA-19503) Deprecate MX4j support TengYao Chi (Jira)
  • [jira] [Updated] (KAFKA-19503) Deprecate MX4J support Federico Valeri (Jira)
  • [jira] [Updated] (KAFKA-19503) Deprecate MX4j support Federico Valeri (Jira)
  • [jira] [Updated] (KAFKA-19503) Deprecate MX4j support Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19500) kafka-consumer-groups.sh should fail quickly if the partition leader is unavailable Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19461) Add share group admin integration tests to PlaintextAdminIntegrationTest Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19517) LoadSummary#numBytes include the size of all records, but LoadSummary#numRecords only includes non-controller records TengYao Chi (Jira)
• Re: [PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka] via GitHub
• [jira] [Updated] (KAFKA-19523) Gracefully handle error while building remoteLogAuxState Kamal Chandraprakash (Jira)
  • [jira] [Updated] (KAFKA-19523) Gracefully handle error while building remoteLogAuxState Kamal Chandraprakash (Jira)
• [jira] [Assigned] (KAFKA-19527) improve the docs of LogDirDescription for remote stroage HongYi Chen (Jira)
• [jira] [Created] (KAFKA-19527) improve the docs of LogDirDescription for remote stroage Chia-Ping Tsai (Jira)
• [PR] KAFKA-19517: Include control records in LoadSummary#numRecords [kafka] via GitHub
  • Re: [PR] KAFKA-19517: Include control records in LoadSummary#numRecords [kafka] via GitHub
• Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka] via GitHub
  • Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka] via GitHub
  • Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka] via GitHub
• Re: [PR] [KAFKA-15580] First attempt at UncleanRecoveryManager [kafka] via GitHub
  • Re: [PR] [KAFKA-15580] First attempt at UncleanRecoveryManager [kafka] via GitHub
  • Re: [PR] [KAFKA-15580] First attempt at UncleanRecoveryManager [kafka] via GitHub
• Re: [PR] KAFAK-14604: SASL session expiration time will be overflowed when calculation [kafka] via GitHub
• Re: [PR] docs: clarify log compaction with example and tombstone explanation [kafka] via GitHub
• Re: [PR] MINOR: Add tests on TxnOffsetCommit and EndTxnMarker protection against invalid producer epoch when TV2 is used [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19526) Enable to use DescribeTopicPartitionsRequest with topic id Bolin Lin (Jira)
• Re: [PR] MINOR: describeTopics should pass the timeout to the describeCluster call [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
• [jira] [Commented] (KAFKA-19526) Enable to use DescribeTopicPartitionsRequest with topic id Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19526) Enable to use DescribeTopicPartitionsRequest with topic id Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-19357: AsyncConsumer#close hangs as commitAsync never completes when coordinator is missing [kafka] via GitHub
  • Re: [PR] KAFKA-19357: AsyncConsumer#close hangs as commitAsync never completes when coordinator is missing [kafka] via GitHub
• [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
  • Re: [PR] MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap [kafka] via GitHub
• [PR] KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code [kafka] via GitHub
  • Re: [PR] KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code [kafka] via GitHub
  • Re: [PR] KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code [kafka] via GitHub
  • Re: [PR] KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code [kafka] via GitHub
  • Re: [PR] KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code [kafka] via GitHub
• [jira] [Created] (KAFKA-19525) Refactor TopicBasedRemoteLogMetadataManager to remove unused code Kamal Chandraprakash (Jira)
• [jira] [Assigned] (KAFKA-19525) Refactor TopicBasedRemoteLogMetadataManager to remove unused code Kamal Chandraprakash (Jira)
• 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
  • 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
  • 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
• [jira] [Commented] (KAFKA-8154) Buffer Overflow exceptions between brokers and with clients Fabrice Bacchella (Jira)
• [jira] [Assigned] (KAFKA-19524) connect-plugin-path crashes with UnsupportedOperationException on plugins without ServiceLoader manifests Sanskar Jhajharia (Jira)
• [jira] [Created] (KAFKA-19524) connect-plugin-path crashes with UnsupportedOperationException on plugins without ServiceLoader manifests Sanskar Jhajharia (Jira)
• Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Server Module [kafka] via GitHub

• Earlier messages
• Later messages