users  

Messages by Thread

• MM2: Failed to reconfigure connector's tasks (MirrorCheckpointConnector), retrying after backoff An, Hongguo (CORP)
  • Re: MM2: Failed to reconfigure connector's tasks (MirrorCheckpointConnector), retrying after backoff Urbán Dániel
• Kafka Streams Topology State Peter Cipov
  • Re: Kafka Streams Topology State Sophie Blee-Goldman
• kafka stream zombie state Samuel Azcona
  • kafka stream zombie state Samuel Azcona
  • Re: kafka stream zombie state Sophie Blee-Goldman
  • RE: Re: kafka stream zombie state Samuel Azcona
• Need help on upgrade kafka from 2.7.0 to 3.2.1 sowjanya reddy
  • Re: Need help on upgrade kafka from 2.7.0 to 3.2.1 sunil chaudhari
  • Re: Need help on upgrade kafka from 2.7.0 to 3.2.1 Fred Bai
  • Re: Need help on upgrade kafka from 2.7.0 to 3.2.1 Patrick Taylor
• Replication of consumer group offset Raphael Mazelier
  • Re: Replication of consumer group offset Raphael Mazelier
• Consumer not polling any messages with random group.id ARABEYRE Étienne
• fluentd with kafka 3 issues pengyh
  • Re: fluentd with kafka 3 issues Raphael Mazelier
  • Re: fluentd with kafka 3 issues pengyh
• Invalid PEM keystore configs Sourabh Mokhasi
  • Invalid PEM keystore configs Sourabh Mokhasi
• leftjoin not working as expected. Chad Preisler
  • Re: leftjoin not working as expected. Guozhang Wang
  • Re: leftjoin not working as expected. Chad Preisler
• Intermittent kafka-consumer-perf-test.sh timeouts during tests Afonso Mukai
• 3.3 release date? Gregory M. Foreman
• How to measure/monitor lag for Mirror Maker 2 Ashish Gupta
• [ANNOUNCE] Apache Kafka 3.2.1 David Arthur
  • Re: [ANNOUNCE] Apache Kafka 3.2.1 Mickael Maison
  • Re: [ANNOUNCE] Apache Kafka 3.2.1 Bill Bejeck
  • Re: [ANNOUNCE] Apache Kafka 3.2.1 Matthew Benedict de Detrich
  • Re: [ANNOUNCE] Apache Kafka 3.2.1 Colin McCabe
  • Fw: Re: [ANNOUNCE] Apache Kafka 3.2.1 podunk
  • Re: Fw: Re: [ANNOUNCE] Apache Kafka 3.2.1 Josep Prat
  • Re: Fw: Re: [ANNOUNCE] Apache Kafka 3.2.1 podunk
  • Re: [ANNOUNCE] Apache Kafka 3.2.1 Kirk True
  • Re: [ANNOUNCE] Apache Kafka 3.2.1 Bruno Cadonna
