dev
Thread
Date
Earlier messages
Messages by Thread
[jira] [Resolved] (KAFKA-19436) Acquisition lock timeout can't find some offsets to release
Apoorv Mittal (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #428
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
[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
[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
[jira] [Created] (KAFKA-19703) Remove unsupported "upgrade from" versions
Matthias J. Sax (Jira)
[jira] [Reopened] (KAFKA-12392) Deprecate batch-size config from console producer
Chia-Ping Tsai (Jira)
Query on Controller Configuration Support with SASL_SSL-Oauthbearer for Kafka in Kraft Mode
Aishwarya Saha
[jira] [Created] (KAFKA-19700) Fix flaky DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout()
Kirk True (Jira)
[jira] [Created] (KAFKA-19699) improve the documentation of `RecordsToDelete`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-8350) Splitting batches should consider topic-level message size
Christo Lolov (Jira)
[VOTE] 4.0.1 RC2
Christo Lolov
Re: [VOTE] 4.0.1 RC2
Chia-Ping Tsai
Re: [VOTE] 4.0.1 RC2
Matthias J. Sax
Re: [VOTE] 4.0.1 RC2
Herman K. Jakobsen
Apache Kafka 3.9.2 - Release Manager
Chia-Ping Tsai
Re: Apache Kafka 3.9.2 - Release Manager
PoAn Yang
Re: Apache Kafka 3.9.2 - Release Manager
Matthias J. Sax
Re: Apache Kafka 3.9.2 - Release Manager
Chia-Ping Tsai
[PR] MINOR: Add 4.0.1 Javadocs [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19697) NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close()
Martin Andersson (Jira)
[jira] [Created] (KAFKA-19695) Last redundant offset calculation to take deleted share partitions into account.
Sushant Mahajan (Jira)
[jira] [Resolved] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException
Kirk True (Jira)
[jira] [Resolved] (KAFKA-19675) StreamsOnTasksAssignedCallbackNeededEvent could not be completed
Lucas Brutschy (Jira)
[DISCUSS] KIP-1216: Add rebalance listener metrics for Kafka Streams
Travis Zhang
Re: [DISCUSS] KIP-1216: Add rebalance listener metrics for Kafka Streams
Alieh Saeedi
Re: [DISCUSS] KIP-1216: Add rebalance listener metrics for Kafka Streams
Travis Zhang
Re: [DISCUSS] KIP-1216: Add rebalance listener metrics for Kafka Streams
Bill Bejeck
Re: [DISCUSS] KIP-1216: Add rebalance listener metrics for Kafka Streams
Travis Zhang
Re: [DISCUSS] KIP-1216: Add rebalance listener metrics for Kafka Streams
Lucas Brutschy
[DISCUSS] KIP-1218: Expose consumer CorruptRecordException
Uladzislau Blok
[jira] [Resolved] (KAFKA-19660) JoinWithIncompleteMetadataIntegrationTest fails in isolated run of one parameter
travis (Jira)
[jira] [Resolved] (KAFKA-19083) Fix flaky MetricsDuringTopicCreationDeletionTest. testMetricsDuringTopicCreateDelete(String).quorum=kraft
Jira
[jira] [Created] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads
Lucas Brutschy (Jira)
[jira] [Resolved] (KAFKA-18708) Move ScramPublisher to metadata module
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-19693) Introduce PersisterBatch in SharePartition
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-19490) Remove usages of distutils in docker scripts
PoAn Yang (Jira)
Re: [PR] Uploaded Unistam logo [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-19679) NoSuchElementException (again) in Kafka Streams iterator metrics
Matthias J. Sax (Jira)
[DISCUSS] KIP-1215 Graceful stop on Kafka Streams exceptions processing handlers
Victor Osorio
[jira] [Resolved] (KAFKA-19630) LSO movement archives only the first available batch not all the ones prior to the new LSO
Apoorv Mittal (Jira)
[PR] Adding 4.1 updates [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19694) StreamsRebalanceListener is not triggered on Consumer.close()
Lucas Brutschy (Jira)
[DISCUSS] KIP-1127: Include push interval in ClientTelemetryReceiver context
Mickael Maison
Re: [DISCUSS] KIP-1127: Include push interval in ClientTelemetryReceiver context
Federico Valeri
Re: [DISCUSS] KIP-1127: Include push interval in ClientTelemetryReceiver context
Mickael Maison
[DISCUSS] KIP-1217: Include push interval in ClientTelemetryReceiver context
Mickael Maison
Re: [DISCUSS] KIP-1217: Include push interval in ClientTelemetryReceiver context
Andrew Schofield
Re: [DISCUSS] KIP-1217: Include push interval in ClientTelemetryReceiver context
Mickael Maison
Re: [DISCUSS] KIP-1217: Include push interval in ClientTelemetryReceiver context
Luke Chen
[jira] [Created] (KAFKA-19692) improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19690) Unexpected Fatal error InvalidTxnStateException on Kafka Streams (KIP-890)
Ritika Reddy (Jira)
[jira] [Resolved] (KAFKA-19689) TopologyTestDriver spends most of its time forcing changes to disk with persistent state stores
Steven Schlansker (Jira)
[jira] [Resolved] (KAFKA-19680) NoSuchElementException (again) in Kafka Streams iterator metrics
Steven Schlansker (Jira)
[PR] MINOR: update docs for KAFKA-19668 [kafka-site]
via GitHub
Re: [PR] MINOR: update docs for KAFKA-19668 [kafka-site]
via GitHub
Re: [PR] MINOR: update docs for KAFKA-19668 [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-19585) Avoid noisy NPE logs when closing consumer after constructor failures
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-19687) MetaData log error message for SNAPSHOT_HEADER and SNAPSHOT_FOOTER
TaiJuWu (Jira)
[VOTE] KIP-1205: Improve RecordHeader to be Thread-Safe
Ming-Yen Chung
Re: [VOTE] KIP-1205: Improve RecordHeader to be Thread-Safe
Chia-Ping Tsai
[jira] [Created] (KAFKA-19686) Trigger Docker image builds in release script
Mickael Maison (Jira)
[jira] [Created] (KAFKA-19685) Revoked partitions are included in currentOffsets passed to preCommit on task stop
Toshiki Murakami (Jira)
[jira] [Resolved] (KAFKA-19475) updateQuotaMetricConfigs could iterate through all metrics under a write lock
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19684) Move Gauge#value to MetricValueProvider
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19677) Flaky Test org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest
Lucy Liu (Jira)
[jira] [Created] (KAFKA-19683) Clean up TaskManagerTest
Shashank (Jira)
[jira] [Resolved] (KAFKA-14085) Clean up usage of asserts in KafkaProducer
Ksolves India Limited (Jira)
[jira] [Resolved] (KAFKA-19658) Tweak org.apache.kafka.clients.consumer.OffsetAndMetadata
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19673) Disallow create too many partitions also in createPartitions
Edoardo Comar (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #413
Apache Jenkins Server
[jira] [Resolved] (KAFKA-19550) Integration test for Streams-related Admin APIs[1/N]
Lucy Liu (Jira)
[jira] [Resolved] (KAFKA-15983) Kafka-acls should return authorization already done if repeating work is issued
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19682) Improve logging about task readiness
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-19681) Optimize MetadataShell tool find command print warning message intead of throwing exception
Jira
[jira] [Resolved] (KAFKA-14083) Check if we don't need to refresh time in RecordAccumulator.append
Ksolves India Limited (Jira)
[VOTE] KIP-1207: Fix anomaly of JMX metrics RequestHandlerAvgIdlePercent in kraft combined mode
Tony Tang
Re: [VOTE] KIP-1207: Fix anomaly of JMX metrics RequestHandlerAvgIdlePercent in kraft combined mode
Kevin Wu
Re: [VOTE] KIP-1207: Fix anomaly of JMX metrics RequestHandlerAvgIdlePercent in kraft combined mode
Justine Olshan
[jira] [Created] (KAFKA-19680) NoSuchElementException (again) in Kafka Streams iterator metrics
Steven Schlansker (Jira)
[jira] [Created] (KAFKA-19679) NoSuchElementException (again) in Kafka Streams iterator metrics
Steven Schlansker (Jira)
[jira] [Created] (KAFKA-19678) Streams open iterator tracking has high contention on metrics lock
Steven Schlansker (Jira)
[jira] [Created] (KAFKA-19676) EpochState should override close to avoid throwing IOException
Chia-Ping Tsai (Jira)
[jira] [Reopened] (KAFKA-18818) Significant delay in Metadata Update After Admin Client Operations in KRaft Mode
Erik van Oosten (Jira)
[jira] [Resolved] (KAFKA-19112) Unifying LIST-Type Configuration Validation and Default Values
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19674) [3.9] Disallow create too many partitions in ZK mode
Edoardo Comar (Jira)
[jira] [Resolved] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-19659) Wrong generic type for UnregisterBrokerOptions
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19675) StreamsOnTasksAssignedCallbackNeededEvent could not be completed before
Lucas Brutschy (Jira)
[jira] [Reopened] (KAFKA-17840) Move ReplicationQuotaManager, ClientRequestQuotaManager and QuotaFactory to server module
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-14086) Cleanup PlaintextConsumerTest.testInterceptors to not pass null record
Ksolves India Limited (Jira)
[jira] [Created] (KAFKA-19672) Producer performance test failing in parsing aggregate statistics
ally heev (Jira)
[jira] [Resolved] (KAFKA-19667) Close ShareConsumer in ShareConsumerPerformance only after metrics displayed
Andrew Schofield (Jira)
[VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Anton Liauchuk
Re:[VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Hector Geraldino (BLOOMBERG/ 919 3RD A)
Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Anton Liauchuk
RE: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Andrei Rudkouski
RE: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Andrei Rudkouski
Re: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Mickael Maison
Re: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Anton Liauchuk
Re: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Chris Egerton
Re: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Anton Liauchuk
Re: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Anton Liauchuk
Re: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Chris Egerton
Re: Re: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Anton Liauchuk
RE: [VOTE] KIP-1209: Add configuration to control internal topic creation in Kafka Connect
Andrei D
[PR] MINOR: Fix broken link in 4.1.0 blog post [kafka-site]
via GitHub
Re: [PR] MINOR: Fix broken link in 4.1.0 blog post [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19671) benchmark_test is throwing `NullPointerException`
ally heev (Jira)
[ANNOUNCE] Apache Kafka 4.1.0
Mickael Maison
Re: [ANNOUNCE] Apache Kafka 4.1.0
Apoorv Mittal
Re: [ANNOUNCE] Apache Kafka 4.1.0
Justine Olshan
Re: [ANNOUNCE] Apache Kafka 4.1.0
Chia-Ping Tsai
Re: [ANNOUNCE] Apache Kafka 4.1.0
Kamal Chandraprakash
Re: [ANNOUNCE] Apache Kafka 4.1.0
Lucas Brutschy
Re: [ANNOUNCE] Apache Kafka 4.1.0
Luke Chen
Re: [ANNOUNCE] Apache Kafka 4.1.0
Satish Duggana
RE: [ANNOUNCE] Apache Kafka 4.1.0
Jhen-Yung Hsu
[jira] [Created] (KAFKA-19670) Unify the command-line parser
Chia-Ping Tsai (Jira)
Why did this build fail?
Claude Warren, Jr
Re: Why did this build fail?
Shivsundar R
ConfigDef.ConfigKey.dependents question.
Claude Warren, Jr
Earlier messages