jira
Thread
Date
Earlier messages
Messages by Thread
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
[PR] MINOR: Correct the docs of inter.worker.signature.algorithm [kafka]
via GitHub
Re: [PR] MINOR: Improve the documentation content for DistributedConfig [kafka]
via GitHub
[jira] [Commented] (KAFKA-19663) kafka-broker-api tool should support to get controller api version
TaiJuWu (Jira)
[PR] MINOR: Fix StreamsRebalanceListenerInvoker [kafka]
via GitHub
Re: [PR] MINOR: Fix StreamsRebalanceListenerInvoker [kafka]
via GitHub
Re: [PR] MINOR: Fix StreamsRebalanceListenerInvoker [kafka]
via GitHub
[jira] [Created] (KAFKA-19731) Remove AppInfoParser deprecated metrics
Jira
[jira] [Created] (KAFKA-19730) StreamsGroupDescribe result is missing topology when topology not configured
Lucas Brutschy (Jira)
[jira] [Resolved] (KAFKA-19478) Optimize sticky assignor
Lucas Brutschy (Jira)
[PR] KAFKA-19390: backport to 3.9 [kafka]
via GitHub
Re: [PR] KAFKA-19390: backport to 3.9 [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19729) Remove addMetric(MetricName metricName, Measurable measurable) method.
majialong (Jira)
[jira] [Created] (KAFKA-19729) Remove addMetric(MetricName metricName, Measurable measurable) method.
majialong (Jira)
[jira] [Updated] (KAFKA-19390) AbstractIndex#resize() does not release old mmap on Linux
Chia-Ping Tsai (Jira)
[PR] KAFKA-19434: moved the metric initialization to task assignment to have the correct thread. [kafka]
via GitHub
[jira] [Updated] (KAFKA-17941) TransactionStateManager.loadTransactionMetadata method may get stuck in an infinite loop
Justine Olshan (Jira)
Re: [PR] KAFKA-19390: Call safeForceUnmap() in AbstractIndex.resize() on Linux to prevent stale mmap of index files [kafka]
via GitHub
[jira] [Resolved] (KAFKA-18351) remove `version` tag for docker-compose.yml
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-17834) Improvement the Dockerfile
Mickael Maison (Jira)
Re: [PR] KAFKA-18351 remove `version` tag for docker-compose.yml [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19436) Acquisition lock timeout can't find some offsets to release
Apoorv Mittal (Jira)
[jira] [Commented] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck
Sanskar Jhajharia (Jira)
[jira] [Resolved] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck
Sanskar Jhajharia (Jira)
[PR] MINOR: Only Apache Kafka allow to publish build scan [kafka]
via GitHub
Re: [PR] MINOR: Only Apache Kafka allow to publish build scan [kafka]
via GitHub
Re: [PR] KAFKA-19408 : Add check for compression type mismatch for push telemetry requests [kafka]
via GitHub
[jira] [Created] (KAFKA-19728) Disk space is not being freed
Jianbin Chen (Jira)
[PR] MINOR: migrate listenerListToEndPoints from CoreUtils to AbstractKafkaConfig [kafka]
via GitHub
[jira] [Updated] (KAFKA-18970) [kafka-clients] Gradle module metadata publication should be enabled
Jira
[jira] [Updated] (KAFKA-18970) [kafka-clients] Gradle module metadata publication should be enabled
Jira
[PR] KAFKA-19174 POC for a new `:distribution` submodule [kafka]
via GitHub
Re: [PR] KAFKA-19174 POC for a new `:distribution` submodule [kafka]
via GitHub
Re: [PR] MINOR: Enable auth test for new consumer [kafka]
via GitHub
Re: [PR] KAFKA-18744: reuse LoginCallbackHandler on kerberos re-login [kafka]
via GitHub
Re: [PR] KAFKA-17554: Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest [kafka]
via GitHub
Re: [PR] KAFKA-17554: Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest [kafka]
via GitHub
Re: [PR] KAFKA-17554: Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest [kafka]
via GitHub
[jira] [Resolved] (KAFKA-8202) StackOverflowError on producer when splitting batches
Christo Lolov (Jira)
[jira] [Resolved] (KAFKA-15186) AppInfo metrics don't contain the client-id
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19681) Optimize MetadataShell tool find command print warning message intead of throwing exception
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-18028) the effective kraft version of `--no-initial-controllers` should be 1 rather than 0
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-18028) the effective kraft version of `--no-initial-controllers` should be 1 rather than 0
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-16262) Add IQv2 to Kafka Streams documentation
Chang-Yu Huang (Jira)
[PR] KAFKA-17076: retain last batch in each round of cleaning (#17193) [kafka]
via GitHub
[jira] [Created] (KAFKA-19711) commit-rate metric
Nicholas Telford (Jira)
[PR] MINOR: Enhanced exception handling for metadata acquisition [kafka]
via GitHub
Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka]
via GitHub
Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka]
via GitHub
Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka]
via GitHub
Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka]
via GitHub
[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
Re: [PR] KAFKA-19716: Clear out coordinator snapshots periodically while loading [kafka]
via GitHub
[jira] [Resolved] (KAFKA-18061) AddRaftVoter responds with error message "NONE" instead of null
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-18191) StreamJoined name is not used for processor names
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-18191) StreamJoined name is not used for processor names
Nikita Shupletsov (Jira)
[PR] KAFKA-19723 Adding consumer rebalance metrics test [kafka]
via GitHub
Re: [PR] KAFKA-19723 Adding consumer rebalance metrics test [kafka]
via GitHub
[jira] [Created] (KAFKA-19694) StreamsRebalanceListener is not triggered on Consumer.close()
Lucas Brutschy (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)
[PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
Re: [PR] KAFKA-19299: Fix race condition in RemoteIndexCacheTest [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19697) NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close()
Fan Yang (Jira)
[PR] KAFKA-19697: Fix unregistering connectorStatusMetrics NPE if tasks fa… [kafka]
via GitHub
Re: [PR] KAFKA-19697: Fix unregistering connectorStatusMetrics NPE if tasks fa… [kafka]
via GitHub
Re: [PR] KAFKA-19697: Fix unregistering connectorStatusMetrics NPE if tasks fa… [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19724) Global stream thread ignores all exceptions
Fatih Celik (Jira)
[PR] MINOR: Remove exitMessage.set() call in TopicBasedRemoteLogMetadataManagerTest [kafka]
via GitHub
Re: [PR] MINOR: Remove exitMessage.set() call in TopicBasedRemoteLogMetadataManagerTest [kafka]
via GitHub
Re: [PR] MINOR: Optimize map lookup efficiency with getOrDefault [kafka]
via GitHub
Re: [PR] MINOR: Optimize map lookup efficiency with getOrDefault [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19644) Enhance the documentation for producer headers
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19727) Make open telemetry object instantiation configurable
Jonathan Lacefield (Jira)
[jira] [Comment Edited] (KAFKA-19727) Make open telemetry object instantiation configurable
Apoorv Mittal (Jira)
[jira] [Commented] (KAFKA-19727) Make open telemetry object instantiation configurable
Apoorv Mittal (Jira)
[jira] [Commented] (KAFKA-19727) Make open telemetry object instantiation configurable
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19727) Make open telemetry object instantiation configurable
Jonathan Lacefield (Jira)
[jira] [Comment Edited] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Comment Edited] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Comment Edited] (KAFKA-19724) Global stream thread ignores all exceptions
Fatih Celik (Jira)
[jira] [Comment Edited] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Comment Edited] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Resolved] (KAFKA-19722) Missing assigned-partitions metric in new consumer
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Fatih Celik (Jira)
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Fatih Celik (Jira)
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Bruno Cadonna (Jira)
[jira] [Commented] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Commented] (KAFKA-18468) Write share consumer performance tests
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19724) Global stream thread ignores all exceptions
Jira
[jira] [Updated] (KAFKA-19724) Global stream thread ignores all exceptions
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-19692) improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions
Chia-Ping Tsai (Jira)
[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
Re: [PR] Introduce RENEW ack type in share groups. [kafka]
via GitHub
[PR] KAFKA-19664 Support building with Java 25 (LTS release) [kafka]
via GitHub
Re: [PR] KAFKA-19664 Support building with Java 25 (LTS release) [kafka]
via GitHub
Re: [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
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
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] [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
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
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)
[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-19719: --no-initial-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-19719: --no-initial-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-19719: --no-initial-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-19719: --no-initial-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-19719: --no-initial-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)
Earlier messages