users  

Messages by Thread

• Access kafka service through http(s) tunnel 乔咏
  • 回复: Access kafka service through http(s) tunnel 乔咏
• Community over Code EU 2024 Travel Assistance Applications now open! Gavin McDonald
• question: mirror maker 2 M. Lim
• v3.5.1 KRAFT mode: Cluster every day exact same time unavailable for ~30sec -> no controller available Denny Fuchs
• Re-key by multiple properties without composite key Karsten Stöckmann
  • Re: Re-key by multiple properties without composite key Matthias J. Sax
  • Re: Re-key by multiple properties without composite key Karsten Stöckmann
  • Re: Re-key by multiple properties without composite key Matthias J. Sax
  • Re: Re-key by multiple properties without composite key Karsten Stöckmann
  • Re: Re-key by multiple properties without composite key Matthias J. Sax
  • Re: Re-key by multiple properties without composite key Karsten Stöckmann
  • Re: Re-key by multiple properties without composite key Matthias J. Sax
  • Re: Re-key by multiple properties without composite key Karsten Stöckmann
• v3.5.1 | KRAFT | broker.rack=0 Denny Fuchs
• Kafka Streams LEFT JOIN multiple tables Karsten Stöckmann
  • Re: Kafka Streams LEFT JOIN multiple tables Dharin Shah
  • Re: Kafka Streams LEFT JOIN multiple tables Karsten Stöckmann
  • Re: Kafka Streams LEFT JOIN multiple tables Slathia p
  • Re: Kafka Streams LEFT JOIN multiple tables Slathia p
• What does kafka streams groupBy does internally? warrior2031
  • Re: What does kafka streams groupBy does internally? Matthias J. Sax
• Script to delete list of topics sunil chaudhari
  • Re: Script to delete list of topics Kamal Chandraprakash
• kafka cluster question Yavuz Sert
  • Re: kafka cluster question Haruki Okada
  • Re: kafka cluster question Yavuz Sert
  • Re: kafka cluster question Artem Timchenko
  • Re: kafka cluster question Yavuz Sert
• Mirror Maker 2 | 2.7.1 | Some partitions are not synched since target cluster patching Akshaya Rawat
• [Kafka Streams], Processor API for KTable and KGroupedStream Igor Maznitsa
  • Re: [Kafka Streams], Processor API for KTable and KGroupedStream Matthias J. Sax
  • Re: [Kafka Streams], Processor API for KTable and KGroupedStream Igor Maznitsa
  • Re: [Kafka Streams], Processor API for KTable and KGroupedStream Matthias J. Sax
• [VOTE] 3.7.0 RC2 Stanislav Kozlovski
  • Re: [VOTE] 3.7.0 RC2 Stanislav Kozlovski
  • Re: [VOTE] 3.7.0 RC2 Stanislav Kozlovski
  • Re: [VOTE] 3.7.0 RC2 kafka
  • Re: [VOTE] 3.7.0 RC2 kafka
  • Re: [VOTE] 3.7.0 RC2 kafka
  • Re: [VOTE] 3.7.0 RC2 Omnia Ibrahim
  • Re: [VOTE] 3.7.0 RC2 Stanislav Kozlovski
• KAfka and syslog Francisco Serrano
  • Re: KAfka and syslog Pasi Hiltunen
• During cluster peak, KAFKA NetworkProcessorAvgIdlePercent is lower than 0.2 dong yu
  • During cluster peak, KAFKA NetworkProcessorAvgIdlePercent is lower than 0.2 dong yu
  • Re: During cluster peak, KAFKA NetworkProcessorAvgIdlePercent is lower than 0.2 Haruki Okada
  • Re: During cluster peak, KAFKA NetworkProcessorAvgIdlePercent is lower than 0.2 dong yu
  • Re: During cluster peak, KAFKA NetworkProcessorAvgIdlePercent is lower than 0.2 Haruki Okada
