jira  

Messages by Thread

• [jira] [Updated] (KAFKA-20861) Kafka Streams should handle corrupted assignment pro-actively Matthias J. Sax (Jira)
• [jira] [Comment Edited] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins sanghyeok An (Jira)
  • [jira] [Commented] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins sanghyeok An (Jira)
  • [jira] [Commented] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins Matthias J. Sax (Jira)
• Re: [PR] KAFKA-20419 : Add SASL_PLAINTEXT docker compose examples and sanity test [kafka] via GitHub
  • Re: [PR] KAFKA-20419 : Add SASL_PLAINTEXT docker compose examples and sanity test [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20954) Remove hamcrest from org.apache.kafka.streams.kstream.internals.foreignkeyjoin package Chia-Ping Tsai (Jira)
• [PR] MINOR: Fix ProducerFailureHandlingTest configuration and topic creation [kafka] via GitHub
  • Re: [PR] MINOR: Fix ProducerFailureHandlingTest configuration and topic creation [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20955) Remove hamcrest from org.apache.kafka.streams.kstream.internals.graph package Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20689) Remove unnecessary Hamcrest dependency from tools module Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-20689: Remove unnecessary Hamcrest runtime dependency from tools [kafka] via GitHub
  • Re: [PR] KAFKA-20689: Remove unnecessary Hamcrest runtime dependency from tools [kafka] via GitHub
• [jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id Preethi KCS (Jira)
  • [jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id Preethi KCS (Jira)
• [PR] MINOR: Add Protobuf message formatter for kafka-console-consumer [kafka] via GitHub
  • Re: [PR] MINOR: Add Protobuf message formatter for kafka-console-consumer [kafka] via GitHub
• [PR] MINOR: Remove unnecessary props.asScala in DynamicBrokerConfig [kafka] via GitHub
  • Re: [PR] MINOR: Remove unnecessary props.asScala in DynamicBrokerConfig [kafka] via GitHub
  • Re: [PR] MINOR: Remove unnecessary props.asScala in DynamicBrokerConfig [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20804) [Java-client] Reduce lock contention in ProducerMetadata#add Kamal Chandraprakash (Jira)
• [jira] [Assigned] (KAFKA-20917) [Java-client] RecordAccumulator.ready performance regression Kamal Chandraprakash (Jira)
• [PR] MINOR: Cross-link header-aware IQv2 docs to the general IQv2 section [kafka] via GitHub
  • Re: [PR] MINOR: Cross-link header-aware IQv2 docs to the general IQv2 section [kafka] via GitHub
  • Re: [PR] MINOR: Cross-link header-aware IQv2 docs to the general IQv2 section [kafka] via GitHub
  • Re: [PR] MINOR: Cross-link header-aware IQv2 docs to the general IQv2 section [kafka] via GitHub
• [jira] [Created] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins sanghyeok An (Jira)
• [jira] [Updated] (KAFKA-20838) Reduce IQv2StoreIntegrationTest runtime by disabling test-only Streams initial rebalance delay Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20973) Unable to dynamically update non string configs with config providers Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-20973) Unable to dynamically update non string configs with config providers Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-20973) Unable to dynamically update non string configs with config providers Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-20973) Unable to dynamically update non string configs with config providers Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-20973) Unable to dynamically update non string configs with config providers Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-20973) Unable to dynamically update non string configs with config providers Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins sanghyeok An (Jira)
• [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka] via GitHub
• [PR] KAFKA-20955: Remove hamcrest from org.apache.kafka.streams.kstream.internals.graph package [kafka] via GitHub
  • Re: [PR] KAFKA-20955: Remove hamcrest from org.apache.kafka.streams.kstream.internals.graph package [kafka] via GitHub
