dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
[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
[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
[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
[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
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
[jira] [Resolved] (KAFKA-16678) Remove unimplementedquorum from EndToEndAuthorizationTest
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16691) Support for nested structures: TimestampConverter
Jorge Esteban Quilcate Otoya (Jira)
[jira] [Created] (KAFKA-16690) Support for nested structures: HeaderFrom
Jorge Esteban Quilcate Otoya (Jira)
[jira] [Resolved] (KAFKA-14226) Introduce support for nested structures
Jorge Esteban Quilcate Otoya (Jira)
[jira] [Created] (KAFKA-16689) Move LogValidatorTest to storage module
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16688) SystemTimer leaks resources on close
Gaurav Narula (Jira)
Request version not enabled errors upgrading from Kafka 3.5 -> 3.6
Johnson Okorie
Re: Request version not enabled errors upgrading from Kafka 3.5 -> 3.6
Justine Olshan
Re: Request version not enabled errors upgrading from Kafka 3.5 -> 3.6
Johnson Okorie
[jira] [Resolved] (KAFKA-15018) Potential tombstone offsets corruption for exactly-once source connectors
Chris Egerton (Jira)
[jira] [Created] (KAFKA-16687) Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0
FTR (Jira)
[jira] [Created] (KAFKA-16686) Flakey tests in TopicBasedRemoteLogMetadataManagerTest
Gaurav Narula (Jira)
[VOTE] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [VOTE] KIP-1038: Add Custom Error Handler to Producer
Andrew Schofield
Re: [VOTE] KIP-1038: Add Custom Error Handler to Producer
Walker Carlson
Re: [VOTE] KIP-1038: Add Custom Error Handler to Producer
Kirk True
[jira] [Resolved] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters
Chris Egerton (Jira)
[jira] [Resolved] (KAFKA-13328) Connect does not perform preflight validation for per-connector header converters
Chris Egerton (Jira)
Creating kafka wiki id
黃竣陽
Re: Creating kafka wiki id
Matthias J. Sax
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2879
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2880
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2881
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2882
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2883
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2884
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2885
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2886
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16307) fix EventAccumulator thread idle ratio metric
David Jacot (Jira)
[jira] [Created] (KAFKA-16685) RSM Task warn logs do not include parent exception trace
Jorge Esteban Quilcate Otoya (Jira)
[jira] [Created] (KAFKA-16684) FetchResponse#responseData could return incorrect data
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16683) Extract security-related helpers from scala.TestUtils to java class
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16682) Rewrite JassTestUtils by Java
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16681) Rewrite MiniKDC by Java
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16680) Make ClusterTestExtensions support SASL
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16679) Merge `DeleteRecordsCommandUnitTest` into `DeleteRecordsCommandTest`, `FeatureCommandUnitTest` into
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16615) JoinGroup API for upgrading ConsumerGroup
David Jacot (Jira)
[jira] [Created] (KAFKA-16678) Remove unimplementedquorum from EndToEndAuthorizationTest
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16593) Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2877
Apache Jenkins Server
[jira] [Created] (KAFKA-16677) Replace ClusterType#ALL and ClusterType#DEFAULT by Array
Chia-Ping Tsai (Jira)
request permissions to contribute to Kafka
Zhisheng Zhang
Re: request permissions to contribute to Kafka
Luke Chen
[jira] [Resolved] (KAFKA-16470) kafka-dump-log --offsets-decoder should support new records
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16608) AsyncKafkaConsumer doesn't honor interrupted thread status on KafkaConsumer.poll(Duration)
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16356) Remove class-name dispatch in RemoteLogMetadataSerde
Greg Harris (Jira)
[jira] [Created] (KAFKA-16676) Security docs missing RPCs from KIP-714 and KIP-1000
Andrew Schofield (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2875
Apache Jenkins Server
[jira] [Created] (KAFKA-16675) Move rebalance callback test for positions to callbacks test file
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16674) Adjust classicGroupJoinToConsumerGroup to add subscription model
Dongnuo Lyu (Jira)
[jira] [Created] (KAFKA-16673) Optimize toTopicPartitions with ConsumerProtocolSubscription
Dongnuo Lyu (Jira)
[jira] [Resolved] (KAFKA-16393) SslTransportLayer doesn't implement write(ByteBuffer[], int, int) correctly
Chia-Ping Tsai (Jira)
[VOTE] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config
Luke Chen
Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config
Federico Valeri
Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config
Christo Lolov
Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config
Satish Duggana
Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
[jira] [Created] (KAFKA-16672) Fix flaky DedicatedMirrorIntegrationTest.testMultiNodeCluster
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16671) Revisit SessionedProtocolIntegrationTest.ensureInternalEndpointIsSecured
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16670) KIP-848 : Consumer will not receive assignment forever because of concurrent issue.
sanghyeok An (Jira)
[jira] [Resolved] (KAFKA-16659) KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16669) Remove extra collection copy when genrating DescribeAclsResource
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2871
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2872
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2873
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16624) Don't generate useless PartitionChangeRecord on older MV
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16668) Enable to set tags by `ClusterTest`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16667) KRaftMigrationDriver gets stuck after successive failovers
David Arthur (Jira)
[jira] [Created] (KAFKA-16666) Remove unused class `GroupMetadataMessageFormatter` and `OffsetsMessageFormatter`
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2869
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16474) AsyncKafkaConsumer might send out heartbeat request without waiting for its response
Philip Nee (Jira)
[jira] [Created] (KAFKA-16665) Fail to get partition's position from within onPartitionsAssigned callback in new consumer
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16664) Re-add EventAccumulator.take(timeout)
Jeff Kim (Jira)
[jira] [Created] (KAFKA-16663) CoordinatorRuntime write timer tasks should be cancelled once HWM advances
Jeff Kim (Jira)
[jira] [Created] (KAFKA-16662) UnwritableMetadataException: Metadata has been lost
Tobias Bohn (Jira)
[DISCUSS] KIP-1042 support for wildcard when creating new acls
Murali Basani
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Claude Warren
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Claude Warren, Jr
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Haruki Okada
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Claude Warren
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Greg Harris
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Claude Warren, Jr
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Murali Basani
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Claude Warren
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Muralidhar Basani
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Claude Warren
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Muralidhar Basani
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Greg Harris
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Muralidhar Basani
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Muralidhar Basani
Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls
Muralidhar Basani
[jira] [Created] (KAFKA-16661) add a lower `log.initial.task.delay.ms` value to integration test framework
Luke Chen (Jira)
[jira] [Created] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16572) allow defining number of disks per broker in ClusterTest
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16659) KafkaConsumer#position() does not respect wakup when group protocol is CONSUMER
Chia-Ping Tsai (Jira)
[PR] MINOR: Add code signing key for Igor [kafka-site]
via GitHub
Re: [PR] MINOR: Add code signing key for Igor [kafka-site]
via GitHub
[DISCUSS] Proposal about support for wildcard when creating new acls
Murali Basani
Suggestion about support for wildcard when creating new acls
Murali Basani
Earlier messages
Later messages