dev
Thread
Date
Earlier messages
Messages by Thread
[jira] [Resolved] (KAFKA-19254) Add generic feature level metric
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19451) Fix flaky test: RemoteIndexCacheTest.testCacheEntryIsDeletedOnRemoval()
Jun Rao (Jira)
[jira] [Created] (KAFKA-19505) ReplicaManagerTest#testMultipleRemoteFetchesInOneFetchRequest fails due to random topic-id in mocked log
Gaurav Narula (Jira)
[jira] [Created] (KAFKA-19504) AdminClient creates and adds second metrics reporter
Bill Bejeck (Jira)
[jira] [Resolved] (KAFKA-19452) Fix flaky test: LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments
Jun Rao (Jira)
[DISCUSS] KIP-1193: Deprecate MX4j support
Federico Valeri
[jira] [Created] (KAFKA-19503) Deprecate MX4j support.
Federico Valeri (Jira)
[jira] [Resolved] (KAFKA-19435) Optimize `kafka-consumer-groups.sh` to return the offset info of other partitions even when the leader of some partitions are missing
Chia-Ping Tsai (Jira)
MX4j support
Federico Valeri
Re: MX4j support
Chia-Ping Tsai
Re: MX4j support
Federico Valeri
[jira] [Created] (KAFKA-19502) During write state call processing,a batch can be split into offsets which is not accounted for
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-19501) System tests should use 17-bullseye instead of 17-buster
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19500) kafka-consumer-groups.sh should fail quickly if the partition leader is unavailable
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19499) Correct the logger name in PersisterStateManager
Chirag Wadhwa (Jira)
[DISCUSS] KIP-1192: Add include argument to ConsumerPerformance tool
Federico Valeri
[DISCUSS] KIP-1181: Add include argument to ConsumerPerformance tool
Federico Valeri
Re: [DISCUSS] KIP-1181: Add include argument to ConsumerPerformance tool
Federico Valeri
[jira] [Created] (KAFKA-19498) Add include argument to ConsumerPerformance tool
Federico Valeri (Jira)
[jira] [Resolved] (KAFKA-19460) fetch result might have size < fetch.min.bytes even if data is available in replica
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-19496) Failing test: DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions()
Matthias J. Sax (Jira)
[PR] MINOR: fix image subfix [kafka-site]
via GitHub
Re: [PR] MINOR: fix image subfix [kafka-site]
via GitHub
[PR] MINOR: add PoAn Yang to committers [kafka-site]
via GitHub
Re: [PR] MINOR: add PoAn Yang to committers [kafka-site]
via GitHub
[ANNOUNCE] New Kafka Committer: PoAn Yang
Chia-Ping Tsai
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
TengYao Chi
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Junwang Guo
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Matthias J. Sax
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Kamal Chandraprakash
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Gaurav Narula
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Lianet M.
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Andrew Schofield
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Luke Chen
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
龚宣璋
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Bruno Cadonna
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Lucas Brutschy
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Mickael Maison
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
Marouan REJEB
RE: [ANNOUNCE] New Kafka Committer: PoAn Yang
Jhen-Yung Hsu
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
ziming deng
Re: [ANNOUNCE] New Kafka Committer: PoAn Yang
黃竣陽
[jira] [Created] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch
Kevin Wu (Jira)
[jira] [Resolved] (KAFKA-18681) GetReplicaLogInfo request
Jonah Hooper (Jira)
[VOTE] 4.1.0 RC0
Mickael Maison
Re: [VOTE] 4.1.0 RC0
Paolo Patierno
Re: [VOTE] 4.1.0 RC0
Federico Valeri
Re: [VOTE] 4.1.0 RC0
Jun Rao
Re: [VOTE] 4.1.0 RC0
Bill Bejeck
[PR] MINOR: Add 4.1 docs [kafka-site]
via GitHub
Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.9 #211
Apache Jenkins Server
[jira] [Created] (KAFKA-19496) Failing test: DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions()
Apoorv Mittal (Jira)
Re: [VOTE] KIP-932: Queues for Kafka
Andrew Schofield
Re: [VOTE] KIP-932: Queues for Kafka
Jun Rao
Re: [VOTE] KIP-932: Queues for Kafka
Andrew Schofield
[jira] [Resolved] (KAFKA-19494) Undeprecate JoinGroup V0 & V1 in 3.x
Ismael Juma (Jira)
[jira] [Created] (KAFKA-19495) DefaultJwtRetriever could not be found with Docker native image
Mickael Maison (Jira)
[jira] [Created] (KAFKA-19494) Undeprecate JoinGroup V0 & V1 in 3.x
Ismael Juma (Jira)
[jira] [Created] (KAFKA-19493) Incorrect rate metric with larger window size
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-19492) ReplicaManager.deleteRecordsOnLocalLog should debug log the exception message when OffsetOutOfRangeException occurs
Jira
Get Kafka-Nated Episode 2: Josep Prat - Life of a Kafka Contributor
Hugh Evans
[jira] [Resolved] (KAFKA-19485) Acknowledgements should not be sent on initial epoch of ShareFetch
Shivsundar R (Jira)
[jira] [Resolved] (KAFKA-19488) Update the docs of "if-not-exists"
TengYao Chi (Jira)
[jira] [Created] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics
Kirk True (Jira)
[jira] [Resolved] (KAFKA-19466) LogConcurrencyTest should close the log when the test completes
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19490) Remove usages of distutils in docker scripts
Mickael Maison (Jira)
[jira] [Created] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Kevin Wu (Jira)
[jira] [Created] (KAFKA-19488) Update the docs of "if-not-exists"
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19487) Improve consistency of command-line arguments
Andrew Schofield (Jira)
[DISCUSS] KIP-1147: Improve consistency of command-line arguments
Andrew Schofield
Re: [DISCUSS] KIP-1147: Improve consistency of command-line arguments
Kirk True
Re: [DISCUSS] KIP-1147: Improve consistency of command-line arguments
Chris Egerton
Re: [DISCUSS] KIP-1147: Improve consistency of command-line arguments
Andrew Schofield
Re: [DISCUSS] KIP-1147: Improve consistency of command-line arguments
Andrew Schofield
[jira] [Created] (KAFKA-19486) Always use the latest version of kafka-topics.sh to create topics in system tests
Chia-Ping Tsai (Jira)
[VOTE] KIP-1172: Improve EndToEndLatency tool
Junwang Guo
Re: [VOTE] KIP-1172: Improve EndToEndLatency tool
Andrew Schofield
[jira] [Resolved] (KAFKA-18120) KIP-891: Support for multiple versions of connect plugins.
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-19248) Plugins Test for Multiversioning in Kafka Connect
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-19444) SASL GSSAPI not working with librdkafka and AK 4.x
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-19457) Revisit the threshold to retry initialize share state RPC in group coordinator.
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19450) ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19485) Acknowledgements should not be sent on initial epoch of ShareFetch
Shivsundar R (Jira)
Librdkafka on Linux
Subra I
[jira] [Created] (KAFKA-19484) Tiered Storage Quota Metrics can stop reporting
George Wu (Jira)
[VOTE] KIP-1097: Add Kafka Connect exception handler
Anton Liauchuk
[jira] [Resolved] (KAFKA-16061) KRaft JBOD follow-ups and improvements
Colin McCabe (Jira)
[jira] [Resolved] (KAFKA-15955) Migrating ZK brokers send dir assignments
Colin McCabe (Jira)
[jira] [Created] (KAFKA-19483) Fix flaky test RemoteIndexCacheTest.testConcurrentCacheDeletedFileExists()
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19482) Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19481) Fix flaky test AuthorizerIntegrationTest.testConsumerGroupHeartbeatWithRegex()
Sushant Mahajan (Jira)
[jira] [Resolved] (KAFKA-7442) forceUnmap mmap on linux when index resize
Jun Rao (Jira)
[jira] [Resolved] (KAFKA-19390) AbstractIndex#resize() does not release old mmap on Linux
Jun Rao (Jira)
[jira] [Resolved] (KAFKA-19463) nextFetchOffset does not take ongoing state transition into account
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19480) KRaft migration hangs when /migration has null value
Jira
[DISCUSS]: KIP-1191: Dead-letter queues for share groups
Andrew Schofield
[jira] [Created] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees.
Mihai Lucian (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #352
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #353
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #354
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #355
Apache Jenkins Server
[jira] [Resolved] (KAFKA-18977) Fix flaky streams_smoke_test
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19478) Optimize sticky assignor
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19477) Sticky Assignor JMH Benchmark
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19476) Improve state transition handling in SharePartition
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-19475) updateQuotaMetricConfigs could iterate through all metrics under a write lock
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19315) Move ControllerMutationQuotaManager to server module
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19474) Wrong placement of WARN log for truncation below HWM
Gaurav Narula (Jira)
[jira] [Created] (KAFKA-19473) The client does not throw RecordTooLargeException when the Record size exceeds max.partition.fetch.bytes
dyingjiecai (Jira)
[jira] [Created] (KAFKA-19472) A BufferOverflowException is thrown by RemoteLogManager when FetchApiVersion <= 2
dyingjiecai (Jira)
[jira] [Created] (KAFKA-19471) Enable acknowledgement for a record which could not be deserialized
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19468) Share group epoch increments on every heartbeat if subscribed topics removed
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19470) Avoid creating loggers repeatedly to affect the performance of request processing
terrytlu (Jira)
[jira] [Resolved] (KAFKA-19363) Enhance share group assignor for heterogeneous subscription type
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19362) Enhance share group assignor for homogeneous subscription type
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19456) State and leader epoch should only be used for validation and not be updated in share coordinator write state RPC.
Sushant Mahajan (Jira)
[jira] [Resolved] (KAFKA-19454) Share group delete should be resilient to metadata image issues in group coordinator.
Sushant Mahajan (Jira)
[jira] [Resolved] (KAFKA-19455) Make unknown_topic_or_partition error retriable by the persister state manager.
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19469) Share group supports dead letter queue
Lan Ding (Jira)
[DISCUSS] KIP-1190: Add a metric for controller thread idleness
Mahsa Seifikar
Re: [DISCUSS] KIP-1190: Add a metric for controller thread idleness
Jonah Hooper
Re: [DISCUSS] KIP-1190: Add a metric for controller thread idleness
Mahsa Seifikar
Re: [DISCUSS] KIP-1190: Add a metric for controller thread idleness
Jonah Hooper
Re: [DISCUSS] KIP-1190: Add a metric for controller thread idleness
Kevin Wu
RE: [DISCUSS] KIP-1190: Add a metric for controller thread idleness
Kevin Wu
RE: Re: [DISCUSS] KIP-1190: Add a metric for controller thread idleness
Kevin Wu
Re: Re: [DISCUSS] KIP-1190: Add a metric for controller thread idleness
Mahsa Seifikar
[jira] [Created] (KAFKA-19468) Share group epoch increments on every heartbeat if subscribed topics removed
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19467) Add a metric for controller thread idleness
Mahsa Seifikar (Jira)
[PR] Add Insero Air Traffic Solutions to Powered By [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-19440) Admin.alterShareGroupOffsets doesn't handle exceptions correctly
Andrew Schofield (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #347
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #348
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #349
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #350
Apache Jenkins Server
[VOTE] KIP-1154: Extending support for Microsecond/Nanosecond Precision for Kafka Connect
pritam kumar
[jira] [Created] (KAFKA-19466) LogConcurrencyTest should close the log when the test completes
Jun Rao (Jira)
[jira] [Created] (KAFKA-19465) Enable Schema definition for InsertHeader SMT
Ed Berezitsky (Jira)
[jira] [Created] (KAFKA-19464) remove findNextFetchOffset.set(true) from acknowledge and release acquired records functionality
Abhinav Dixit (Jira)
Clarification on open(TopicPartitions) and close(TopicPartitions) Behavior During Rebalances in SinkTasks
pritam kumar
Requesting permissions to contribute to Apache Kafka
Evan Zhou
Re: Requesting permissions to contribute to Apache Kafka
Matthias J. Sax
[VOTE] KIP-1121: Compression acceleration in Kafka
Denloye, Olasoji
[FYI] Tiny wiki KIP list cleanup
Kirk True
Re: [FYI] Tiny wiki KIP list cleanup
Chia-Ping Tsai
[VOTE] KIP-1066: Mechanism to cordon brokers and log directories
Mickael Maison
Re: [VOTE] KIP-1066: Mechanism to cordon brokers and log directories
Luke Chen
[jira] [Created] (KAFKA-19463) nextFetchOffset does not take ongoing state transition into account
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-19462) "fetch.max.bytes" config is not honored when remote + local fetch
Luke Chen (Jira)
[jira] [Created] (KAFKA-19460) fetch result might have size < fetch.min.bytes even if data is available in replica
Luke Chen (Jira)
[jira] [Created] (KAFKA-19461) Add share group admin integration tests to PlaintextAdminIntegrationTest
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19459) List internal topics for the user
Alieh Saeedi (Jira)
[jira] [Resolved] (KAFKA-19244) Add support for kafka-streams-groups.sh options beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[PR] Update Kpow intro in the powered by page [kafka-site]
via GitHub
Re: [PR] Update Kpow intro in the powered by page [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19458) Successive AlterReplicaLogDirsRequest on a topic partition may leak log segments
Gaurav Narula (Jira)
[jira] [Created] (KAFKA-19457) Revisit the threshold to retry initialize share state RPC in group coordinator.
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19456) State epoch should only be used for validation and not be updated in share coordinator write state RPC.
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19454) Share group delete should be resilient to metadata image issues in group coordinator.
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19455) Make unknown_topic_or_partition error retriable by the persister state manager.
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19453) Handle ShareGroupStatePartitionMetadata replay in group coordinator for non-existent groups.
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19452) Fix flaky test: LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments
Jun Rao (Jira)
[jira] [Created] (KAFKA-19451) Fix flaky test: RemoteIndexCacheTest.testCacheEntryIsDeletedOnRemoval()
Jun Rao (Jira)
Discussion: Ensuring Unique client.id per Task in Kafka Connect (KAFKA-19070)
pritam kumar
[jira] [Resolved] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-15697) Add local assignor and ensure it cannot be used with server side assignor
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-19450) ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer
Abhinav Dixit (Jira)
[jira] [Reopened] (KAFKA-19221) IOException on log segment close shouldn't be ignored
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19449) Unexpected UNREVOKED_PARTITIONS to UNRELEASED_PARTITIONS transition in consumer member reconciliation
Sean Quah (Jira)
[DISCUSS] Apache Kafka 4.0.1 release
Christo Lolov
[DISCUSS] KIP-1189: Allow custom topic configurations for RemoteStorageManager
Ivan Yurchenko
[jira] [Created] (KAFKA-19448) Allow custom topic configurations for RemoteStorageManager
Ivan Yurchenko (Jira)
[jira] [Resolved] (KAFKA-19445) Group coordinator and share coordinator runtime metrics are aliased
TengYao Chi (Jira)
[jira] [Resolved] (KAFKA-19402) Typo in EventAccumulator.java
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-18486) Remove ReplicaManager#becomeLeaderOrFollower
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19447) makeFollower and makeLeader should use PartitionRegistration instead of PartitionState
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #343
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #344
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #345
Apache Jenkins Server
[PR] บิวAdd files via upload [kafka-site]
via GitHub
Re: [PR] บิวAdd files via upload [kafka-site]
via GitHub
Re: [PR] บิวAdd files via upload [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19446) TV2 late marker can violate EOS guarantees.
Justine Olshan (Jira)
[jira] [Created] (KAFKA-19445) Group coordinator and share coordinator runtime metrics are aliased
Sean Quah (Jira)
[jira] [Created] (KAFKA-19444) SASL GSSAPI now working with librdkafka and AK 4.x
Emanuele Sabellico (Jira)
[jira] [Created] (KAFKA-19443) test-common ClusterInstance should make it easy to have more listeners
Edoardo Comar (Jira)
[jira] [Resolved] (KAFKA-19420) Don't export SocketServer from ClusterInstance
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17662) config.providers configuration missing from the docs
Mickael Maison (Jira)
[jira] [Created] (KAFKA-19442) Kafka Streams state store used an outdated value when reducing records, resulting in incorrect output.
juned (Jira)
[jira] [Created] (KAFKA-19441) Encapsulate MetadataImage in GroupCoordinator
Liz Bennett (Jira)
[jira] [Resolved] (KAFKA-19246) OffsetFetch API does not return group level errors correctly with version 1
David Jacot (Jira)
[jira] [Created] (KAFKA-19440) Admin.alterShareGroupOffsets doesn't handle exceptions correctly
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19439) OffsetFetch API does not return group level errors correctly with version 1 for 4.0 and 3.9
David Jacot (Jira)
[jira] [Created] (KAFKA-19438) Request for Assistance: FileSystemException Errors on Kafka Log Cleanup in Windows (KRaft and Zookeeper Modes)
Krishna Sai Dandu (Jira)
[jira] [Created] (KAFKA-19437) Review incidence of null metadata image in share coordinator
Andrew Schofield (Jira)
Request for Assistance: FileSystemException Errors on Kafka Log Cleanup in Windows (KRaft and Zookeeper Modes)
Rakesh Muniganti
[ANNOUNCE] Introducing "Debo" – A Unified Management Tool for the Hadoop Ecosystem (Including Kafka Support)
Surafel Temesgen
[jira] [Resolved] (KAFKA-18834) Fix LoggingResourceTest#testSetLevelDefaultScope
Chia-Ping Tsai (Jira)
AI usage in code contribution
Zhao, Guang
Re: AI usage in code contribution
Luke Chen
Earlier messages