• [PR] MINOR: Fix IQ key hashing during streams-protocol rebalance [kafka] via GitHub
  • Re: [PR] KAFKA-20887: Fix IQ key hashing during streams-protocol rebalance [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19895) __consumer_offsets Partitions Growing to TB Size and Not Cleaning Until Broker Restart md tanwir (Jira)
  • [jira] [Assigned] (KAFKA-19895) __consumer_offsets Partitions Growing to TB Size and Not Cleaning Until Broker Restart md tanwir (Jira)
  • [jira] [Assigned] (KAFKA-19895) __consumer_offsets Partitions Growing to TB Size and Not Cleaning Until Broker Restart Arnab Nandy (Jira)
• [jira] [Assigned] (KAFKA-18744) When I add sasl.login.callback.handler.class it is used for initial login but not used when ticket is about to expire md tanwir (Jira)
• [jira] [Updated] (KAFKA-20979) Potential data loss caused by time index truncation Mickael Maison (Jira)
  • [jira] [Updated] (KAFKA-20979) Potential data loss caused by time index truncation Ken Huang (Jira)
  • [jira] [Updated] (KAFKA-20979) Potential data loss caused by time index truncation Ken Huang (Jira)
  • [jira] [Updated] (KAFKA-20979) Potential data loss caused by time index truncation Ken Huang (Jira)
• [jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation Luke Chen (Jira)
  • [jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation Gaurav Narula (Jira)
  • [jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20979) Potential data loss caused by time index truncation Mickael Maison (Jira)
• Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (1/N) [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20838) Reduce IQv2StoreIntegrationTest runtime by disabling test-only Streams initial rebalance delay Ken Huang (Jira)
• Re: [PR] KAFKA-20857: Use Java 25 in Docker images [kafka] via GitHub
• [PR] minor: revert formatter test for latest testing metadata version [kafka] via GitHub
  • Re: [PR] MINOR: revert formatter test for latest testing metadata version [kafka] via GitHub
• [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka] via GitHub
  • Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka] via GitHub
  • Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka] via GitHub
• Re: [PR] KAFKA-17218: let kafka-consumer-groups handle describe groups with deleted topics [kafka] via GitHub
  • Re: [PR] KAFKA-17218: let kafka-consumer-groups handle describe groups with deleted topics [kafka] via GitHub
• Re: [PR] KAFKA-18647: Clarify Windows support in Quick Start Guide [kafka] via GitHub
  • Re: [PR] KAFKA-18647: Clarify Windows support in Quick Start Guide [kafka] via GitHub
• [PR] KAFKA-20954 Remove hamcrest [kafka] via GitHub
  • Re: [PR] KAFKA-20954 Remove hamcrest [kafka] via GitHub
  • Re: [PR] KAFKA-20954 Replace Hamcrest with JUnit assertions in foreign-key join tests [kafka] via GitHub
  • Re: [PR] KAFKA-20954 Replace Hamcrest with JUnit assertions in foreign-key join tests [kafka] via GitHub
• Re: [PR] KAFKA-20689: Migrate reset integration tests to ClusterInstance [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20954) Remove hamcrest from org.apache.kafka.streams.kstream.internals.foreignkeyjoin package dino2895 (Jira)
• Re: [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka] via GitHub
• [PR] MM2: fail fast instead of silently resetting on data loss / topic reset. [kafka] via GitHub
  • Re: [PR] MM2: fail fast instead of silently resetting on data loss / topic reset. [kafka] via GitHub
• [PR] MINOR: Speed up TimestampedStoreUpgradeIntegrationTest [kafka] via GitHub
  • Re: [PR] MINOR: Speed up TimestampedStoreUpgradeIntegrationTest [kafka] via GitHub
  • Re: [PR] MINOR: Speed up TimestampedStoreUpgradeIntegrationTest [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON) Chia-Ping Tsai (Jira)
• [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
  • Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
  • Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
  • Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
  • Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
  • Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
  • Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
  • Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka] via GitHub
• [PR] MINOR: update collaborator list [kafka] via GitHub
  • Re: [PR] MINOR: update collaborator list [kafka] via GitHub
  • Re: [PR] MINOR: update collaborator list [kafka] via GitHub
