Messages by Date
-
2022/06/06
Kafka MirrorMaker2 with different version
Doug Whitfield
-
2022/06/06
RE: SASL authentication between Kafka and Zookeeper
Ivanov, Evgeny
-
2022/06/06
Re: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env
张晓寅
-
2022/06/06
Re: SASL authentication between Kafka and Zookeeper
Francois Papon
-
2022/06/06
RE: Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env
Deepak Jain
-
2022/06/06
RE: SASL authentication between Kafka and Zookeeper
Ivanov, Evgeny
-
2022/06/06
Re: SASL authentication between Kafka and Zookeeper
fpapon
-
2022/06/06
SASL authentication between Kafka and Zookeeper
Ivanov, Evgeny
-
2022/06/05
Re: Query regarding kafka controller shutdown
Liam Clarke-Hutchinson
-
2022/06/04
Contributing documentation
m sacks
-
2022/06/03
Kafka producer fails with expiring 2 record(s) for myTopic-1:120004 ms has passed since batch creation
Kuttaiah Robin
-
2022/06/03
Query regarding kafka controller shutdown
dhiraj prajapati
-
2022/06/02
Re: What role plays transactional.id after KIP-447?
Guozhang Wang
-
2022/06/02
Random continuous TimeoutException with Topic not present on one KafkaProducer out of many in multithreaded env
Deepak Jain
-
2022/06/02
Re: What role plays transactional.id after KIP-447?
Gabriel Giussi
-
2022/06/01
Re: KStreams State Store - state.dir does not have .checkpoint file
Steven Schlansker
-
2022/06/01
Kafka as a service
Ivanov, Evgeny
-
2022/06/01
Re: KStreams State Store - state.dir does not have .checkpoint file
Neeraj Vaidya
-
2022/05/31
Re: KStreams State Store - state.dir does not have .checkpoint file
John Roesler
-
2022/05/31
KStreams State Store - state.dir does not have .checkpoint file
Neeraj Vaidya
-
2022/05/31
Re: Newbie how to get key/value pojo out of a stream?
Luca
-
2022/05/31
Re: number of request
aydemir kala
-
2022/05/31
Re: What role plays transactional.id after KIP-447?
Guozhang Wang
-
2022/05/31
Re: What role plays transactional.id after KIP-447?
Gabriel Giussi
-
2022/05/31
Re: Newbie how to get key/value pojo out of a stream?
andrew davidson
-
2022/05/31
RE: Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available
Ivanov, Evgeny
-
2022/05/31
Re: Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available
Richard Bosch
-
2022/05/30
Re: Newbie how to get key/value pojo out of a stream?
Luca
-
2022/05/30
Newbie how to get key/value pojo out of a stream?
Andy
-
2022/05/30
Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available
Ivanov, Evgeny
-
2022/05/30
Connection to node 432 (localhost/127.0.0.1:9094) could not be established. Broker may not be available
Ivanov, Evgeny
-
2022/05/28
Reset Kafka TestContainers after each junit test without destroying container
Debraj Manna
-
2022/05/27
What happens when kafka gracefully stopped
sunil chaudhari
-
2022/05/27
unsubscribed from all topics when adding a KTable
Meir Goldenberg
-
2022/05/27
How it is safe to break message ordering but not idempotency after getting an OutOfOrderSequenceException?
Gabriel Giussi
-
2022/05/26
Can CooperativeStickyAssignor be used with transactions?
Gabriel Giussi
-
2022/05/26
why includeMetadataInTimeout could be set only in deprecated api
Xiangyuan LI
-
2022/05/25
Kafka in gmp validation environment (pharmaceuticals)
Alexis Papadopoulos
-
2022/05/24
Re: What role plays transactional.id after KIP-447?
Guozhang Wang
-
2022/05/24
Re: What role plays transactional.id after KIP-447?
Gabriel Giussi
-
2022/05/24
[ANNOUNCE] Call for Speakers is open for Current 2022: The Next Generation of Kafka Summit
Robin Moffatt
-
2022/05/24
Re: What role plays transactional.id after KIP-447?
Guozhang Wang
-
2022/05/24
Re: What role plays transactional.id after KIP-447?
Gabriel Giussi
-
2022/05/23
Re: Connect task configuration limits?
Ryan Slominski
-
2022/05/23
Re: Request to include me to contributors list
Guozhang Wang
-
2022/05/22
Re: Request to include me to contributors list
Luke Chen
-
2022/05/22
Request to include me to contributors list
Kumud Kumar Srivatsava Tirupati
-
2022/05/22
Request to include me to contributors list
Kumud Kumar Srivatsava Tirupati
-
2022/05/21
Re: What role plays transactional.id after KIP-447?
Guozhang Wang
-
2022/05/21
Re: Connect task configuration limits?
Urbán Dániel
-
2022/05/20
Re: kafka stream - sliding window - getting unexpected output
Matthias J. Sax
-
2022/05/20
What role plays transactional.id after KIP-447?
Gabriel Giussi
-
2022/05/20
Re: [ANNOUNCE] Apache Kafka 3.2.0
Bruno Cadonna
-
2022/05/19
Re: [ANNOUNCE] Apache Kafka 3.2.0
James Cheng
-
2022/05/19
Connect task configuration limits?
Ryan Slominski
-
2022/05/19
Re: Leverage multiple disks for kafka streams stores
Bruno Cadonna
-
2022/05/19
Re: Leverage multiple disks for kafka streams stores
Adrian Tubio
-
2022/05/19
Re: Leverage multiple disks for kafka streams stores
Bruno Cadonna
-
2022/05/19
Final reminder: ApacheCon North America call for presentations closing soon
Rich Bowen
-
2022/05/19
Leverage multiple disks for kafka streams stores
Adrian Tubio
-
2022/05/18
Re: kafka stream - sliding window - getting unexpected output
Shankar Mane
-
2022/05/18
Re: docs fixes
Guozhang Wang
-
2022/05/18
Re: kafka stream - sliding window - getting unexpected output
Matthias J. Sax
-
2022/05/18
Re: What does Apache Kafka do?
sunil chaudhari
-
2022/05/18
What does Apache Kafka do?
Turritopsis Dohrnii Teo En Ming
-
2022/05/18
docs fixes
Владимир Савостин
-
2022/05/17
Re: [ANNOUNCE] Apache Kafka 3.2.0
Bill Bejeck
-
2022/05/17
[ANNOUNCE] Apache Kafka 3.2.0
Bruno Cadonna
-
2022/05/17
kafka stream - sliding window - getting unexpected output
Shankar Mane
-
2022/05/17
AW: Switchin from Zookepper to Kafka KRaft mode / Using ACLs with Kafka KRaft mode
Florian Blumenstein
-
2022/05/16
Re: Switchin from Zookepper to Kafka KRaft mode / Using ACLs with Kafka KRaft mode
Thomas Cooper
-
2022/05/16
Re: Failed to fetch offset for partition ...: There are unstable offsets that need to be cleared
Domantas Petrauskas
-
2022/05/16
Switchin from Zookepper to Kafka KRaft mode / Using ACLs with Kafka KRaft mode
Florian Blumenstein
-
2022/05/14
Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1
Federico Valeri
-
2022/05/13
Re: Failed to fetch offset for partition ...: There are unstable offsets that need to be cleared
Domantas Petrauskas
-
2022/05/13
Failed to fetch offset for partition ...: There are unstable offsets that need to be cleared
Domantas Petrauskas
-
2022/05/13
Failed to fetch offset for partition; There are unstable offsets that need to be cleared
Domantas Petrauskas
-
2022/05/13
Kafka Connect - REST API security
Vignesh
-
2022/05/13
[ANNOUNCE] Apache Kafka 3.1.1
Tom Bentley
-
2022/05/12
Question about MM2's source-cluster.checkpoints.internal topic
Aki Yoshida
-
2022/05/12
Re: Kafka Stretch Clusters
Guozhang Wang
-
2022/05/12
Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1
Bruno Cadonna
-
2022/05/11
Re: Kafka Stretch Clusters
Andrew Otto
-
2022/05/11
Re: Increased latency when consuming from the closest ISR
benitocm
-
2022/05/11
Re: Increased latency when consuming from the closest ISR
Luke Chen
-
2022/05/10
Increased latency when consuming from the closest ISR
benitocm
-
2022/05/10
Re: Topic without Leader / ISR
Nicolas Carlot
-
2022/05/10
Re: Topic without Leader / ISR
Luke Chen
-
2022/05/10
Re: Topic without Leader / ISR
Nicolas Carlot
-
2022/05/09
Re: Topic without Leader / ISR
Luke Chen
-
2022/05/09
Re: Kafka Stretch Clusters
Guozhang Wang
-
2022/05/09
Kafka Stretch Clusters
Andrew Otto
-
2022/05/09
[RESULTS] [VOTE] Release Kafka version 3.2.0
Bruno Cadonna
-
2022/05/09
Topic without Leader / ISR
Nicolas Carlot
-
2022/05/06
Re: [VOTE] 3.2.0 RC1
David Jacot
-
2022/05/05
Re: Add to Kafka contributor list
Guozhang Wang
-
2022/05/05
Add to Kafka contributor list
Chern Yih Cheah
-
2022/05/05
Re: [VOTE] 3.2.0 RC1
Jakub Scholz
-
2022/05/04
Re: [VOTE] 3.1.1 RC1
Luke Chen
-
2022/05/04
Re: [VOTE] 3.2.0 RC1
Luke Chen
-
2022/05/04
Re: [VOTE] 3.2.0 RC1
Mickael Maison
-
2022/05/04
Re: [VOTE] 3.1.1 RC1
Bill Bejeck
-
2022/05/04
Re: [VOTE] 3.2.0 RC1
Bruno Cadonna
-
2022/05/03
Re: Unexpected loss of Offsets
Luke Chen
-
2022/05/03
Re: [VOTE] 3.2.0 RC1
Bill Bejeck
-
2022/05/03
Re: [VOTE] 3.1.1 RC1
Jakub Scholz
-
2022/05/03
[VOTE] 3.2.0 RC1
Bruno Cadonna
-
2022/05/03
Re: Kafka Question
Robin Moffatt
-
2022/05/03
REMINDER - Travel Assistance available for ApacheCon NA New Orleans 2022
Gavin McDonald
-
2022/05/02
Re: Event Grouping
Liam Clarke-Hutchinson
-
2022/05/02
Re: Event Grouping
Dave Greeko
-
2022/05/02
Re: Event Grouping
Liam Clarke-Hutchinson
-
2022/05/02
Re: Kafka Question
Liam Clarke-Hutchinson
-
2022/05/02
Re: kafka and Kube,
Liam Clarke-Hutchinson
-
2022/05/02
Event Grouping
Dave Greeko
-
2022/05/02
kafka and Kube,
David Ballano Fernandez
-
2022/05/02
Kafka Question
Emily Schepisi
-
2022/05/02
Idempotent producer vs. JVM heap usage
Oleksandr Shulgin
-
2022/05/02
Re: Unexpected loss of Offsets
Divij Vaidya
-
2022/04/29
Re: [VOTE] 3.1.1 RC1
Mickael Maison
-
2022/04/29
[VOTE] 3.1.1 RC1
Tom Bentley
-
2022/04/28
Re: Unexpected loss of Offsets
James Olsen
-
2022/04/28
Re: Unexpected loss of Offsets
Luke Chen
-
2022/04/28
Re: Unexpected loss of Offsets
James Olsen
-
2022/04/28
RE: How to deal with the Error: KAFKA_STORAGE_ERROR
Dong, Peter A. (NSB - CN/Qingdao)
-
2022/04/28
Re: How to deal with the Error: KAFKA_STORAGE_ERROR
Liam Clarke-Hutchinson
-
2022/04/28
Re: Unexpected Rebalances ,Any tips on APIs or debug techniques to figure out rebalance causes?
sunil chaudhari
-
2022/04/27
How to deal with the Error: KAFKA_STORAGE_ERROR
Dong, Peter A. (NSB - CN/Qingdao)
-
2022/04/27
Re: Unexpected Rebalances ,Any tips on APIs or debug techniques to figure out rebalance causes?
Luke Chen
-
2022/04/27
kafka 2.7 to 2.8 upgrade
David Ballano Fernandez
-
2022/04/27
Unexpected Rebalances ,Any tips on APIs or debug techniques to figure out rebalance causes?
杨宝栓
-
2022/04/26
Re: Requesting Pricing for Kafka Support
Liam Clarke-Hutchinson
-
2022/04/26
Re: [kafka-clients] Re: [VOTE] 3.2.0 RC0
Jun Rao
-
2022/04/26
Re: [kafka-clients] Re: [VOTE] 3.2.0 RC0
Bruno Cadonna
-
2022/04/26
Re: [VOTE] 3.2.0 RC0
Jun Rao
-
2022/04/26
Requesting Pricing for Kafka Support
Lavanya Voruganti
-
2022/04/26
Re: [VOTE] 3.2.0 RC0
Bruno Cadonna
-
2022/04/25
Re: Partnership: Apache Kafka & SantoDigital
Bruno Cadonna
-
2022/04/25
Partnership: Apache Kafka & SantoDigital
Amanda Jampaulo
-
2022/04/23
org.apache.kafka.common.errors.InvalidProducerEpochException: Producer attempted to produce with an old epoch
Neeraj Vaidya
-
2022/04/21
Re: Move all partitions from one log.dir to another
Fares Oueslati
-
2022/04/21
Re: [VOTE] 3.2.0 RC0
Michal Tóth
-
2022/04/19
Re: Thank you!
Liam Clarke-Hutchinson
-
2022/04/18
Thank you!
Matt Gilbert
-
2022/04/15
Re: Subscribing to users@kafka.apache.org
John Roesler
-
2022/04/15
Re: MirrorMaker 2 not replicating topic ACLs correctly
Ryanne Dolan
-
2022/04/15
MirrorMaker 2 not replicating topic ACLs correctly
Alex Zuroff
-
2022/04/15
[VOTE] 3.2.0 RC0
Bruno Cadonna
-
2022/04/15
Subscribing to users@kafka.apache.org
Lorcan Cooke
-
2022/04/13
Re: [VOTE] 3.1.1 RC0
Ismael Juma
-
2022/04/13
RE: Re: Migrating from 2.5.0 to 2.8.0
Vakati, Vinay kumar
-
2022/04/13
Re: Move all partitions from one log.dir to another
Luke Chen
-
2022/04/13
Re: Migrating from 2.5.0 to 2.8.0
vinay kumar
-
2022/04/13
Re: Move all partitions from one log.dir to another
Fares Oueslati
-
2022/04/12
Re: Move all partitions from one log.dir to another
Fares Oueslati
-
2022/04/12
Re: Move all partitions from one log.dir to another
Luke Chen
-
2022/04/12
Re: [VOTE] 3.1.1 RC0
Luke Chen
-
2022/04/12
Re: [VOTE] 3.1.1 RC0
David Jacot
-
2022/04/12
Re: Move all partitions from one log.dir to another
Fares Oueslati
-
2022/04/12
Re: [VOTE] 3.1.1 RC0
Guozhang Wang
-
2022/04/11
Re: RuntimeMBeanException: getMBeanInfo threw RuntimeException caused by ConcurrentModificationException
Peter Schrott (Extern)
-
2022/04/10
Re: Migrating from 2.5.0 to 2.8.0
Luke Chen
-
2022/04/10
Migrating from 2.5.0 to 2.8.0
vinay kumar
-
2022/04/10
Re: KRaft - Release Date
Luke Chen
-
2022/04/10
Re: Unexpected loss of Offsets
Luke Chen
-
2022/04/10
Unexpected loss of Offsets
James Olsen
-
2022/04/08
[VOTE] 3.1.1 RC0
Tom Bentley
-
2022/04/08
KRaft - Release Date
Glaess, Michael
-
2022/04/06
Re: Move all partitions from one log.dir to another
Luke Chen
-
2022/04/06
Re: Java 8 support in Kafka 3.1.1 release
Luke Chen
-
2022/04/06
Java 8 support in Kafka 3.1.1 release
Deepak Jain
-
2022/04/06
Move all partitions from one log.dir to another
Fares Oueslati
-
2022/04/06
Fwd: RuntimeMBeanException: getMBeanInfo threw RuntimeException caused by ConcurrentModificationException
Liam Clarke-Hutchinson
-
2022/04/06
RuntimeMBeanException: getMBeanInfo threw RuntimeException caused by ConcurrentModificationException
Peter Schrott (Extern)
-
2022/04/05
Re: kafka producer exception due to TimeoutException: Expiring records for topic 120000ms has passed since batch creation
Haruki Okada
-
2022/04/04
Re: kafka producer exception due to TimeoutException: Expiring records for topic 120000ms has passed since batch creation
Pushkar Deole
-
2022/04/04
Re: Request was for a topic or partition that does not exist on this broker error when using Kafka in Kraft mode
Francis Chuang
-
2022/04/04
Re: Request was for a topic or partition that does not exist on this broker error when using Kafka in Kraft mode
Francis Chuang
-
2022/04/04
Re: Request was for a topic or partition that does not exist on this broker error when using Kafka in Kraft mode
Liam Clarke-Hutchinson
-
2022/04/04
Re: Request was for a topic or partition that does not exist on this broker error when using Kafka in Kraft mode
Francis Chuang
-
2022/04/04
Re: kafka producer exception due to TimeoutException: Expiring records for topic 120000ms has passed since batch creation
Liam Clarke-Hutchinson
-
2022/04/04
Re: Kafka Producer Record Error Rate
Liam Clarke-Hutchinson
-
2022/04/04
Re: Kafka Producer Record Error Rate
Neeraj Vaidya
-
2022/04/04
Re: Kafka Producer Record Error Rate
Liam Clarke-Hutchinson
-
2022/04/04
kafka producer exception due to TimeoutException: Expiring records for topic 120000ms has passed since batch creation
Pushkar Deole
-
2022/04/04
Re: HACKING vulnerability is SpringBoot (Java) for apache kafka
Kafka Life
-
2022/04/04
Re: HACKING vulnerability is SpringBoot (Java) for apache kafka
Luke Chen
-
2022/04/04
HACKING vulnerability is SpringBoot (Java) for apache kafka
Kafka Life
-
2022/04/04
Re: Kafka Producer Record Error Rate
Neeraj Vaidya
-
2022/04/03
Upgrading kafka from 2.5 to 2.8
vinay kumar
-
2022/04/03
Re: Kafka Producer Record Error Rate
David Finnie
-
2022/04/03
Re: Kafka Producer Record Error Rate
David Finnie
-
2022/04/03
Re: Kafka Producer Record Error Rate
Liam Clarke-Hutchinson
-
2022/04/03
Re: Kafka Producer Record Error Rate
Neeraj Vaidya
-
2022/04/03
Re: Kafka Producer Record Error Rate
Liam Clarke-Hutchinson
-
2022/04/03
Re: Kafka Producer Record Error Rate
Neeraj Vaidya
-
2022/04/03
Re: Kafka Producer Record Error Rate
Liam Clarke-Hutchinson
-
2022/04/03
Kafka Producer Record Error Rate
Neeraj Vaidya
-
2022/04/02
Request was for a topic or partition that does not exist on this broker error when using Kafka in Kraft mode
Francis Chuang
-
2022/04/01
Re: [Question] What is the best practice in consuming multiple topics?
Xiong, Pin