• mTLS authentication for inter broker communication Krishna Sai Veera Reddy
• [PROPOSAL] Add commercial support page on website fpapon
  • Re: [PROPOSAL] Add commercial support page on website Divij Vaidya
  • Re: [PROPOSAL] Add commercial support page on website fpapon
  • Re: [PROPOSAL] Add commercial support page on website Kenneth Eversole
  • Re: [PROPOSAL] Add commercial support page on website fpapon
  • Re: [PROPOSAL] Add commercial support page on website fpapon
  • Re: [PROPOSAL] Add commercial support page on website Chris Egerton
  • Re: [PROPOSAL] Add commercial support page on website fpapon
  • Re: [PROPOSAL] Add commercial support page on website Francois Papon
  • Re: [PROPOSAL] Add commercial support page on website Matthias J. Sax
  • Re: [PROPOSAL] Add commercial support page on website tison
  • Re: [PROPOSAL] Add commercial support page on website Francois Papon
  • Re: [PROPOSAL] Add commercial support page on website Viktor Somogyi-Vass
  • Re: [PROPOSAL] Add commercial support page on website Romain Manni-Bucau
  • Re: [PROPOSAL] Add commercial support page on website Viktor Somogyi-Vass
  • Re: [PROPOSAL] Add commercial support page on website Francois Papon
• Comparison between jbod vs single large disk for kafka broker Jigar Shah
• MM2 Question Vinay Bagare
  • Re: MM2 Question Greg Harris
  • Re: MM2 Question Vinay Bagare
• Mirror Maker bidirectional offset sync Jeroen Schutrup
  • Re: Mirror Maker bidirectional offset sync Greg Harris
  • Re: Mirror Maker bidirectional offset sync Ryanne Dolan
  • Re: Mirror Maker bidirectional offset sync Jeroen Schutrup
  • Re: Mirror Maker bidirectional offset sync Greg Harris
  • Re: Mirror Maker bidirectional offset sync Ryanne Dolan
  • Re: Mirror Maker bidirectional offset sync Greg Harris
  • Re: Mirror Maker bidirectional offset sync Jeroen Schutrup
  • Re: Mirror Maker bidirectional offset sync Greg Harris
  • Re: Mirror Maker bidirectional offset sync Ryanne Dolan
  • Re: Mirror Maker bidirectional offset sync Jeroen Schutrup
  • Re: Mirror Maker bidirectional offset sync Greg Harris
  • Re: Mirror Maker bidirectional offset sync Greg Harris
• Kafka architecture Winstein Martins
  • Re: Kafka architecture Andrew Grant
  • Re: Kafka architecture sunil chaudhari
• Kafka client metrics expiration is disabled Олексій Ігначук
• Using MirrorMaker2 | How to conclude that clusters are in sync? Akshaya Rawat
• where to capture a failed task's exception Akash Dhiman
  • Re: where to capture a failed task's exception Greg Harris
• Is the KafkaStreams#store() method thread-safe? Kohei Nozaki
  • Re: Is the KafkaStreams#store() method thread-safe? Sophie Blee-Goldman
  • Re: Is the KafkaStreams#store() method thread-safe? Kohei Nozaki
  • Re: Is the KafkaStreams#store() method thread-safe? Martin Gainty
  • Re: Is the KafkaStreams#store() method thread-safe? Sophie Blee-Goldman
• Strange error in Kafka server logs Kostroun Petr
• Question about using public classes from the internal packages John Brackin
  • Re: Question about using public classes from the internal packages Bruno Cadonna
  • Re: Question about using public classes from the internal packages Vikram Singh
  • Re: Question about using public classes from the internal packages Vikram Singh
• KAFKA-4090 sreekanth guru
• [DISCUSS] Kafka Connect source task interruption semantics Chris Egerton
• [DISCUSS] KIP-1010: Topic Partition Quota Afshin Moazami
  • Re: [DISCUSS] KIP-1010: Topic Partition Quota Afshin Moazami
  • Re: [DISCUSS] KIP-1010: Topic Partition Quota Viktor Somogyi-Vass
