dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Omnia Ibrahim
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Omnia Ibrahim
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Justine Olshan
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Claude Warren
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Justine Olshan
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Omnia Ibrahim
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Claude Warren
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Justine Olshan
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Omnia Ibrahim
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Justine Olshan
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Claude Warren
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Justine Olshan
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Claude Warren, Jr
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Igor Soarez
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Claude Warren, Jr
Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation
Igor Soarez
[jira] [Created] (KAFKA-16769) Delete deprecated add.source.alias.to.metrics configuration
Mickael Maison (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2903
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2904
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2905
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16671) Revisit SessionedProtocolIntegrationTest.ensureInternalEndpointIsSecured
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition
Greg Harris (Jira)
[jira] [Resolved] (KAFKA-15170) CooperativeStickyAssignor cannot adjust assignment correctly
A. Sophie Blee-Goldman (Jira)
[jira] [Created] (KAFKA-16767) KRaft should track HWM outside the log layer
Jira
[jira] [Created] (KAFKA-16766) New consumer offsetsForTimes timeout exception does not have the proper message
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16765) NioEchoServer leaks accepted SocketChannel instances due to race condition
Greg Harris (Jira)
[jira] [Created] (KAFKA-16764) New consumer should throw InvalidTopicException on poll when invalid topic in metadata
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16763) Upgrade to scala 2.12.19 and scala 2.13.14
Chia-Ping Tsai (Jira)
[VOTE] KIP-1028: Docker Official Image for Apache Kafka
Vedarth Sharma
Re: [VOTE] KIP-1028: Docker Official Image for Apache Kafka
Chris Egerton
Re: [VOTE] KIP-1028: Docker Official Image for Apache Kafka
Manikumar
Re: [VOTE] KIP-1028: Docker Official Image for Apache Kafka
Justine Olshan
Re:[VOTE] KIP-1028: Docker Official Image for Apache Kafka
Hector Geraldino (BLOOMBERG/ 919 3RD A)
Re: [VOTE] KIP-1028: Docker Official Image for Apache Kafka
Vedarth Sharma
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Christopher Shannon
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Greg Harris
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Christopher Shannon
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Chris Egerton
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Christopher Shannon
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Chris Egerton
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Christopher Shannon
Re: [DISCUSS] KIP-1032: Upgrade to Jakarta and JavaEE 9 in Kafka 4.0
Christopher Shannon
[jira] [Created] (KAFKA-16762) SyncGroup API for upgrading ConsumerGroup
Dongnuo Lyu (Jira)
[jira] [Resolved] (KAFKA-16406) Split long-running consumer integration test
Lianet Magrans (Jira)
[VOTE] KIP-950: Tiered Storage Disablement
Christo Lolov
Re: [VOTE] KIP-950: Tiered Storage Disablement
Luke Chen
Re: [VOTE] KIP-950: Tiered Storage Disablement
Kamal Chandraprakash
Re: [VOTE] KIP-950: Tiered Storage Disablement
Chia-Ping Tsai
Re: [VOTE] KIP-950: Tiered Storage Disablement
Luke Chen
Re: [VOTE] KIP-950: Tiered Storage Disablement
Satish Duggana
Re: [VOTE] KIP-950: Tiered Storage Disablement
Christo Lolov
Re: [VOTE] KIP-950: Tiered Storage Disablement
Mickael Maison
Re: [VOTE] KIP-950: Tiered Storage Disablement
David Jacot
[VOTE] KIP-989: RocksDB Iterator Metrics
Nick Telford
Re: [VOTE] KIP-989: RocksDB Iterator Metrics
Lucas Brutschy
Re: [VOTE] KIP-989: RocksDB Iterator Metrics
Matthias J. Sax
Re: [VOTE] KIP-989: RocksDB Iterator Metrics
Sophie Blee-Goldman
Re: [VOTE] KIP-989: RocksDB Iterator Metrics
Nick Telford
Re: [VOTE] KIP-989: RocksDB Iterator Metrics
Josep Prat
Re: [VOTE] KIP-989: RocksDB Iterator Metrics
Nick Telford
Community over Code EU 2024: The countdown has started!
Ryan Skraba
[jira] [Resolved] (KAFKA-13115) doSend can be blocking
Jira
[jira] [Created] (KAFKA-16761) ZkClusterInstance#start does not create ClusterConfigurableIntegrationHarness
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16760) alterReplicaLogDirs failed even if responded with none error
Luke Chen (Jira)
[jira] [Created] (KAFKA-16759) Invalid client telemetry transition on consumer close
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-16694) Remove rack aware code in assignors temporarily due to performance
David Jacot (Jira)
[jira] [Created] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
A. Sophie Blee-Goldman (Jira)
[jira] [Created] (KAFKA-16757) Fix broker re-registration issues around MV 3.7-IV2
Colin McCabe (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2898
Apache Jenkins Server
[jira] [Resolved] (KAFKA-15578) Run System Tests for Old protocol in the New Coordinator
David Jacot (Jira)
[jira] [Resolved] (KAFKA-16117) Add Integration test for checking if the correct assignor is chosen
David Jacot (Jira)
[jira] [Resolved] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8
David Jacot (Jira)
[jira] [Created] (KAFKA-16755) Implement lock timeout functionality in SharePartition
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16756) Implement max delivery count functionality in SharePartition
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16754) Implement release acquired records functionality in SharePartition
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16753) Implement acknowledge functionality in SharePartition
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16752) Implement acquire functionality in SharePartition
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16749) Implement share fetch messages
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16751) Implement release acquired records in SharePartitionManager
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16750) Implement acknowledge API in SharePartitionManager
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16747) Implement share sessions and context
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16748) Implement share response handling in SharePartitionManager
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16746) Add support for share acknowledgement request in KafkaApis
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16745) Add support for share fetch request in KafkaApis
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16744) Add support for share group describe in KafkaApis
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16741) Add SharGroupHeartbeat API support in GroupCoordinator
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16742) Add ShareGroupDescribe API support in GroupCoordinator
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16740) Define skeleton for SharePartitionManager and SharePartition
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16739) Exclude protected variables from aggregated JavaDocs
Greg Harris (Jira)
[jira] [Created] (KAFKA-16738) Returns BaseRecords instead of MemoryRecords
Zhenyu Luo (Jira)
[KAFKA-16361] Rack aware sticky assignor minQuota violations
Julien Opoix
Re: [KAFKA-16361] Rack aware sticky assignor minQuota violations
Sophie Blee-Goldman
[KAFKA-16361] Rack aware sticky assignor minQuota violations
Julien Opoix
Re: [KAFKA-16361] Rack aware sticky assignor minQuota violations
Xiangyuan LI
[jira] [Created] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16736) Remove offsets.commit.required.acks in 4.0
David Jacot (Jira)
[jira] [Created] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8
David Jacot (Jira)
[jira] [Created] (KAFKA-16734) Add support for formatting records written to share-group state topic
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16730) Initial code for share-group consumer
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16733) Add support for formatting new records written to offsets topic
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16732) Support for share-coordinator-metrics in the broker
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16731) Support for share-group-metrics in the broker
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16728) Add dynamic group configuration for heartbeat interval and session timeout
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16729) Support for read-committed isolation level
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16726) Add dynamic group configuration for offset reset
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16725) Add broker configurations
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16727) Add dynamic group configuration for record lock duration
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16724) Add new options for kafka-producer-perf-test.sh
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16723) Add kafka-console-share-consumer.sh
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16722) Add ConsumerGroupPartitionAssignor and ShareGroupPartitionAssignor
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16721) Add exceptions for the new error codes
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16718) Add AdminClient.deleteShareGroupOffsets
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16719) Add AdminClient.deleteShareGroups
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16717) Add AdminClient.alterShareGroupOffsets
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16720) Add AdminClient.listShareGroupOffsets
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16716) Add AdminClient.describeShareGroups and AdminClient.listShareGroups
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16715) Create KafkaShareConsumer interface
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16714) kafka-share-groups.sh supporting list and describe
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16713) Add new RPC definitions
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16712) Race while setting RemoteLogMetadataTopicPartitioner in TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest
Gaurav Narula (Jira)
[jira] [Created] (KAFKA-16711) highestOffsetInRemoteStorage is not updated after logDir altering within broker
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-16587) Store subscription model for consumer group in group state
David Jacot (Jira)
[jira] [Created] (KAFKA-16710) Continuously `makeFollower` may cause the replica fetcher thread to encounter an offset mismatch exception when `processPartitionData`
hudeqi (Jira)
[jira] [Resolved] (KAFKA-16663) CoordinatorRuntime write timer tasks should be cancelled once HWM advances
David Jacot (Jira)
[jira] [Resolved] (KAFKA-16677) Replace ClusterType#ALL and ClusterType#DEFAULT by Array
Chia-Ping Tsai (Jira)
why check producer record batch is full used uncompressed size, not use the compressed size
jiang dou
[jira] [Created] (KAFKA-16709) move logDir within broker might cause log cleanup hanging
Luke Chen (Jira)
[jira] [Created] (KAFKA-16708) Allow dynamic port for advertised listeners in Docker image
Chris Bono (Jira)
[jira] [Created] (KAFKA-16707) Kafka Kraft : adding Principal Type in StandardACL for matching with KafkaPrincipal of connected client
Franck L. (Jira)
[jira] [Created] (KAFKA-16706) Refactor ReplicationQuotaManager/RLMQuotaManager to eliminate code duplication
Abhijeet Kumar (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2895
Apache Jenkins Server
[jira] [Created] (KAFKA-16705) the flag "started" of RaftClusterInstance is false even though the cluster is started
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16679) Merge unit test down to the class of integration test
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16704) Fix flaky kafka.log.remote.RemoteIndexCacheTest#testIndexFileAlreadyExistOnDiskButNotInCache
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16703) SocketServer leaks ServerSocketChannel when port is already in-use
Greg Harris (Jira)
[jira] [Created] (KAFKA-16702) KafkaLog4jAppenderTest leaks producer instances
Greg Harris (Jira)
[jira] [Resolved] (KAFKA-16513) Allow WriteTxnMarkers API with Alter Cluster Permission
Justine Olshan (Jira)
[jira] [Created] (KAFKA-16701) Some SocketServerTest buffered close tests flaky failing locally
Greg Harris (Jira)
[jira] [Created] (KAFKA-16700) Kafka Streams: possible message loss on KTable-KTable FK Left Join
Jira
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2891
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2892
Apache Jenkins Server
[jira] [Created] (KAFKA-16699) Have Streams treat InvalidPidMappingException like a ProducerFencedException
Walker Carlson (Jira)
[jira] [Created] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16697) Fix flaky kafka.api.SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeWithWildcardAcls
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16688) SystemTimer leaks resources on close
Igor Soarez (Jira)
[PR] Add Skillsoft to "Powered By" [kafka-site]
via GitHub
Re: [PR] Add Skillsoft to "Powered By" [kafka-site]
via GitHub
Re: [PR] Add Skillsoft to "Powered By" [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-16445) PATCH method for connector configuration
Ivan Yurchenko (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2889
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-12947) Replace EasyMock and PowerMock with Mockito for StreamsMetricsImplTest ...
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty
Chia-Ping Tsai (Jira)
[DISCUSS] KIP-891: Running multiple versions of Connector plugins
Greg Harris
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Snehashis
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Greg Harris
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Snehashis
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Chris Egerton
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Greg Harris
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Chris Egerton
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Greg Harris
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Chris Egerton
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Greg Harris
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Chris Egerton
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Greg Harris
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Chris Egerton
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Snehashis
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Greg Harris
Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins
Snehashis
[jira] [Created] (KAFKA-16696) Remove the in-memory implementation of RSM and RLMM
Kamal Chandraprakash (Jira)
[jira] [Created] (KAFKA-16695) Improve expired poll interval logging by showing exceeded time
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-16676) Security docs missing RPCs from KIP-714 and KIP-1000
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-16595) Introduce ClusterTemplate in ClusterTests
Kuan Po Tseng (Jira)
[jira] [Created] (KAFKA-16694) Remove rack aware code in assignors temporarily due to performance
Ritika Reddy (Jira)
[jira] [Created] (KAFKA-16693) Kafka Users are created with ACL entries and during performing operations allowed by ACL we see Denied Operation
Janardhana Gopalachar (Jira)
[VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)
David Jacot
Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)
Andrew Schofield
Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)
Federico Valeri
Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)
Justine Olshan
Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)
Manikumar
Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)
David Jacot
Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)
Matthias J. Sax
[jira] [Resolved] (KAFKA-16108) Backport fix for KAFKA-16093 to 3.7
Chris Egerton (Jira)
[jira] [Resolved] (KAFKA-16685) RLMTask warning logs do not include parent exception trace
Jorge Esteban Quilcate Otoya (Jira)
[jira] [Created] (KAFKA-16692) InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when
Johnson Okorie (Jira)
[jira] [Resolved] (KAFKA-16640) Replace TestUtils#resource by scala.util.Using
Chia-Ping Tsai (Jira)
KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Mario Fiore Vitale
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Chris Egerton
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Mario Fiore Vitale
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Chris Egerton
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Chris Egerton
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Mario Fiore Vitale
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Chris Egerton
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Mario Fiore Vitale
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Chris Egerton
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Mario Fiore Vitale
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Chris Egerton
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Chris Egerton
Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations
Mario Fiore Vitale
Earlier messages
Later messages