jira  

Messages by Thread

• [jira] [Created] (KAFKA-19725) Deprecate --property and replace with --reader-property in console producer Andrew Schofield (Jira)
• [PR] Introduce RENEW ack type in share groups. [kafka] via GitHub
• [PR] KAFKA-19664 Support building with Java 25 (LTS release) [kafka] via GitHub
• [PR] MINOR : Add unit tests for verifying --formatter-property in console tools. [kafka] via GitHub
  • Re: [PR] MINOR : Add unit tests for verifying --formatter-property in console tools. [kafka] via GitHub
  • Re: [PR] MINOR : Add unit tests for verifying --formatter-property in console tools. [kafka] via GitHub
• [jira] [Updated] (KAFKA-19716) OOM when loading large uncompacted __consumer_offsets partitions with transactional workload David Jacot (Jira)
• [jira] [Created] (KAFKA-19724) Global stream thread ignores all exceptions Jira
• [jira] [Assigned] (KAFKA-19492) ReplicaManager.deleteRecordsOnLocalLog should debug log the exception message when OffsetOutOfRangeException occurs Ksolves India Limited (Jira)
• [jira] [Created] (KAFKA-19698) Streams | Fix order of arguments to assertEquals in unit test Ksolves India Limited (Jira)
• [PR] MINOR: Remove metrics attribute from StreamsGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from StreamsGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from StreamsGroup [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager Arpit Goyal (Jira)
  • [jira] [Assigned] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager Arpit Goyal (Jira)
  • [jira] [Assigned] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager Arpit Goyal (Jira)
• [PR] MINOR: fix incorrect offset reset logging [kafka] via GitHub
  • Re: [PR] MINOR: fix incorrect offset reset logging [kafka] via GitHub
  • Re: [PR] MINOR: fix incorrect offset reset logging [kafka] via GitHub
  • Re: [PR] MINOR: fix incorrect offset reset logging [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19676) EpochState should override close to avoid throwing IOException Chia-Ping Tsai (Jira)
• [jira] [Comment Edited] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager Lianet Magrans (Jira)
• [jira] [Commented] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager Lianet Magrans (Jira)
  • [jira] [Commented] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager Arpit Goyal (Jira)
• [jira] [Created] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager Lianet Magrans (Jira)
• [PR] KAFKA-19722: Adding missing metric assigned-partitions for new consumer [kafka] via GitHub
  • Re: [PR] KAFKA-19722: Adding missing metric assigned-partitions for new consumer [kafka] via GitHub
• [PR] [wip] Kafka 18376 avoid events [kafka] via GitHub
• [jira] [Created] (KAFKA-19722) Missing assigned-partitions metric in new consumer Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-19695) Last redundant offset calculation to take deleted share partitions into account. Sushant Mahajan (Jira)
• [jira] [Comment Edited] (KAFKA-19721) Update streams documentation with KIP-1147 changes Jhen-Yung Hsu (Jira)
• [jira] [Assigned] (KAFKA-19721) Update streams documentation with KIP-1147 changes Jhen-Yung Hsu (Jira)
• [jira] [Commented] (KAFKA-19721) Update streams documentation with KIP-1147 changes Jhen-Yung Hsu (Jira)
  • [jira] [Commented] (KAFKA-19721) Update streams documentation with KIP-1147 changes Jhen-Yung Hsu (Jira)
  • [jira] [Commented] (KAFKA-19721) Update streams documentation with KIP-1147 changes Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19721) Update streams documentation with KIP-1147 changes Andrew Schofield (Jira)
• [PR] KAFKA-19692: improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions [kafka] via GitHub
• [PR] Tighten up argument descriptions for console CLI tools [kafka] via GitHub
  • Re: [PR] MINOR: Tighten up argument descriptions for console CLI tools [kafka] via GitHub
  • Re: [PR] MINOR: Tighten up argument descriptions for console CLI tools [kafka] via GitHub
  • Re: [PR] MINOR: Tighten up argument descriptions for console CLI tools [kafka] via GitHub
• [jira] [Assigned] (KAFKA-10552) Update directory structure to use topic IDs Omnia Ibrahim (Jira)
• [jira] [Resolved] (KAFKA-17443) Create a tool to manipulate share-group state snapshots for recovery purposes Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-18468) Write share consumer performance tests Apoorv Mittal (Jira)
• [PR] (WIP) KAFKA-19706: ListOffsetsHandler should kick out the unsupported timestyamp type when receiving a UnsupportedVersionException [kafka] via GitHub
• [PR] MINOR : Fix parantheses in console_consumer.py and console_share_consumer.py [kafka] via GitHub
  • Re: [PR] MINOR : Fix parantheses in console_consumer.py and console_share_consumer.py [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19676) EpochState should override close to avoid throwing IOException Jimmy Wang (Jira)