• Extend DefaultReplicationPolicy for MirrorSourceConnector / MirrorMaker astronaut37
• [ANNOUNCE] Apache Kafka 3.5.2 Luke Chen
  • Re: [ANNOUNCE] Apache Kafka 3.5.2 Josep Prat
  • Re: [ANNOUNCE] Apache Kafka 3.5.2 Mickael Maison
  • Re: [ANNOUNCE] Apache Kafka 3.5.2 Dima Brodsky
• FW: Issue with "connections.max.idle.ms" property defined for admin client config in apache kafka version 3.3.1 Ankit Nigam
  • Issue with "connections.max.idle.ms" property defined for admin client config in apache kafka version 3.3.1 Ankit Nigam
• Re: Security Vulnerabilities found in Kafka 3.5.1 Jakub Scholz
• Kafka frequent disconnection issue Ankit Nigam
  • Re: Kafka frequent disconnection issue Luke Chen
  • Re: Kafka frequent disconnection issue Vikram Singh
• MirrorMaker2 and source value deserialization Franck (Handfreezer - Ether)
• [ANNOUNCE] Apache Kafka 3.6.1 Mickael Maison
  • Re: [ANNOUNCE] Apache Kafka 3.6.1 Luke Chen
• In Kafka KRaft can controllers participate as bootstrap servers Dima Brodsky
  • Can a controller in a kafka kraft cluster be a bootstrap server Dima Brodsky
  • Re: Can a controller in a kafka kraft cluster be a bootstrap server Luke Chen
  • Re: Can a controller in a kafka kraft cluster be a bootstrap server Vikram Singh
  • Re: Can a controller in a kafka kraft cluster be a bootstrap server Luke Chen
  • Re: Can a controller in a kafka kraft cluster be a bootstrap server Vikram Singh
  • Re: Can a controller in a kafka kraft cluster be a bootstrap server Vikram Singh
  • Re: In Kafka KRaft can controllers participate as bootstrap servers David Arthur
  • Re: In Kafka KRaft can controllers participate as bootstrap servers Vikram Singh
• Streams configurations to optimize keeping standby tasks within acceptable recovery lag Sabit Nepal
• How do you know you are at the end of the partition? Jesus Cea
• Do we have any mechanism to control requests per second for a Kafka connect sink? Yeikel Santana
• Thinking on a New Message Queue Design jonefee wang
• PANIC: Unable to recover the cluster after all the controllers in KRaft mode were dead at the same time Jesus Cea
  • Re: PANIC: Unable to recover the cluster after all the controllers in KRaft mode were dead at the same time Jesus Cea
• Kafka 2.7.2 to 3.5.1 upgrade Lud Antonie
  • Re: Kafka 2.7.2 to 3.5.1 upgrade Haruki Okada
  • Re: Kafka 2.7.2 to 3.5.1 upgrade Lud Antonie
  • Re: Kafka 2.7.2 to 3.5.1 upgrade megh vidani
  • Re: Kafka 2.7.2 to 3.5.1 upgrade Lud Antonie
  • Re: Kafka 2.7.2 to 3.5.1 upgrade Luke Chen
• Relation between fetch.max.bytes, max.partition.fetch.bytes & max.poll.records Debraj Manna
  • Re: Relation between fetch.max.bytes, max.partition.fetch.bytes & max.poll.records Haruki Okada
  • Re: Relation between fetch.max.bytes, max.partition.fetch.bytes & max.poll.records Debraj Manna
  • Re: Relation between fetch.max.bytes, max.partition.fetch.bytes & max.poll.records Haruki Okada
  • Re: Relation between fetch.max.bytes, max.partition.fetch.bytes & max.poll.records Debraj Manna
  • Re: Relation between fetch.max.bytes, max.partition.fetch.bytes & max.poll.records Debraj Manna
  • Re: Relation between fetch.max.bytes, max.partition.fetch.bytes & max.poll.records Haruki Okada
