users  

Messages by Thread

• [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
  • Re: What role plays transactional.id after KIP-447? Guozhang Wang
• Connect task configuration limits? Ryan Slominski
  • Re: Connect task configuration limits? Urbán Dániel
  • Re: Connect task configuration limits? Ryan Slominski
• Final reminder: ApacheCon North America call for presentations closing soon Rich Bowen
• Leverage multiple disks for kafka streams stores Adrian Tubio
  • Re: Leverage multiple disks for kafka streams stores Bruno Cadonna
  • Re: Leverage multiple disks for kafka streams stores Adrian Tubio
  • Re: Leverage multiple disks for kafka streams stores Bruno Cadonna
• What does Apache Kafka do? Turritopsis Dohrnii Teo En Ming
  • Re: What does Apache Kafka do? sunil chaudhari
• docs fixes Владимир Савостин
  • Re: docs fixes Guozhang Wang
• [ANNOUNCE] Apache Kafka 3.2.0 Bruno Cadonna
  • Re: [ANNOUNCE] Apache Kafka 3.2.0 Bill Bejeck
  • Re: [ANNOUNCE] Apache Kafka 3.2.0 James Cheng
  • Re: [ANNOUNCE] Apache Kafka 3.2.0 Bruno Cadonna
• kafka stream - sliding window - getting unexpected output Shankar Mane
  • Re: kafka stream - sliding window - getting unexpected output Matthias J. Sax
  • Re: kafka stream - sliding window - getting unexpected output Shankar Mane
  • Re: kafka stream - sliding window - getting unexpected output Matthias J. Sax
• Switchin from Zookepper to Kafka KRaft mode / Using ACLs with Kafka KRaft mode Florian Blumenstein
  • Re: Switchin from Zookepper to Kafka KRaft mode / Using ACLs with Kafka KRaft mode Thomas Cooper
  • AW: Switchin from Zookepper to Kafka KRaft mode / Using ACLs with Kafka KRaft mode Florian Blumenstein
• Failed to fetch offset for partition ...: There are unstable offsets that need to be cleared Domantas Petrauskas
  • Re: Failed to fetch offset for partition ...: There are unstable offsets that need to be cleared Domantas Petrauskas
  • Re: Failed to fetch offset for partition ...: There are unstable offsets that need to be cleared Domantas Petrauskas
• Failed to fetch offset for partition; There are unstable offsets that need to be cleared Domantas Petrauskas
• Kafka Connect - REST API security Vignesh
• [ANNOUNCE] Apache Kafka 3.1.1 Tom Bentley
• Question about MM2's source-cluster.checkpoints.internal topic Aki Yoshida
• Increased latency when consuming from the closest ISR benitocm
  • Re: Increased latency when consuming from the closest ISR Luke Chen
  • Re: Increased latency when consuming from the closest ISR benitocm
• Kafka Stretch Clusters Andrew Otto
  • Re: Kafka Stretch Clusters Guozhang Wang
  • Re: Kafka Stretch Clusters Andrew Otto
  • Re: Kafka Stretch Clusters Guozhang Wang
• [RESULTS] [VOTE] Release Kafka version 3.2.0 Bruno Cadonna
• Topic without Leader / ISR Nicolas Carlot
  • Re: Topic without Leader / ISR Luke Chen
  • Re: Topic without Leader / ISR Nicolas Carlot
  • Re: Topic without Leader / ISR Luke Chen
  • Re: Topic without Leader / ISR Nicolas Carlot
• Add to Kafka contributor list Chern Yih Cheah
  • Re: Add to Kafka contributor list Guozhang Wang
  • Add to kafka contributor list vinay kumar
  • Re: Add to kafka contributor list Bill Bejeck
  • Re: Add to kafka contributor list vinay kumar
  • Re: Add to kafka contributor list Luke Chen
  • Add to Kafka contributor list vinay kumar
  • Re: Add to Kafka contributor list Guozhang Wang
• [VOTE] 3.2.0 RC1 Bruno Cadonna
  • Re: [VOTE] 3.2.0 RC1 Bill Bejeck
  • Re: [VOTE] 3.2.0 RC1 Bruno Cadonna
  • Re: [VOTE] 3.2.0 RC1 Mickael Maison
  • Re: [VOTE] 3.2.0 RC1 Luke Chen
  • Re: [VOTE] 3.2.0 RC1 Jakub Scholz
  • Re: [VOTE] 3.2.0 RC1 David Jacot
  • Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1 Bruno Cadonna
  • Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1 Federico Valeri
• REMINDER - Travel Assistance available for ApacheCon NA New Orleans 2022 Gavin McDonald
• Event Grouping Dave Greeko
  • Re: Event Grouping Liam Clarke-Hutchinson
  • Re: Event Grouping Dave Greeko
  • Re: Event Grouping Liam Clarke-Hutchinson
• kafka and Kube, David Ballano Fernandez
  • Re: kafka and Kube, Liam Clarke-Hutchinson
• Kafka Question Emily Schepisi
  • Re: Kafka Question Liam Clarke-Hutchinson
  • Re: Kafka Question Robin Moffatt
  • kafka question 王 留成
• Idempotent producer vs. JVM heap usage Oleksandr Shulgin
• [VOTE] 3.1.1 RC1 Tom Bentley
  • Re: [VOTE] 3.1.1 RC1 Mickael Maison
  • Re: [VOTE] 3.1.1 RC1 Jakub Scholz
  • Re: [VOTE] 3.1.1 RC1 Bill Bejeck
  • Re: [VOTE] 3.1.1 RC1 Luke Chen
• How to deal with the Error: KAFKA_STORAGE_ERROR Dong, Peter A. (NSB - CN/Qingdao)
  • Re: How to deal with the Error: KAFKA_STORAGE_ERROR Liam Clarke-Hutchinson
  • RE: How to deal with the Error: KAFKA_STORAGE_ERROR Dong, Peter A. (NSB - CN/Qingdao)
• kafka 2.7 to 2.8 upgrade David Ballano Fernandez
• Unexpected Rebalances ，Any tips on APIs or debug techniques to figure out rebalance causes? 杨宝栓
  • Re: Unexpected Rebalances ，Any tips on APIs or debug techniques to figure out rebalance causes? Luke Chen
  • Re: Unexpected Rebalances ，Any tips on APIs or debug techniques to figure out rebalance causes? sunil chaudhari
• Requesting Pricing for Kafka Support Lavanya Voruganti
  • Re: Requesting Pricing for Kafka Support Liam Clarke-Hutchinson
• Partnership: Apache Kafka & SantoDigital Amanda Jampaulo
  • Re: Partnership: Apache Kafka & SantoDigital Bruno Cadonna
• org.apache.kafka.common.errors.InvalidProducerEpochException: Producer attempted to produce with an old epoch Neeraj Vaidya
• Thank you! Matt Gilbert
  • Re: Thank you! Liam Clarke-Hutchinson
• MirrorMaker 2 not replicating topic ACLs correctly Alex Zuroff
  • Re: MirrorMaker 2 not replicating topic ACLs correctly Ryanne Dolan
• [VOTE] 3.2.0 RC0 Bruno Cadonna
  • Re: [VOTE] 3.2.0 RC0 Michal Tóth
  • Re: [VOTE] 3.2.0 RC0 Bruno Cadonna
  • Re: [VOTE] 3.2.0 RC0 Jun Rao
  • Re: [kafka-clients] Re: [VOTE] 3.2.0 RC0 Bruno Cadonna
  • Re: [kafka-clients] Re: [VOTE] 3.2.0 RC0 Jun Rao
• Migrating from 2.5.0 to 2.8.0 vinay kumar
  • Re: Migrating from 2.5.0 to 2.8.0 Luke Chen
  • Re: Migrating from 2.5.0 to 2.8.0 vinay kumar
  • RE: Re: Migrating from 2.5.0 to 2.8.0 Vakati, Vinay kumar
• Unexpected loss of Offsets James Olsen
  • Re: Unexpected loss of Offsets Luke Chen
  • Re: Unexpected loss of Offsets James Olsen
  • Re: Unexpected loss of Offsets Luke Chen
  • Re: Unexpected loss of Offsets James Olsen
  • Re: Unexpected loss of Offsets Divij Vaidya
  • Re: Unexpected loss of Offsets Luke Chen

• Earlier messages
• Later messages