• [jira] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException Jainil Rana (Jira)
• Re: [PR] KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID [kafka] via GitHub
• [jira] [Commented] (KAFKA-17182) Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer Arpit Goyal (Jira)
• [jira] [Resolved] (KAFKA-19623) Consistency of command-line arguments for console producer/consumer Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19704) Kafka Broker Fails to Start After Upgrade to 4.1.0 Due to Invalid segment.bytes Configuration MithaJoseph (Jira)
• [jira] [Created] (KAFKA-19712) Implement new behaviour in ProcessorStateManager Nicholas Telford (Jira)
• Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka] via GitHub
• [PR] MINOR: Fix format in CoordinatorLoaderImplTest [kafka] via GitHub
  • Re: [PR] MINOR: Fix format in CoordinatorLoaderImplTest [kafka] via GitHub
• [jira] [Created] (KAFKA-19720) Regex subscription should be empty for classic members joining mixed group Dongnuo Lyu (Jira)
• [jira] [Assigned] (KAFKA-19720) Regex subscription should be empty for classic members joining mixed group Dongnuo Lyu (Jira)
• [PR] KAFKA-19719: --no-intial-controllers should not assume kraft.version=1 [kafka] via GitHub
  • Re: [PR] KAFKA-19719: --no-intial-controllers should not assume kraft.version=1 [kafka] via GitHub
  • Re: [PR] KAFKA-19719: --no-intial-controllers should not assume kraft.version=1 [kafka] via GitHub
  • Re: [PR] KAFKA-19719: --no-intial-controllers should not assume kraft.version=1 [kafka] via GitHub
  • Re: [PR] KAFKA-19719: --no-intial-controllers should not assume kraft.version=1 [kafka] via GitHub
  • Re: [PR] KAFKA-19719: --no-initial-controllers should not assume kraft.version=1 [kafka] via GitHub
• Re: [PR] KAFKA-18028: the effective kraft version of --no-initial-controllers should be 1 rather than 0 [kafka] via GitHub
• [jira] [Created] (KAFKA-19719) setting --no-initial-controllers flag should not validate kraft version against metadata version Kevin Wu (Jira)
• [jira] [Updated] (KAFKA-19719) setting --no-initial-controllers flag should not validate kraft version against metadata version Kevin Wu (Jira)
  • [jira] [Updated] (KAFKA-19719) setting --no-initial-controllers flag should not validate kraft version against metadata version Kevin Wu (Jira)
• Re: [PR] KAKKA-12506: Strengthen AdjustStreamThreadCountTest with stateful counting and higher throughput [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19699) improve the documentation of `RecordsToDelete` Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19296) Revise AsyncKafkaConsumer event wakeup approach Kirk True (Jira)
• [jira] [Resolved] (KAFKA-19589) Reduce number of events generated in AsyncKafkaConsumer.updateFetchPositions() Kirk True (Jira)
• [jira] [Resolved] (KAFKA-19588) Reduce waiting for event completion in AsyncKafkaConsumer.poll() Kirk True (Jira)
• Re: [PR] MINOR: Delete temporary directories after using them in RaftManagerTest [kafka] via GitHub
• [PR] MINOR: Delete temporary directories after using them in RaftManagerTest Updated [kafka] via GitHub
  • Re: [PR] MINOR: Delete temporary directories after using them in RaftManagerTest Updated [kafka] via GitHub
  • Re: [PR] MINOR: Delete temporary directories after using them in RaftManagerTest Updated [kafka] via GitHub
• [PR] MINOR: Fix typos in CoordinatorRecordTypeGenerator [kafka] via GitHub
• Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
  • Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
  • Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
  • Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
  • Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
  • Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
  • Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
  • Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka] via GitHub
• [PR] MINOR: Add support for podman when running system tests [kafka] via GitHub
• [PR] Mirror data to LSO for transaction data [kafka] via GitHub
  • Re: [PR] Mirror data to LSO for transaction data [kafka] via GitHub