• [jira] [Created] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py` Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py` majialong (Jira)
• [jira] [Updated] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py` Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py` Chia-Ping Tsai (Jira)
• [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka] via GitHub
  • Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka] via GitHub
  • Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka] via GitHub
  • Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka] via GitHub
  • Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka] via GitHub
  • Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka] via GitHub
  • Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka] via GitHub
• [jira] [Created] (KAFKA-20977) RemoteCopyLagSegments/RemoteCopyLagBytes report a phantom lag of 1 on low-throughput partitions (single-record segments) Avishek Das (Jira)
• [jira] [Updated] (KAFKA-20977) RemoteCopyLagSegments/RemoteCopyLagBytes report a phantom lag of 1 on low-throughput partitions (single-record segments) Avishek Das (Jira)
  • [jira] [Updated] (KAFKA-20977) RemoteCopyLagSegments/RemoteCopyLagBytes report a phantom lag of 1 on low-throughput partitions (single-record segments) Avishek Das (Jira)
• [PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka] via GitHub
  • Re: [PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka] via GitHub
  • Re: [PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka] via GitHub
  • Re: [PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka] via GitHub
• [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
  • Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka] via GitHub
• Re: [PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka] via GitHub
  • Re: [PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka] via GitHub
  • Re: [PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-20971) Add cross version system test for "streams" static group membership Harsh Vasava (Jira)
  • [jira] [Comment Edited] (KAFKA-20971) Add cross version system test for "streams" static group membership Harsh Vasava (Jira)
  • [jira] [Comment Edited] (KAFKA-20971) Add cross version system test for "streams" static group membership Harsh Vasava (Jira)
• [PR] KAFKA-20976: Make KRaft max partitions per request limit a config [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make KRaft max partitions per request limit a config [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make KRaft max partitions per request limit a config [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka] via GitHub
  • Re: [PR] KAFKA-20976: Make max records per batch configurable [kafka] via GitHub
• [PR] MINOR: Restore metadata version tests and add IBP_4_5_IV0 [kafka] via GitHub
  • Re: [PR] MINOR: Restore metadata version tests and add IBP_4_5_IV0 [kafka] via GitHub
  • Re: [PR] MINOR: Restore metadata version tests and add IBP_4_5_IV0 [kafka] via GitHub
• [jira] [Updated] (KAFKA-20976) Make KRaft max partitions per request limit a config Andrew Grant (Jira)
  • [jira] [Updated] (KAFKA-20976) Make KRaft max partitions per request limit a config Andrew Grant (Jira)
• [jira] [Created] (KAFKA-20976) Make KRaft max partitions per request limit a config Andrew Grant (Jira)
• [jira] [Commented] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON) ASF GitHub Bot (Jira)
  • [jira] [Commented] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON) ASF GitHub Bot (Jira)
• [jira] [Commented] (KAFKA-20975) Remove hamcrest from streams test-utils Shantanu Shukla (Jira)
  • [jira] [Commented] (KAFKA-20975) Remove hamcrest from streams test-utils Shantanu Shukla (Jira)
  • [jira] [Commented] (KAFKA-20975) Remove hamcrest from streams test-utils Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-20975) Remove hamcrest from streams test-utils Shantanu (Jira)
• [jira] [Created] (KAFKA-20975) Remove hamcrest from streams test-utils Shantanu Shukla (Jira)
• [PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka] via GitHub
  • Re: [PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka] via GitHub
  • Re: [PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka] via GitHub
  • Re: [PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka] via GitHub
  • Re: [PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka] via GitHub
• Re: [PR] KAFKA-19619: Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation [kafka] via GitHub
  • Re: [PR] KAFKA-19619: Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation [kafka] via GitHub
• [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
• [jira] [Created] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON) Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON) majialong (Jira)

• Earlier messages
• Later messages