• CMAK | Unable to see Logize and Lag HariBabu kuruva
• Switching from MirrorMaker to MirrorMaker 2 Andrew Gehring
• How does Kafka Consumer send JoinRequest? Debraj Manna
  • Re: How does Kafka Consumer send JoinRequest? Haruki Okada
• [VOTE] 3.6.1 RC0 Mickael Maison
  • Re: [VOTE] 3.6.1 RC0 Jakub Scholz
  • Re: [VOTE] 3.6.1 RC0 Federico Valeri
• Failover issue with kafka cluster Denis Santangelo
  • Re: Failover issue with kafka cluster Artem Timchenko
• GlobalKTable with RocksDB - queries before state RUNNING? Christian Zuegner
  • Re: GlobalKTable with RocksDB - queries before state RUNNING? Sophie Blee-Goldman
  • RE: GlobalKTable with RocksDB - queries before state RUNNING? Christian Zuegner
  • Re: GlobalKTable with RocksDB - queries before state RUNNING? Sophie Blee-Goldman
  • Re: GlobalKTable with RocksDB - queries before state RUNNING? Matthias J. Sax
• Change super.users at runtime Artem Timchenko
• [VOTE] 3.5.2 RC1 Luke Chen
  • Messages streaming from topic to topic Alexander Shapiro (ashapiro)
  • Re: Messages streaming from topic to topic megh vidani
  • RE: Messages streaming from topic to topic Alexander Shapiro (ashapiro)
  • Re: Messages streaming from topic to topic Anders Engström
  • RE: Messages streaming from topic to topic Alexander Shapiro (ashapiro)
  • Re: Messages streaming from topic to topic megh vidani
  • Re: [VOTE] 3.5.2 RC1 Josep Prat
  • Re: [VOTE] 3.5.2 RC1 Federico Valeri
  • Re: [VOTE] 3.5.2 RC1 Jakub Scholz
• Kafka CVE's Daniel Peric
• How to dynamically change configurations in the controllers Jesus Cea
  • Re: How to dynamically change configurations in the controllers Luke Chen
  • Re: How to dynamically change configurations in the controllers Jesus Cea
• Kafka Broker Backups Upesh Desai
• Important Security Notice for Apache Kafka Users Divij Vaidya
• Fwd: [Question] About Kafka producer design decision making Sean Sin
  • Re: [Question] About Kafka producer design decision making Haruki Okada
• About Kafka Java Client Producer Retry And Callback 王有胜
  • Re: About Kafka Java Client Producer Retry And Callback Haruki Okada
  • Re: About Kafka Java Client Producer Retry And Callback 王有胜
  • Re: About Kafka Java Client Producer Retry And Callback 1
• Fwd: unsubscribe Clark Sims
  • Re: Fwd: unsubscribe Bruno Cadonna
• Example dynamic TLS certificates reconfiguration Jesus Cea
  • Re: Example dynamic TLS certificates reconfiguration Jesus Cea
• Regarding ingestion rate, topic size and retention period Yeikel Santana
  • Re: Regarding ingestion rate, topic size and retention period Richard Bosch
• License Cost for Apache Kafka with Support Vinothkumar S
  • Re: License Cost for Apache Kafka with Support sunil chaudhari
  • Re: License Cost for Apache Kafka with Support Bruno Cadonna
• Upgrade procedure from 2.8 to 3.6 Kraft Srinivas Polamarasetty
  • Re: Upgrade procedure from 2.8 to 3.6 Kraft Nag Pavan Chilakam
• How to get a X509 broker certificate with "openssl s_client"? Jesus Cea
  • Re: How to get a X509 broker certificate with "openssl s_client"? Jesus Cea
• Digest-MD5 authentication between kafka and zookeeper arjun s v
  • Re: Digest-MD5 authentication between kafka and zookeeper arjun s v
  • Re: Digest-MD5 authentication between kafka and zookeeper Alex Craig

• Earlier messages
• Later messages