• [jira] [Updated] (KAFKA-19718) docker_build_test.py does not run tests when using --kafka_archive. Shivsundar R (Jira)
• [jira] [Updated] (KAFKA-19718) docker_build_test.py does not run tests when using --kafka-archive. Shivsundar R (Jira)
• [jira] [Assigned] (KAFKA-19718) docker_build_test.py does not run tests when using --kafka_archive. Shivsundar R (Jira)
• [jira] [Created] (KAFKA-19718) docker_build_test.py does not run tests when using --kafka_archive. Shivsundar R (Jira)
• Re: [PR] KAFKA-14945: Add Serializer#serializeToByteBuffer() to reduce memory copying [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] Add a SelectorProvider that reuses custom provider implementations. [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19446) TV2 late marker can violate EOS guarantees. Ritika Reddy (Jira)
• [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] [kafka] via GitHub
• [jira] [Commented] (KAFKA-19578) Fix flaky RemoteLogManagerTest#testCopyQuota Lianet Magrans (Jira)
• [PR] KAFKA-19684: Move Gauge#value to MetricValueProvider [kafka] via GitHub
  • Re: [PR] KAFKA-19684: Move Gauge#value to MetricValueProvider [kafka] via GitHub
  • Re: [PR] KAFKA-19684: Move Gauge#value to MetricValueProvider [kafka] via GitHub
  • Re: [PR] KAFKA-19684: Move Gauge#value to MetricValueProvider [kafka] via GitHub
• [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
  • Re: [PR] MINOR: Remove metrics attribute from ConsumerGroup [kafka] via GitHub
• [PR] KAFKA-19705: Kafka Streams integration tests using IQv2 updated [kafka] via GitHub
  • Re: [PR] KAFKA-19705: Kafka Streams integration tests using IQv2 updated [kafka] via GitHub
  • Re: [PR] KAFKA-19705: Kafka Streams integration tests using IQv2 updated [kafka] via GitHub
  • Re: [PR] KAFKA-19705: Kafka Streams integration tests using IQv2 updated [kafka] via GitHub
  • Re: [PR] KAFKA-19705: Enable streams rebalance protocol in IQv2 integration test [kafka] via GitHub
  • Re: [PR] KAFKA-19705: Kafka Streams integration tests using IQv2 updated [kafka] via GitHub
  • Re: [PR] KAFKA-19705: Kafka Streams integration tests using IQv2 updated [kafka] via GitHub
• [jira] [Commented] (KAFKA-19717) InsertHeader drops part of the value when header value is a number LiuJing (Jira)
• [jira] [Resolved] (KAFKA-19604) Document controller.quorum.auto.join.enable config in upgrade.html Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-19717) InsertHeader drops part of the value when header value is a number Marcos Schroh (Jira)
• [jira] [Created] (KAFKA-19713) Auto migrate .position offsets Nicholas Telford (Jira)
• [PR] MINOR: Improve producer docs around timeout behaviour on missing topic/partition [kafka] via GitHub
  • Re: [PR] MINOR: Improve producer docs around timeout behaviour on missing topic/partition [kafka] via GitHub
  • Re: [PR] MINOR: Improve producer docs and add tests around timeout behaviour on missing topic/partition [kafka] via GitHub
  • Re: [PR] MINOR: Improve producer docs and add tests around timeout behaviour on missing topic/partition [kafka] via GitHub
  • Re: [PR] MINOR: Improve producer docs and add tests around timeout behaviour on missing topic/partition [kafka] via GitHub
• [jira] [Updated] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads Matthias J. Sax (Jira)
• [PR] KAFKA-19703: Removed versions 2.3 and below from UpgradeFromValues. [kafka] via GitHub
  • Re: [PR] KAFKA-19703: Removed versions 2.3 and below from UpgradeFromValues. [kafka] via GitHub
  • Re: [PR] KAFKA-19703: Removed versions 2.3 and below from UpgradeFromValues. [kafka] via GitHub
  • Re: [PR] KAFKA-19703: Removed versions 2.3 and below from UpgradeFromValues. [kafka] via GitHub
  • Re: [PR] KAFKA-19703: Removed versions 2.3 and below from UpgradeFromValues. [kafka] via GitHub
  • Re: [PR] KAFKA-19703: Removed versions 2.3 and below from UpgradeFromValues. [kafka] via GitHub
