dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Resolved] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer
Philip Nee (Jira)
[jira] [Created] (KAFKA-16585) No way to forward message from punctuation method in the FixedKeyProcessor
Stanislav Spiridonov (Jira)
[jira] [Created] (KAFKA-16584) Make log processing summary configurable or debug
Andras Hatvani (Jira)
[jira] [Created] (KAFKA-16583) Update from 3.4.0 to 3.7.0 image write failed in Kraft mode
HanXu (Jira)
[jira] [Created] (KAFKA-16582) Feature Request: Introduce max.record.size Configuration Parameter for Producers
Ramiz Mehran (Jira)
[jira] [Created] (KAFKA-16581) Implement KafkaRaftClient unittest for membership change
Jira
[jira] [Created] (KAFKA-16580) Write simulation tests for kraft membership change
Jira
[jira] [Created] (KAFKA-16579) Revert changes to consumer_rolling_upgrade_test.py for the new async Consumer
Kirk True (Jira)
[jira] [Created] (KAFKA-16578) Revert changes to connect_distributed_test.py for the new async Consumer
Kirk True (Jira)
[jira] [Created] (KAFKA-16577) New consumer fails with stop timeout in consumer_test.py’s test_consumer_bounce system test
Kirk True (Jira)
[jira] [Created] (KAFKA-16576) New consumer fails with assert in consumer_test.py’s test_consumer_failure system test
Kirk True (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.7 #138
Apache Jenkins Server
[jira] [Created] (KAFKA-16575) Automatically remove KTable aggregation result when group becomes empty
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-16574) The metrics of LogCleaner disappear after reconfiguration
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16405) Mismatch assignment error when running consumer rolling upgrade system tests
Kirk True (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2821
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2822
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2823
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2824
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2825
Apache Jenkins Server
[jira] [Created] (KAFKA-16573) Streams does not specify where a Serde is needed
Ayoub Omari (Jira)
[DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Omnia Ibrahim
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Justine Olshan
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Lucas Brutschy
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Chris Egerton
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Andrew Schofield
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Matthias J. Sax
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Matthias J. Sax
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Knowles Atchison Jr
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Kirk True
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Justine Olshan
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Kirk True
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Chris Egerton
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Justine Olshan
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Chris Egerton
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Justine Olshan
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Artem Livshits
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Matthias J. Sax
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Chris Egerton
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Justine Olshan
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Artem Livshits
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Andrew Schofield
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Chris Egerton
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Justine Olshan
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Chris Egerton
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Justine Olshan
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Andrew Schofield
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Alieh Saeedi
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Chris Egerton
Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer
Federico Valeri
Re: [DISCUSS] KIP-892: Transactional Semantics for StateStores
Nick Telford
[jira] [Created] (KAFKA-16572) allow defining number of disks per broker in ClusterTest
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16559) allow defining number of disks per broker in TestKitNodes
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16571) reassign_partitions_test.bounce_brokers should wait for messages to be sent to every partition
David Mao (Jira)
[jira] [Created] (KAFKA-16570) FenceProducers API returns "unexpected error" when successful
Justine Olshan (Jira)
[jira] [Created] (KAFKA-16569) Target Assignment Format Change
Ritika Reddy (Jira)
[jira] [Created] (KAFKA-16568) Add JMH Benchmarks for assignor performance testing
Ritika Reddy (Jira)
[jira] [Created] (KAFKA-16567) Add New Stream Metrics based on KIP-869
Walter Hernandez (Jira)
[VOTE] KIP-924: customizable task assignment for Streams
Rohan Desai
Re: [VOTE] KIP-924: customizable task assignment for Streams
Sophie Blee-Goldman
Re: [VOTE] KIP-924: customizable task assignment for Streams
Matthias J. Sax
Re: [VOTE] KIP-924: customizable task assignment for Streams
Bruno Cadonna
Re: [VOTE] KIP-924: customizable task assignment for Streams
Lucas Brutschy
Re: [VOTE] KIP-924: customizable task assignment for Streams
Rohan Desai
[jira] [Created] (KAFKA-16566) Update static membership fencing system test to support new protocol
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16565) IncrementalAssignmentConsumerEventHandler throws error when attempting to remove a partition that isn't assigned
Kirk True (Jira)
Permission to contribute to Apache Kafka Project
Robin Han
Re: Permission to contribute to Apache Kafka Project
Josep Prat
[jira] [Created] (KAFKA-16564) Apply `Xlint` to java code in core module
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16563) migration to KRaft hanging after KeeperException
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-16562) Install the ginkgo to tools folder
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16562) Install the ginkgo to tools folder
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16561) Disable `allow.auto.create.topics` in MirrorMaker2 Consumer Config
Yangkun Ai (Jira)
[jira] [Created] (KAFKA-16560) Refactor/cleanup BrokerNode/ControllerNode/ClusterConfig
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16559) Support to define the number of data folders in ClusterTest
Chia-Ping Tsai (Jira)
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2816
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2817
Apache Jenkins Server
[jira] [Created] (KAFKA-16558) Implement HeartbeatRequestState.toStringBase()
Kirk True (Jira)
[jira] [Created] (KAFKA-16557) Fix CommitRequestManager’s OffsetFetchRequestState.toString()
Kirk True (Jira)
[jira] [Created] (KAFKA-16556) Race condition between ConsumerRebalanceListener and SubscriptionState
Kirk True (Jira)
[jira] [Created] (KAFKA-16555) Consumer's RequestState has incorrect logic to determine if inflight
Kirk True (Jira)
[jira] [Created] (KAFKA-16554) Online downgrade triggering and group type conversion
Dongnuo Lyu (Jira)
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Chris Egerton
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Andrew Schofield
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Omnia Ibrahim
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Manikumar
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Jun Rao
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Rajini Sivaram
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Ivan Yurchenko
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Ivan Yurchenko
Re: [VOTE] KIP-899: Allow producer and consumer clients to rebootstrap
Jun Rao
[jira] [Created] (KAFKA-16553) log controller configs when startup
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-15230) ApiVersions data between controllers is not reliable
Chia-Ping Tsai (Jira)
[jira] [Reopened] (KAFKA-15230) ApiVersions data between controllers is not reliable
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-15369) Allow AdminClient to Talk Directly with the KRaft Controller Quorum and add Controller Registration
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16552) Create an internal config to control InitialTaskDelayMs in LogManager to speed up tests
Luke Chen (Jira)
[jira] [Created] (KAFKA-16551) add integration test for ClusterTool
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16550) add integration test for LogDirsCommand
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16490) Upgrade gradle from 8.6 to 8.7
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16549) suppress the warnings from RemoteLogManager
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-16467: Add how to integrate with kafka repo [kafka-site]
via GitHub
Re: [PR] KAFKA-16467: Add how to integrate with kafka repo [kafka-site]
via GitHub
Re: [PR] KAFKA-16467: Add how to integrate with kafka repo [kafka-site]
via GitHub
Re: [PR] KAFKA-16467: Add how to integrate with kafka repo [kafka-site]
via GitHub
Re: [PR] KAFKA-16467: Add how to integrate with kafka repo [kafka-site]
via GitHub
Request for Contributor Permission
Suprem Vanam
Re: Request for Contributor Permission
Luke Chen
[jira] [Resolved] (KAFKA-15729) KRaft support in GetOffsetShellTest
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-4560) Min / Max Partitions Fetch Records params
Walter Hernandez (Jira)
[jira] [Resolved] (KAFKA-15748) KRaft support in MetricsDuringTopicCreationDeletionTest
Walter Hernandez (Jira)
[jira] [Resolved] (KAFKA-2499) kafka-producer-perf-test should use something more realistic than empty byte arrays
Walter Hernandez (Jira)
[ANNOUNCE] New Kafka PMC Member: Greg Harris
Chris Egerton
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Mickael Maison
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Boudjelda Mohamed Said
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Bill Bejeck
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Viktor Somogyi-Vass
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Luke Chen
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Randall Hauch
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Yash Mayya
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Kamal Chandraprakash
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Divij Vaidya
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Josep Prat
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Jorge Esteban Quilcate Otoya
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Sophie Blee-Goldman
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Ivan Yurchenko
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Claude Warren
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Satish Duggana
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Bruno Cadonna
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Manikumar
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Zhisheng Zhang
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Christo Lolov
Re:[ANNOUNCE] New Kafka PMC Member: Greg Harris
Hector Geraldino (BLOOMBERG/ 919 3RD A)
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Matthias J. Sax
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Justine Olshan
Re: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Lucas Brutschy
[jira] [Created] (KAFKA-16547) add test for DescribeConfigsOptions#includeDocumentation
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16546) add docs to explain how to update cluster-wide default by Admin#incrementalAlterConfigs
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #135
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #136
Apache Jenkins Server
[jira] [Created] (KAFKA-16545) Auto adjust the replica factor according to number of broker when using ClusterTestExtensions
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16544) DescribeTopicsResult#allTopicIds and DescribeTopicsResult#allTopicNames should return null instead of throwing NPE
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16543) There may be ambiguous deletions in the `cleanupGroupMetadata` when the generation of the group is less than or equal to 0
hudeqi (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #133
Apache Jenkins Server
[VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Omnia Ibrahim
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Mickael Maison
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Chris Egerton
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Omnia Ibrahim
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Igor Soarez
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Omnia Ibrahim
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Omnia Ibrahim
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Igor Soarez
Re: [VOTE] KIP-1031: Control offset translation in MirrorSourceConnector
Omnia Ibrahim
[jira] [Created] (KAFKA-16542) The remote node is not a BROKER that supports the METADATA api. (org.apache.kafka.clients.admin.internals.AdminMetadataManager)
Hiro (Jira)
[jira] [Resolved] (KAFKA-16510) java.lang.OutOfMemoryError in kafka-metadata-quorum.sh
Hiro (Jira)
[jira] [Resolved] (KAFKA-16473) KafkaDockerWrapper uses wrong cluster ID when formatting log dir
Manikumar (Jira)
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2807
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2808
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2809
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2810
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2811
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2812
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2813
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2814
Apache Jenkins Server
[jira] [Created] (KAFKA-16541) Potential leader epoch checkpoint file corruption on OS crash
Haruki Okada (Jira)
[jira] [Created] (KAFKA-16540) Update partitions when the min isr config is updated.
Calvin Liu (Jira)
[jira] [Resolved] (KAFKA-15586) Clean shutdown detection, server side
Calvin Liu (Jira)
[jira] [Created] (KAFKA-16539) Can't update specific broker configs in pre-migration mode
David Arthur (Jira)
[jira] [Created] (KAFKA-16538) UpdateFeatures for kraft.version
Jira
[jira] [Created] (KAFKA-16537) RemoveVoter RPC and request handling
Jira
[jira] [Created] (KAFKA-16536) Use BeginQuorumEpoch as the leader's heartbeat
Jira
[jira] [Created] (KAFKA-16535) AddVoter RPC and request handling
Jira
[jira] [Created] (KAFKA-16534) Sending UpdateVoter request and response handling
Jira
[jira] [Created] (KAFKA-16533) UpdateVoter RPC and request handling
Jira
[jira] [Created] (KAFKA-16532) Support for first leader bootstrapping the voter set
Jira
[jira] [Created] (KAFKA-16531) Fix check-quorum calculation to no assume that the leader is in the voter set
Jira
[jira] [Created] (KAFKA-16530) Fix high-watermark calculation to no assume the leader is in the voter set
Jira
[jira] [Created] (KAFKA-16529) Response handling and request sending for voters RPCs
Jira
[jira] [Created] (KAFKA-16528) Reset member heartbeat interval when request sent
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16527) RPC changes and request handling
Jira
[jira] [Created] (KAFKA-16526) Change to quorum state for KIP-853
Jira
[jira] [Created] (KAFKA-16525) Request manager and raft channel discover node endpoints
Jira
[jira] [Created] (KAFKA-16524) Metrics for KIP-853
Jira
[jira] [Created] (KAFKA-16523) kafka-metadata-quorum add voter and remove voter changes
Jira
[jira] [Created] (KAFKA-16522) Implement Admin client changes for adding and removing votes
Jira
[jira] [Created] (KAFKA-16521) Implement kafka-metadata-quorum describe changes for KIP-853
Jira
[jira] [Created] (KAFKA-16520) Implement changes to DescribeQuorum response
Jira
[jira] [Created] (KAFKA-16519) Expose the supported and finalized kraft.version in ApiVersions response
Jira
[jira] [Created] (KAFKA-16518) Implement storage tool changes for KIP-853
Jira
[jira] [Created] (KAFKA-16517) Do not decode metadata records in the internal kraft partition listener
Jira
[jira] [Created] (KAFKA-16516) Fix the controller node provider for broker to control channel
Jira
[jira] [Created] (KAFKA-16515) Fix the ZK Metadata cache use of voter static configuration
Jira
[jira] [Created] (KAFKA-16514) Kafka Streams: stream.close(CloseOptions) does not respect options.leaveGroup flag.
Sal Sorrentino (Jira)
Earlier messages
Later messages