dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [DISCUSS] KIP-1222: Acquisition lock timeout renewal in share consumer explicit mode
Christo Lolov
Re: [DISCUSS] KIP-1222: Acquisition lock timeout renewal in share consumer explicit mode
Sushant Mahajan
Re: [DISCUSS] KIP-1222: Acquisition lock timeout renewal in share consumer explicit mode
Christo Lolov
Re: [DISCUSS] KIP-1222: Acquisition lock timeout renewal in share consumer explicit mode
Sushant Mahajan
[jira] [Created] (KAFKA-19759) Add built-in TTL (Time-to-Live) support for Kafka Streams State Stores
Ankur Sinha (Jira)
RE: Marketing: [EXT] [jira] [Created] (KAFKA-19759) Add built-in TTL (Time-to-Live) support for Kafka Streams State Stores
Dhruva Vardhan
RE: Critical bug in Kafka Streams 4.1.0 -- bug-fix release 4.1.1 needed?
Colt McNealy
Critical bug in Kafka Streams 4.1.0 -- bug-fix release 4.1.1 needed?
Matthias J. Sax
Re: Critical bug in Kafka Streams 4.1.0 -- bug-fix release 4.1.1 needed?
Lianet M.
Re: Critical bug in Kafka Streams 4.1.0 -- bug-fix release 4.1.1 needed?
Chia-Ping Tsai
Re: Critical bug in Kafka Streams 4.1.0 -- bug-fix release 4.1.1 needed?
Mickael Maison
Re: Critical bug in Kafka Streams 4.1.0 -- bug-fix release 4.1.1 needed?
Matthias J. Sax
[DISCUSS] Apache Kafka 4.1.1 release
Lianet M.
Re: [DISCUSS] Apache Kafka 4.1.1 release
David Jacot
Re: [DISCUSS] Apache Kafka 4.1.1 release
Mickael Maison
Re: [DISCUSS] Apache Kafka 4.1.1 release
Lianet M.
Re: [DISCUSS] Apache Kafka 4.1.1 release
Matthias J. Sax
[jira] [Created] (KAFKA-19755) Move `KRaftClusterTest` from core module to server module
Chia-Ping Tsai (Jira)
[DISCUSS] KIP-1223: Add user tag to DeprecatedRequestsMetric
Gaurav Narula
Re: [DISCUSS] KIP-1223: Add user tag to DeprecatedRequestsMetric
Ismael Juma
Re: [DISCUSS] KIP-1223: Add user tag to DeprecatedRequestsMetric
Gaurav Narula
Re: [DISCUSS] KIP-1223: Add user tag to DeprecatedRequestsMetric
Gaurav Narula
Re: [DISCUSS] KIP-1223: Add user tag to DeprecatedRequestsMetric
Chia-Ping Tsai
Re: [DISCUSS] KIP-1223: Add user tag to DeprecatedRequestsMetric
Gaurav Narula
Query about KRaft and dynamic advertised.listeners
Christo Lolov
Kafka Connect and Postgres composite types
Liam Clarke
Re: [VOTE] KIP-1136: Make ConsumerGroupMetadata an interface
Paweł Szymczyk
Re: [VOTE] KIP-1136: Make ConsumerGroupMetadata an interface
Lianet M.
Re: [VOTE] KIP-1136: Make ConsumerGroupMetadata an interface
Bill Bejeck
Re: [VOTE] KIP-1136: Make ConsumerGroupMetadata an interface
Paweł Szymczyk
Re: [VOTE] KIP-1136: Make ConsumerGroupMetadata an interface
Chia-Ping Tsai
Re: [VOTE] KIP-1136: Make ConsumerGroupMetadata an interface
Paweł Szymczyk
[jira] [Resolved] (KAFKA-19467) Add a metric for controller thread idleness
Jira
[jira] [Created] (KAFKA-19754) Add RPC-level integration tests for StreamsGroupDescribe
Lucy Liu (Jira)
[jira] [Resolved] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19753) Metrics from FetchMetricsManager containing a topic tag are duplicated
Charles-Eddy (Jira)
[jira] [Created] (KAFKA-19752) Move UnifiedLogTest to storage module
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-9825) Kafka protocol BNF format should have some way to display tagged fields
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19751) Fix the "6.6 Java Version" for branch 3.9
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19750) Address the compileClasspath resolution warnings for the `releaseTarGz` task
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19721) Update streams documentation with KIP-1147 changes
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19749) The `version-mapping` of kafka-features.sh should work without requiring the bootstrap
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19747) Improve failed push telemetry request
Bill Bejeck (Jira)
[jira] [Resolved] (KAFKA-19692) improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions
Chia-Ping Tsai (Jira)
[DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Ismael Juma
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Mickael Maison
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Justine Olshan
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Chia-Ping Tsai
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Andrew Schofield
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Lucas Brutschy
Re: [DISCUSS] Apache Kafka 4.2.0 release
David Jacot
Re: [DISCUSS] Apache Kafka 4.2.0 release
Andrew Schofield
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
Re: [DISCUSS] Apache Kafka 4.2.0 release
Manikumar
RE: Re: [DISCUSS] Apache Kafka 4.2.0 release
Herman K. Jakobsen
Re: [DISCUSS] Apache Kafka 4.2.0 release
Christo Lolov
[jira] [Resolved] (KAFKA-12506) Expand AdjustStreamThreadCountTest
Matthias J. Sax (Jira)
[DISCUSS] KIP-1221: Add application-id tag to Kafka Streams state metric
Bill Bejeck
Re: [DISCUSS] KIP-1221: Add application-id tag to Kafka Streams state metric
Matthias J. Sax
Re: [DISCUSS] KIP-1221: Add application-id tag to Kafka Streams state metric
Bill Bejeck
[jira] [Created] (KAFKA-19743) [DISCUSS] Exploring Compile-time AST Generation as an Alternative Approach for Kafka Protocol Classes
Yingquan He (Jira)
[jira] [Created] (KAFKA-19741) Remove deprecated metrics in Rename AssignmentsManager and RemoteStorageThreadPool
Jira
[jira] [Resolved] (KAFKA-17876) Consider renaming org.apache.kafka.server:type=AssignmentsManager
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19150) Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19617) ConsumerPerformance#ConsumerPerfRebListener get corrupted value when the number of partitions is increased
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19740) Depreacte broker-level config group.coordinator.rebalance.protocols
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #434
Apache Jenkins Server
[PR] Update Exoscale Cloud logo [kafka-site]
via GitHub
Re: [PR] Update Exoscale Cloud logo [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-19730) StreamsGroupDescribe result is missing topology when topology not configured
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19739) Upgrade commons-validator to 1.10.0 and remove the forced commons-beanutils workaround
Patrik Nagy (Jira)
[jira] [Resolved] (KAFKA-19546) Rebalance should be triggered if the subscription is changed during group protocol downgrade triggered by static member replacement
David Jacot (Jira)
[jira] [Resolved] (KAFKA-19732) Backport KAFKA-19716 fix to 4.0 and 4.1
David Jacot (Jira)
[jira] [Resolved] (KAFKA-18356) Explicitly setting up instrumentation for inline mocking (Java 21+)
Mickael Maison (Jira)
[jira] [Created] (KAFKA-19738) Improve testing of OffsetsRequestManager to better match OffsetFetcher
Evan Zhou (Jira)
[jira] [Created] (KAFKA-19736) KAFKA-15665 prevents safe reassignments from completing
Alyssa Huang (Jira)
[jira] [Created] (KAFKA-19737) Fix PluginUtils#pluginLocations warning log not being printed
majialong (Jira)
[jira] [Resolved] (KAFKA-19733) Clients | Fix order of arguments to assertEquals()
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19544) Improve `MetadataVersion.fromVersionString()` to take an enableUnstableFeature flag
Chia-Ping Tsai (Jira)
[DISCUSS] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation
Kuan-Po Tseng
Re: [DISCUSS] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation
Chia-Ping Tsai
Re: [DISCUSS] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation
Luke Chen
Re: [DISCUSS] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation
Ismael Juma
Re: [DISCUSS] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation
Kuan Po Tseng
Re: [DISCUSS] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation
Kuan Po Tseng
Re: [DISCUSS] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation
Chia-Ping Tsai
[jira] [Resolved] (KAFKA-19716) OOM when loading large uncompacted __consumer_offsets partitions with transactional workload
David Jacot (Jira)
[jira] [Created] (KAFKA-19732) Backport KAFKA-19716 fix to 4.0 and 4.1
Sean Quah (Jira)
[jira] [Resolved] (KAFKA-17554) Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19729) Remove addMetric(MetricName metricName, Measurable measurable) method.
majialong (Jira)
[jira] [Reopened] (KAFKA-19390) AbstractIndex#resize() does not release old mmap on Linux
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17834) Improvement the Dockerfile
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-18351) remove `version` tag for docker-compose.yml
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-19436) Acquisition lock timeout can't find some offsets to release
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck
Sanskar Jhajharia (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #428
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #429
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #430
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #431
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #432
Apache Jenkins Server
[jira] [Resolved] (KAFKA-19681) Optimize MetadataShell tool find command print warning message intead of throwing exception
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-15186) AppInfo metrics don't contain the client-id
Chia-Ping Tsai (Jira)
Dev
Carlos Manuel Duclos-Vergara
Apache Kafka 4.2 -- Release Manager
Matthias J. Sax
Re: Apache Kafka 4.2 -- Release Manager
Christo Lolov
Re: Apache Kafka 4.2 -- Release Manager
Matthias J. Sax
Re: Apache Kafka 4.2 -- Release Manager
Bill Bejeck
Re: Apache Kafka 4.2 -- Release Manager
Chia-Ping Tsai
Re: Apache Kafka 4.2 -- Release Manager
Bruno Cadonna
Re: Apache Kafka 4.2 -- Release Manager
Christo Lolov
Re: Apache Kafka 4.2 -- Release Manager
Mickael Maison
[jira] [Resolved] (KAFKA-19676) EpochState should override close to avoid throwing IOException
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-18061) AddRaftVoter responds with error message "NONE" instead of null
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19708) Add new StateStore APIs
Nicholas Telford (Jira)
[PR] MINOR: Use the ASF new logo [kafka-site]
via GitHub
Re: [PR] MINOR: Use the ASF new logo [kafka-site]
via GitHub
Re: [PR] MINOR: Use the ASF new logo [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19705) Update Kafka Streams integration tests using IQv2 to new streams protocol
travis (Jira)
[jira] [Resolved] (KAFKA-17255) Migrate ListOffsetsIntegrationTest to ClusterTestExtensions framework
TaiJuWu (Jira)
[jira] [Resolved] (KAFKA-8202) StackOverflowError on producer when splitting batches
Christo Lolov (Jira)
[jira] [Created] (KAFKA-19702) Move MetadataVersionConfigValidator and related test code to metadata module
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19727) Make open telemetry object instantiation configurable
Jonathan Lacefield (Jira)
[jira] [Resolved] (KAFKA-19644) Enhance the documentation for producer headers
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19722) Missing assigned-partitions metric in new consumer
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-19727) Make open telemetry object instantiation configurable
Jonathan Lacefield (Jira)
[jira] [Created] (KAFKA-19726) Throw an exception if client tries to override topic replication factor with a value that it < min.insync.replicas
Genseric Ghiro (Jira)
High score CVE found in version 3.9.1
Rico Hightower
Re: High score CVE found in version 3.9.1
Chia-Ping Tsai
[jira] [Created] (KAFKA-19688) Provide clean upgrade path from transformValues to processValues
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-19725) Deprecate --property and replace with --reader-property in console producer
Andrew Schofield (Jira)
Please approve workflow runs for this PR: KAFKA-19664 Support building with Java 25 (LTS release)
Dejan Stojadinović
[jira] [Created] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #425
Apache Jenkins Server
[jira] [Created] (KAFKA-19723) Add tests for ConsumerRebalanceMetricsManager
Lianet Magrans (Jira)
[DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Jonah Hooper
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
José Armando García Sancio
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Jonah Hooper
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
José Armando García Sancio
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Jun Rao
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Justine Olshan
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Jonah Hooper
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Jonah Hooper
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Kevin Wu
Re: [DISCUSS] KIP-1219: Configurations for KRaft Fetch and FetchSnapshot Byte Size
Jonah Hooper
[jira] [Created] (KAFKA-19722) Missing assigned-partitions metric in new consumer
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-19721) Update streams documentation with KIP-1147 changes
Andrew Schofield (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)
[jira] [Created] (KAFKA-19691) Add metrics corresponding to consumer rebalance listener metrics
travis (Jira)
[jira] [Created] (KAFKA-19715) Consider bumping 3rd party Github Actions
Mickael Maison (Jira)
[jira] [Created] (KAFKA-19698) Streams | Fix order of arguments to assertEquals in unit test
Ksolves India Limited (Jira)
[jira] [Created] (KAFKA-19713) Auto migrate .position offsets
Nicholas Telford (Jira)
[jira] [Created] (KAFKA-19689) TopologyTestDriver spends most of its time forcing changes to disk
Steven Schlansker (Jira)
[jira] [Created] (KAFKA-19711) commit-rate metric
Nicholas Telford (Jira)
[jira] [Resolved] (KAFKA-19623) Consistency of command-line arguments for console producer/consumer
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19720) Regex subscription should be empty for classic members joining mixed group
Dongnuo Lyu (Jira)
[jira] [Created] (KAFKA-19719) setting --no-initial-controllers flag should not validate kraft version against metadata version
Kevin Wu (Jira)
[jira] [Resolved] (KAFKA-19589) Reduce number of events generated in AsyncKafkaConsumer.updateFetchPositions()
Kirk True (Jira)
[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-19588) Reduce waiting for event completion in AsyncKafkaConsumer.poll()
Kirk True (Jira)
[jira] [Created] (KAFKA-19718) docker_build_test.py does not run tests when using --kafka_archive.
Shivsundar R (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #423
Apache Jenkins Server
[jira] [Resolved] (KAFKA-19604) Document controller.quorum.auto.join.enable config in upgrade.html
Chia-Ping Tsai (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] [Created] (KAFKA-19714) Auto migrate .checkpoint offsets
Nicholas Telford (Jira)
[jira] [Created] (KAFKA-19717) InsertHeader drops part of the value when header value is a number
Marcos Schroh (Jira)
[jira] [Created] (KAFKA-19716) OOM when loading large uncompacted __consumer_offsets partitions with transactional workload
Sean Quah (Jira)
[DISCUSSION] KIP-1202: Align broker and controller "advertised.listeners" and "listeners" behaviour
黃竣陽
[jira] [Created] (KAFKA-19712) Implement new behaviour in ProcessorStateManager
Nicholas Telford (Jira)
[jira] [Created] (KAFKA-19710) Add downgrade support
Nicholas Telford (Jira)
[jira] [Created] (KAFKA-19709) Add LegacyCheckpointingStateStore
Nicholas Telford (Jira)
[jira] [Resolved] (KAFKA-18747) Persister request de-duplication
Sushant Mahajan (Jira)
[jira] [Resolved] (KAFKA-19609) Move TransactionLogTest to transaction-coordinator module
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19695) Last redundant offset calculation to take deleted share partitions into account.
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-19707) Develocity Gradle plugin version upgrade breaks CI build: build scan failed to be published
Jira
[jira] [Resolved] (KAFKA-18501) Fix flaky ClientQuotasRequestTest.testAlterClientQuotasInvalidRequests
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19203) Replace `ApiError#exception` by `Error#exception` for KafkaAdminClient
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19706) ListOffsetsHandler should kick out the unsupported timestyamp type when receiving a UnsupportedVersionException
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-18105) Fix flaky PlaintextAdminIntegrationTest#testElectPreferredLeaders
Chia-Ping Tsai (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] [Resolved] (KAFKA-17649) Remove none-StateUpdater Code
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-17380) Kafka Streams few partition stuck in processing - fixed after restart
Matthias J. Sax (Jira)
[VOTE] KIP-1200: Deprecate ClientQuotaCallback#updateClusterMetadata
Kuan-Po Tseng
Re: [VOTE] KIP-1200: Deprecate ClientQuotaCallback#updateClusterMetadata
Chia-Ping Tsai
Re: [VOTE] KIP-1200: Deprecate ClientQuotaCallback#updateClusterMetadata
黃竣陽
RE: [VOTE] KIP-1200: Deprecate ClientQuotaCallback#updateClusterMetadata
Hsu Jhen-Yung
[jira] [Created] (KAFKA-19693) Introduce PersisterBatch in SharePartition
Chirag Wadhwa (Jira)
[jira] [Created] (KAFKA-19701) Mark DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() as flaky
Kirk True (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #418
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #419
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #420
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #421
Apache Jenkins Server
Earlier messages
Later messages