• [jira] (KAFKA-19703) Remove unsupported "upgrade from" versions Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-19703) Remove unsupported "upgrade from" versions Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-19096) Skipped Records in FK join should not be marked as dropped Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
• [jira] [Assigned] (KAFKA-19715) Consider bumping 3rd party Github Actions Chang Chi Hsu (Jira)
• [PR] KAFKA-19661 [6/N]: Use heaps also on the process-level [kafka] via GitHub
  • Re: [PR] KAFKA-19661 [6/N]: Use heaps also on the process-level [kafka] via GitHub
  • Re: [PR] KAFKA-19661 [6/N]: Use heaps also on the process-level [kafka] via GitHub
  • Re: [PR] KAFKA-19661 [6/N]: Use heaps also on the process-level [kafka] via GitHub
  • Re: [PR] KAFKA-19661 [6/N]: Use heaps also on the process-level [kafka] via GitHub
  • Re: [PR] KAFKA-19661 [6/N]: Use heaps also on the process-level [kafka] via GitHub
• [jira] [Commented] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads LiuJing (Jira)
  • [jira] [Commented] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads LiuJing (Jira)
  • [jira] [Commented] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads LiuJing (Jira)
  • [jira] [Commented] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads Lucas Brutschy (Jira)
  • [jira] [Commented] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads LiuJing (Jira)
• [PR] MINOR: Fix format in CoordinatorLoaderImpl [kafka] via GitHub
  • Re: [PR] MINOR: Fix format in CoordinatorLoaderImpl [kafka] via GitHub
  • Re: [PR] MINOR: Fix format in CoordinatorLoaderImpl [kafka] via GitHub
• Re: [PR] KAFKA-19242: Fix commit bugs caused by race condition during rebalancing. [kafka] via GitHub
• [jira] [Created] (KAFKA-19717) InsertHeader drops part of the value when header value is a number Marcos Schroh (Jira)
• [jira] [Created] (KAFKA-19708) Add new StateStore APIs Nicholas Telford (Jira)
• [jira] [Assigned] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads Lucas Brutschy (Jira)
  • [jira] [Assigned] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-12392) Deprecate batch-size config from console producer Kamal Chandraprakash (Jira)
• [jira] [Created] (KAFKA-19716) OOM when loading large uncompacted __consumer_offsets partitions with transactional workload Sean Quah (Jira)
• [jira] [Assigned] (KAFKA-18710) Move DynamicClientQuotaPublisher to metadata module Jira
• [jira] [Created] (KAFKA-19709) Add LegacyCheckpointingStateStore Nicholas Telford (Jira)
• [jira] [Created] (KAFKA-19715) Consider bumping 3rd party Github Actions Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19714) Auto migrate .checkpoint offsets Nicholas Telford (Jira)
• [jira] [Created] (KAFKA-19710) Add downgrade support Nicholas Telford (Jira)
• [jira] [Commented] (KAFKA-18710) Move DynamicClientQuotaPublisher to metadata module Maros Orsak (Jira)
  • [jira] [Commented] (KAFKA-18710) Move DynamicClientQuotaPublisher to metadata module Jira
• [jira] [Resolved] (KAFKA-18747) Persister request de-duplication Sushant Mahajan (Jira)
• [jira] [Commented] (KAFKA-10549) Add topic ID support to ListOffsets, OffsetForLeaders TaiJuWu (Jira)
  • [jira] [Commented] (KAFKA-10549) Add topic ID support to ListOffsets, OffsetForLeaders TaiJuWu (Jira)
• [jira] [Resolved] (KAFKA-8350) Splitting batches should consider topic-level message size Christo Lolov (Jira)
• Re: [PR] MINOR: Update Protocol Buffers documentation URLs [kafka] via GitHub
  • Re: [PR] MINOR: Update Protocol Buffers documentation URLs [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19609) Move TransactionLogTest to transaction-coordinator module Chia-Ping Tsai (Jira)
• Re: [PR] MINOR: increase Config change throwable log info to error [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19695) Last redundant offset calculation to take deleted share partitions into account. Apoorv Mittal (Jira)
• [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version upgrade breaks CI build: build scan failed to be published Jira
• [PR] MINOR Try ASF self-hosted runner [kafka] via GitHub
• [jira] [Updated] (KAFKA-19654) [Gradle 8 --> 9 upgrade] GitHub Actions build issues: JUnit tests parsing fails (for a new/flaky steps) Jira
  • [jira] [Updated] (KAFKA-19654) [Gradle 8 --> 9 upgrade] GitHub Actions build issues: JUnit tests parsing fails (for a new/flaky steps) Jira
• [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
  • [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
  • [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
  • [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
  • [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
  • [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
  • [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira
  • [jira] [Updated] (KAFKA-19707) Develocity Gradle plugin version can't be upgraded (CI build fails with error: "build scan failed to be published") Jira

• Earlier messages