users
Thread
Date
Earlier messages
Messages by Thread
Kafka Streams Consumer Constantly Rebalance over 100k tps
Martinus Elvin
Kafka Raft 3 node cluster - NO authorizer configured error
Seetha Ramanjaneyulu
Schema Registry - serving multiple Kafka clusters
karan alang
Re: Schema Registry - serving multiple Kafka clusters
Brebner, Paul
Re: Schema Registry - serving multiple Kafka clusters
Shahar Cizer Kobrinsky
Re: Schema Registry - serving multiple Kafka clusters
karan alang
Re: Schema Registry - serving multiple Kafka clusters
Raphael Mazelier
Handling Private Methods in AclAuthorizer and Transition to StandardAuthorizer
Kasper Andersen Storgaard
Handling Private Methods in AclAuthorizer and Transition to StandardAuthorizer
Kasper Andersen Storgaard
Re: Handling Private Methods in AclAuthorizer and Transition to StandardAuthorizer
Luke Chen
Using cached FileTokenProvider for SASL/OAUTHBEARER for OIDC with k8s project service account tokens
Creed Haymond
Question about replication mechanism and leader election in Kafka
Ilya Starchenko
Re: Question about replication mechanism and leader election in Kafka
Haruki Okada
Re: Question about replication mechanism and leader election in Kafka
Ilya Starchenko
Re: Question about replication mechanism and leader election in Kafka
Haruki Okada
Startup error due to log.dirs being symbolic link
David
Seeking Advice on Restricting Kafka ACLs for Specific Operations
Achar, Bharath Kumar Cm
RE: Seeking Advice on Restricting Kafka ACLs for Specific Operations
Achar, Bharath Kumar Cm
Extracting key-value pair from Produce Request API.
Chain Head
Re: Extracting key-value pair from Produce Request API.
Greg Harris
Re: Extracting key-value pair from Produce Request API.
Chain Head
Re: Extracting key-value pair from Produce Request API.
Chain Head
Re: Extracting key-value pair from Produce Request API.
Greg Harris
Re: Extracting key-value pair from Produce Request API.
David Finnie
[HELP] kraft cluster sasl_plaintext(plain) not works without super.users configured
????
CVE-2024-56128: Apache Kafka: SCRAM authentication vulnerable to replay attacks when used without encryption
Manikumar
Kafka streams lost messages on repartition topic during rebalancing
TheKaztek
Re: Kafka streams lost messages on repartition topic during rebalancing
Bill Bejeck
Re: Kafka streams lost messages on repartition topic during rebalancing
TheKaztek
Re: Kafka streams lost messages on repartition topic during rebalancing
Bill Bejeck
Need help with issues setting up OAuth2 SASL authentication on Kafka
Subra I
[ANNOUNCE] Apache Kafka 3.7.2
Matthias J. Sax
Re: [ANNOUNCE] Apache Kafka 3.7.2
Bill Bejeck
[RESULT] [VOTE] Release Kafka version 3.7.2
Matthias J. Sax
Does Replication Throttling Work with "*"
Jason Taylor
RE: Does Replication Throttling Work with "*"
Harry Fallows
Warn error message after partial upgrade to 3.9 / upgrade catastrophic failure
Raphael Mazelier
Apache Kafka and Zookeeper Compatibility matrix
Kiran Satpute
Re: Apache Kafka and Zookeeper Compatibility matrix
Chia-Ping Tsai
Re: Apache Kafka and Zookeeper Compatibility matrix
Divij Vaidya
Config Kafka kraft
Ernar Ratbek
Re: Config Kafka kraft
Ernar Ratbek
[VOTE] 3.7.2 RC1
Matthias J. Sax
Re: [VOTE] 3.7.2 RC1
Bill Bejeck
Re: [VOTE] 3.7.2 RC1
Matthias J. Sax
Re: [VOTE] 3.7.2 RC1
Josep Prat
Re: [VOTE] 3.7.2 RC1
Divij Vaidya
Re: [VOTE] 3.7.2 RC1
Matthias J. Sax
Re: [VOTE] 3.7.2 RC1
Luke Chen
Re: [VOTE] 3.7.2 RC1
Andrew Schofield
Re: [VOTE] 3.7.2 RC1
Matthias J. Sax
Proper way to horizontally scale kafka 3 kraft cluster
Gregory Rybalka
Re: Proper way to horizontally scale kafka 3 kraft cluster
Greg Harris
Re: Proper way to horizontally scale kafka 3 kraft cluster
kafkaisthebest
[VOTE] [CANCELED] 3.7.2 RC0
Matthias J. Sax
Re: [ANNOUNCE] New committer: Andrew Schofield
Matthias J. Sax
Re: [ANNOUNCE] New committer: Andrew Schofield
Luke Chen
Re: [ANNOUNCE] New committer: Andrew Schofield
Satish Duggana
Intermediate CA communiation is not working between kafka and kafka-topic-manager/applications
Sravani
Kafka throughput calculation
Perez
Kafka cluster collapsed for no reason
Rybalka, Grigoriy (Fortebank)
Re: Kafka cluster collapsed for no reason
Oleksandr Shulgin
RE: COMMERCIAL:Re: Kafka cluster collapsed for no reason
Rybalka, Grigoriy (Fortebank)
Schema Registry on bare metal
wojtekodrobinski
Re: Schema Registry on bare metal
Brebner, Paul
Re: Schema Registry on bare metal
Artem Timchenko
Explicitly creating topology topics in a streams app
John D. Ament
Re: Explicitly creating topology topics in a streams app
Brebner, Paul
Re: Explicitly creating topology topics in a streams app
John D. Ament
Re: Explicitly creating topology topics in a streams app
Sophie Blee-Goldman
Data Corruption in Netty 4.1.111.Final (Kafka 3.9.0)
Thomas Thornton
Re: Data Corruption in Netty 4.1.111.Final (Kafka 3.9.0)
Thomas Thornton
[DISCUSS] Java 23 Support for 3.9.x
Greg Harris
Re: [DISCUSS] Java 23 Support for 3.9.x
David Arthur
Re: [DISCUSS] Java 23 Support for 3.9.x
Greg Harris
Re: [DISCUSS] Java 23 Support for 3.9.x
Chia-Ping Tsai
Re: [DISCUSS] Java 23 Support for 3.9.x
Josep Prat
Re: [DISCUSS] Java 23 Support for 3.9.x
Anton Agestam
Spread primary and replica of a partition across different zones in AWS
Soham Chakraborty
Re: Spread primary and replica of a partition across different zones in AWS
Oleksandr Shulgin
Re: Spread primary and replica of a partition across different zones in AWS
Soham Chakraborty
Re: Spread primary and replica of a partition across different zones in AWS
Oleksandr Shulgin
Re: Spread primary and replica of a partition across different zones in AWS
Soham Chakraborty
FW: [EXTERNAL] Re: Spread primary and replica of a partition across different zones in AWS
no-reply-cortevaquarantine5
FW: [EXTERNAL] Re: Spread primary and replica of a partition across different zones in AWS
no-reply-cortevaquarantine4
Kafka service failure seen during scaling
Sravani
Re: Kafka service failure seen during scaling
Sravani
CVE-2024-31141: Apache Kafka Clients: Privilege escalation to filesystem read-access via automatic ConfigProvider
Greg Harris
Re: CVE-2024-31141: Apache Kafka Clients: Privilege escalation to filesystem read-access via automatic ConfigProvider
Greg Harris
Re: CVE-2024-31141: Apache Kafka Clients: Privilege escalation to filesystem read-access via automatic ConfigProvider
Greg Harris
Fwd: Query on MM2 Compatibility for Kafka Versions
Atul Sharma
Kafka Connect
Surbhi Mungre
Re: Kafka Connect
Neeraj Vaidya
Re: Kafka Connect
Prince Varshney
Re: Kafka Connect
Ömer Şiar Baysal
Correct way to override Kafka Connect producer settings?
Mehrtens, Mazrim
Data Loss from Kafka Connect when Schema Registry requests fail
Thomas Thornton
Re: Data Loss from Kafka Connect when Schema Registry requests fail
Thomas Thornton
Kafka transactions allow aborted reads, lost writes, and torn transactions
Kyle Kingsbury
RE: Kafka transactions allow aborted reads, lost writes, and torn transactions
Artem Livshits
Kafka "kafka-metadata-quorum.sh" regression in 3.9.0
Jesus Cea
Re: Kafka "kafka-metadata-quorum.sh" regression in 3.9.0
Luke Chen
Fix for CVE-2024-47554
Sahil Sharma D
RE: Fix for CVE-2024-47554
Sahil Sharma D
RE: Fix for CVE-2024-47554
Sahil Sharma D
RE: Fix for CVE-2024-47554
Sahil Sharma D
Re: Fix for CVE-2024-47554
Josep Prat
Re: Fix for CVE-2024-47554
Matthias J. Sax
Safe removal of stray partition logs from a broker
Jakub Daniel
[ANNOUNCE] Apache Kafka 3.9.0
Colin McCabe
Re: [ANNOUNCE] Apache Kafka 3.9.0
Luke Chen
Re: [ANNOUNCE] Apache Kafka 3.9.0
Satish Duggana
Re: [ANNOUNCE] Apache Kafka 3.9.0
Josep Prat
Re: [ANNOUNCE] Apache Kafka 3.9.0
Apoorv Mittal
can we have a plaintext and sasl protocol together with acl enabled
Sameer Modak
Re: can we have a plaintext and sasl protocol together with acl enabled
Ömer Şiar Baysal
Strimzi kafka on k8s - only bootstrap server has public IP, brokers have Cluster IP
karan alang
Re: Strimzi kafka on k8s - only bootstrap server has public IP, brokers have Cluster IP
Richard Bosch
ApiVersionsResponse writes apiKeys prepended with two bytes instead of one byte.
Chain Head
Re: ApiVersionsResponse writes apiKeys prepended with two bytes instead of one byte.
Chain Head
Advice on how to comprehend Kafka source code
Xiang Zhang
Re: Advice on how to comprehend Kafka source code
Colin McCabe
Q: Does Kafka log level affect performance and latency
Om Shree
Re: Q: Does Kafka log level affect performance and latency
Brebner, Paul
Re: Q: Does Kafka log level affect performance and latency
Brebner, Paul
Re: Q: Does Kafka log level affect performance and latency
Artem Timchenko
Logging configuration to see from which AZ consumers are fetching data in AWS environment
Soham Chakraborty
Re: Logging configuration to see from which AZ consumers are fetching data in AWS environment
Ömer Şiar Baysal
Re: Logging configuration to see from which AZ consumers are fetching data in AWS environment
Soham Chakraborty
Re: Logging configuration to see from which AZ consumers are fetching data in AWS environment
Artem Timchenko
Re: Logging configuration to see from which AZ consumers are fetching data in AWS environment
Soham Chakraborty
Re: Logging configuration to see from which AZ consumers are fetching data in AWS environment
Soham Chakraborty
Re: Logging configuration to see from which AZ consumers are fetching data in AWS environment
Artem Timchenko
[ANNOUNCE] Apache Kafka 3.8.1
Josep Prat
Re: [ANNOUNCE] Apache Kafka 3.8.1
Jesus Cea
Re: [ANNOUNCE] Apache Kafka 3.8.1
Jesus Cea
Re: [ANNOUNCE] Apache Kafka 3.8.1
Jesus Cea
Re: [ANNOUNCE] Apache Kafka 3.8.1
Josep Prat
Schema performance concerns?
Paul Nienaber
Developers needed
Alexandre Ruggiu
Inquiry on Scale Down Process for KRaft Kafka Cluster
이호호
Fwd: Inquiry on Scale Down Process for KRaft Kafka Cluster
hayoung lee
Re: Inquiry on Scale Down Process for KRaft Kafka Cluster
Luke Chen
Re: Inquiry on Scale Down Process for KRaft Kafka Cluster
sunil chaudhari
RE: Re: Inquiry on Scale Down Process for KRaft Kafka Cluster
hayoung lee
Kafka Tiered Storage Disablement Implement in ZK Mode Question
Jianfeng Lin
Re: Kafka Tiered Storage Disablement Implement in ZK Mode Question
Luke Chen
Re: Kafka Tiered Storage Disablement Implement in ZK Mode Question
Kamal Chandraprakash
Re: Kafka Tiered Storage Disablement Implement in ZK Mode Question
Kamal Chandraprakash
Re: Kafka Tiered Storage Disablement Implement in ZK Mode Question
Jianfeng Lin
Re: Kafka Tiered Storage Disablement Implement in ZK Mode Question
Jianfeng Lin
Kafka wire protocol and Wireshark capture don't seem to align.
Chain Head
Re: Kafka wire protocol and Wireshark capture don't seem to align.
Ömer Şiar Baysal
Re: Kafka wire protocol and Wireshark capture don't seem to align.
Chain Head
Re: Kafka wire protocol and Wireshark capture don't seem to align.
Steven Miller
Re: Kafka wire protocol and Wireshark capture don't seem to align.
Chain Head
Kafka wire protocol - Request and response versions.
Chain Head
Re: Kafka wire protocol - Request and response versions.
Ivan Yurchenko
Re: Kafka wire protocol - Request and response versions.
Chain Head
Re: Kafka wire protocol - Request and response versions.
Ivan Yurchenko
Kafka producer transaction details
Artur Bondek
Re: Kafka producer transaction details
Greg Harris
SLF4J error when running Kafka in IDEA
Xiang Zhang
Updating log.dirs using 'kafka-reassign-partitions' spamming 'ReplicaFetcher: Current offset 0 for partition 0 is out of range, ... Reset fetch offset to 0'
Julian Bergner
Re: doc clarification about meesage format
Xiang Zhang
Re: doc clarification about meesage format
Greg Harris
Re: doc clarification about meesage format
Xiang Zhang
Get topic creationTimestamp through Admin Client (or Client)
Erik Godding Boye
Re: Get topic creationTimestamp through Admin Client (or Client)
Ömer Şiar Baysal
Re: Get topic creationTimestamp through Admin Client (or Client)
Erik Godding Boye
Re: Get topic creationTimestamp through Admin Client (or Client)
Vinay Bagare
Re: Get topic creationTimestamp through Admin Client (or Client)
Erik Godding Boye
[VOTE] 3.8.1 RC1
Josep Prat
Re: [VOTE] 3.8.1 RC1
Josep Prat
Re: [VOTE] 3.8.1 RC1
Jakub Scholz
Re: [VOTE] 3.8.1 RC1
Josep Prat
IllegalStateException :Tried to lookup lag for unknown task 1_0
Hima Mohan
[VOTE] 3.8.1 RC0
Josep Prat
KAFKA POLL
Sathishkumar Palanisamy
Re: KAFKA POLL
Matthias J. Sax
Re: [EXT MSG] Re: KAFKA POLL
Sathishkumar Palanisamy
Re: [EXT MSG] Re: KAFKA POLL
Matthias J. Sax
RE: [EXT MSG] Re: KAFKA POLL
Sathishkumar Palanisamy
Missing upgrade notes?
Sarah Brofeldt
Re: Missing upgrade notes?
Josep Prat
Re: Missing upgrade notes?
Josep Prat
kafka MirrorMaker2 - stop offset sync when consumer group idle on source cluster
Massimiliano Rotondo
Re: kafka MirrorMaker2 - stop offset sync when consumer group idle on source cluster
Greg Harris
Re: kafka MirrorMaker2 - stop offset sync when consumer group idle on source cluster
Mehrtens, M
Setting server.properties for OAuth from Azure
Shaw, Kerwn
How to store log data on host using kafka native docker?
Jörg Wille
Please add me to kafka user group
Prince Varshney
[DISCUSS] bug fix to allow dynamically change some log configs
Luke Chen
Re: [DISCUSS] bug fix to allow dynamically change some log configs
Colin McCabe
Re: [DISCUSS] bug fix to allow dynamically change some log configs
Luke Chen
Kafka KRaft Mode - Access Denied Exception When Deleting Snapshot Files
Nishant Chauhan
Inquiry about Kafka topic reassigin
李闯闯
CommitFailedException during rebalance of cooperative-sticky consumer, message is not retried
galya bocheva
[VOTE] 3.9.0 RC0
Colin McCabe
Re: [VOTE] 3.9.0 RC0
Jakub Scholz
Earlier messages