• [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Guozhang Wang
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Adam Bellemare
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Luke Chen
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman David Quigley
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman pengyh
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Josep Prat
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Viktor Somogyi-Vass
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Mickael Maison
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Mazen Ezzeddine
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Chris Egerton
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman John Roesler
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Anna McDonald
  • Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman Matthew Benedict de Detrich
• Query regarind iPv6 setup and produce using ipv6 listener Nanda Naga
• An existing connection was forcibly closed by the remote host podunk
  • Fw: An existing connection was forcibly closed by the remote host podunk
  • Re: Fw: An existing connection was forcibly closed by the remote host Luke Chen
• Expand embedded cluster at the Integration test Taras Ledkov
• Apache Kafka acknowledgement selva raj selvaraj
  • Re: Apache Kafka acknowledgement Richard Bosch
  • Re: Apache Kafka acknowledgement Mohammad.R esmailzadeh
• question: kafka stream Tumbling Window can't close when no producer sending message 张家帅
  • Re: question: kafka stream Tumbling Window can't close when no producer sending message John Roesler
• [RESULTS] [VOTE] Release Kafka version 3.2.1 David Arthur
• Kafka certificate monitoring Sandeep M
  • Re: Kafka certificate monitoring Luke Chen
  • Re: Kafka certificate monitoring Fares Oueslati
• Question about log lock removal Tomas Alabes
• [ANNOUNCE] New Committer: Chris Egerton Mickael Maison
  • Re: [ANNOUNCE] New Committer: Chris Egerton Josep Prat
  • Re: [ANNOUNCE] New Committer: Chris Egerton Matthew Benedict de Detrich
  • Re: [ANNOUNCE] New Committer: Chris Egerton Viktor Somogyi-Vass
  • Re: [ANNOUNCE] New Committer: Chris Egerton Martin Gainty
  • Re: [ANNOUNCE] New Committer: Chris Egerton Anna McDonald
  • Re: [ANNOUNCE] New Committer: Chris Egerton Luke Chen
  • Re: [ANNOUNCE] New Committer: Chris Egerton John Roesler
  • Re: [ANNOUNCE] New Committer: Chris Egerton Chris Egerton
• Kafka Consumer JMX incoming byte rate to 0 Jose Manuel Vega Monroy
• perf test on kafka and mirror2 Calvin Chen
• Performance test latency Ivanov, Evgeny
  • Re: Performance test latency Yurii Demchenko
• [VOTE] 3.2.1 RC3 David Arthur
  • Re: [VOTE] 3.2.1 RC3 Christopher Shannon
  • Re: [VOTE] 3.2.1 RC3 Federico Valeri
  • Re: [VOTE] 3.2.1 RC3 Jakub Scholz
  • Re: [VOTE] 3.2.1 RC3 Randall Hauch
  • Re: [VOTE] 3.2.1 RC3 Rajini Sivaram
  • Re: [VOTE] 3.2.1 RC3 Matthew Benedict de Detrich
  • Re: [VOTE] 3.2.1 RC3 Bill Bejeck
  • Re: [VOTE] 3.2.1 RC3 David Arthur
• Designing a low latency consumer Vasant Surya Teja
  • Re: Designing a low latency consumer Patrick Taylor
• OutOfRange event handler Sasha Korn
• DataMass Summit waiting for a speakers Klaudia Wachnio
• MM2 - mapping different replica number An, Hongguo (CORP)
  • Re: MM2 - mapping different replica number Ryanne Dolan
• Clarification Kafka - MySQL Alalasundaram Saravanan
  • Re: Clarification Kafka - MySQL Richard Bosch
• Inquiry about using SSL encryption and SASL authentication for Kafka without specifying IP address in SAN in the CA certificate Deepak Jain
  • RE: Inquiry about using SSL encryption and SASL authentication for Kafka without specifying IP address in SAN in the CA certificate Deepak Jain
  • Re: Inquiry about using SSL encryption and SASL authentication for Kafka without specifying IP address in SAN in the CA certificate Richard Bosch
  • RE: Inquiry about using SSL encryption and SASL authentication for Kafka without specifying IP address in SAN in the CA certificate Deepak Jain
  • Re: Inquiry about using SSL encryption and SASL authentication for Kafka without specifying IP address in SAN in the CA certificate Richard Bosch
• Consume data-skewed partitions using Kafka-streams causes consumer load balancing issue. ankit Soni
  • Re: Consume data-skewed partitions using Kafka-streams causes consumer load balancing issue. Guozhang Wang
• NoAuth for /brokers/ids Ivanov, Evgeny
  • Re: NoAuth for /brokers/ids Luke Chen
  • RE: NoAuth for /brokers/ids Ivanov, Evgeny
• what is Best Practices of kafka mirror maker 2 #12375 Phongtat Yaemsomphong
• Facing MESSAGE_TOO_LARGE Divya Jain
  • Re: Facing MESSAGE_TOO_LARGE M. Manna
  • Re: Facing MESSAGE_TOO_LARGE Divya Jain
  • Re: Facing MESSAGE_TOO_LARGE Malcolm McFarland
  • Re: Facing MESSAGE_TOO_LARGE Divya Jain
• Kafka Log4J vulnerabilities - Urgent Kumar.Mayank2
• [FINAL CALL] - Travel Assistance to ApacheCon New Orleans 2022 Gavin McDonald
• a little problem in quickstart mason lee
  • Re: a little problem in quickstart Men Lim
  • Re: a little problem in quickstart Chris Egerton
  • Re: a little problem in quickstart Luke Chen
• apply to be a contributor (jira) Justinwins
  • Re: apply to be a contributor (jira) Bill Bejeck
• end of life Jonas Thaarup Løvig
  • Re: end of life Josep Prat
• Granting contributor permission for Jira lith_angelo
  • Re: Granting contributor permission for Jira Luke Chen
• Kafka can not delete old logs for some portion QQ
• Filtring messages abdelali elmantagui
• Help on MM2 -- only copy new data An, Hongguo (CORP)
  • Re: Help on MM2 -- only copy new data An, Hongguo (CORP)
  • Re: Help on MM2 -- only copy new data Jamie
  • Re: Help on MM2 -- only copy new data An, Hongguo (CORP)
• Kafka consumer filtering abdelali elmantagui
  • Re: Kafka consumer filtering Jamie
  • Re: Kafka consumer filtering Anders Engström
• source topic partitions not assigned evenly to kafka stream threads Pushkar Deole
  • Re: source topic partitions not assigned evenly to kafka stream threads Pushkar Deole
• Required Business Proposal For BMW Group Asia JYOTI.CHAUDHARY
  • Re: Required Business Proposal For BMW Group Asia Neeraj Vaidya
• Broker allows transactions with generation.id -1 and could lead to duplicates Gabriel Giussi
  • Re: Broker allows transactions with generation.id -1 and could lead to duplicates Luke Chen
• Mirror Maker 2.0 Josée Brodeur
• Kafka use case for my setup Jay Linux
  • Kafka use case for my setup Jay Linux
• Kafka Java clients compatibility 刘冲
• Kafka Authentication + Authorization rohit garg
• Kafka MirrorMaker2 with different version Doug Whitfield
• SASL authentication between Kafka and Zookeeper Ivanov, Evgeny
  • Re: SASL authentication between Kafka and Zookeeper fpapon
  • RE: SASL authentication between Kafka and Zookeeper Ivanov, Evgeny
  • Re: SASL authentication between Kafka and Zookeeper Francois Papon
  • RE: SASL authentication between Kafka and Zookeeper Ivanov, Evgeny
• Contributing documentation m sacks
• Kafka producer fails with expiring 2 record(s) for myTopic-1:120004 ms has passed since batch creation Kuttaiah Robin
• Query regarding kafka controller shutdown dhiraj prajapati
  • Re: Query regarding kafka controller shutdown Liam Clarke-Hutchinson
  • Re: Query regarding kafka controller shutdown dhiraj prajapati
• Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env Deepak Jain
  • RE: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env Deepak Jain
  • Re: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env 张晓寅
  • RE: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env Deepak Jain
  • Re: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env Luke Chen
  • RE: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env Deepak Jain
  • Re: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env 张晓寅
• Kafka as a service Ivanov, Evgeny
• KStreams State Store - state.dir does not have .checkpoint file Neeraj Vaidya
  • Re: KStreams State Store - state.dir does not have .checkpoint file John Roesler
  • Re: KStreams State Store - state.dir does not have .checkpoint file Neeraj Vaidya
  • Re: KStreams State Store - state.dir does not have .checkpoint file Steven Schlansker
• Re: number of request aydemir kala
• Newbie how to get key/value pojo out of a stream? Andy
  • Re: Newbie how to get key/value pojo out of a stream? Luca
  • Re: Newbie how to get key/value pojo out of a stream? andrew davidson
  • Re: Newbie how to get key/value pojo out of a stream? Luca
  • Re: Newbie how to get key/value pojo out of a stream? Matthias J. Sax
• Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available Ivanov, Evgeny
  • Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available Ivanov, Evgeny
  • Re: Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available Richard Bosch
  • RE: Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available Ivanov, Evgeny
• Reset Kafka TestContainers after each junit test without destroying container Debraj Manna
• What happens when kafka gracefully stopped sunil chaudhari
• unsubscribed from all topics when adding a KTable Meir Goldenberg
  • Re: unsubscribed from all topics when adding a KTable Guozhang Wang
• How it is safe to break message ordering but not idempotency after getting an OutOfOrderSequenceException? Gabriel Giussi
  • Re: How it is safe to break message ordering but not idempotency after getting an OutOfOrderSequenceException? Matthias J. Sax
  • Re: How it is safe to break message ordering but not idempotency after getting an OutOfOrderSequenceException? Gabriel Giussi
  • Re: How it is safe to break message ordering but not idempotency after getting an OutOfOrderSequenceException? Matthias J. Sax
• Can CooperativeStickyAssignor be used with transactions? Gabriel Giussi
• why includeMetadataInTimeout could be set only in deprecated api Xiangyuan LI
• Kafka in gmp validation environment (pharmaceuticals) Alexis Papadopoulos
• [ANNOUNCE] Call for Speakers is open for Current 2022: The Next Generation of Kafka Summit Robin Moffatt
• Request to include me to contributors list Kumud Kumar Srivatsava Tirupati
  • Re: Request to include me to contributors list Guozhang Wang
  • Request to include me to contributors list Kumud Kumar Srivatsava Tirupati
  • Re: Request to include me to contributors list Luke Chen
• What role plays transactional.id after KIP-447? Gabriel Giussi
  • Re: What role plays transactional.id after KIP-447? Guozhang Wang
  • Re: What role plays transactional.id after KIP-447? Gabriel Giussi
  • Re: What role plays transactional.id after KIP-447? Guozhang Wang
  • Re: What role plays transactional.id after KIP-447? Gabriel Giussi
  • Re: What role plays transactional.id after KIP-447? Guozhang Wang
  • Re: What role plays transactional.id after KIP-447? Gabriel Giussi
  • Re: What role plays transactional.id after KIP-447? Guozhang Wang
  • Re: What role plays transactional.id after KIP-447? Gabriel Giussi

• Earlier messages
• Later messages