This article outlines the evolution of a data pipeline from using JSON to AVRO for Change Data Capture (CDC). As the business expanded, the limitations of JSON became apparent, leading to the adoption of AVRO, which improved performance, reduced storage costs, and streamlined schema evolution.

Confluent has agreed to be acquired by IBM in an all-cash deal valued at $31 per share. After the acquisition, Confluent will remain a distinct brand within IBM, focusing on enhancing data streaming capabilities for enterprises and supporting real-time operations.

This article shares insights from analyzing 25,000 dead letter queue (DLQ) messages to highlight common pitfalls in DLQ setups and the importance of proper configuration and monitoring. It outlines a systematic approach for diagnosing issues in Kafka, emphasizing the need to identify root causes and take corrective action efficiently.

AWS Lambda now offers improved observability for Kafka event source mappings, allowing users to monitor event polling, scaling, and processing with Amazon CloudWatch Logs and metrics. This enhancement helps troubleshoot issues quickly, reducing operational overhead and mean time to resolution. It's available for both Amazon Managed Streaming for Apache Kafka and self-managed Kafka setups.

This article argues against the notion that Postgres can replace Kafka, highlighting their distinct purposes. It explains how using Postgres for event streaming can lead to challenges and inefficiencies, particularly for use cases Kafka is designed to handle.

This article discusses a system built for Wayfair that uses PostgreSQL as a Dead Letter Queue (DLQ) to manage failed event processing. Instead of using Kafka for failed events, the system stores them in a PostgreSQL table, allowing for better visibility and easier reprocessing. It also outlines a retry mechanism with exponential backoff to prevent flooding the DLQ with transient failures.

Uber developed uFowarder, a consumer proxy for Apache Kafka, to address issues like head-of-line blocking and hardware efficiency. This blog details the challenges faced during its production and the solutions implemented, such as context-aware routing and active head-of-line blocking resolution.

This article discusses the performance benchmarks of Diskless Kafka (KIP-1150), showcasing significant cost savings and low latency achieved using just six m8g.4xlarge machines. It emphasizes the importance of realistic and open-source testing to validate the effectiveness of Diskless topics in Apache Kafka deployments.

This article details Datadog's approach to creating a managed data replication platform that improves data movement across services. It covers technical challenges faced with a shared Postgres database, the transition to a dedicated search platform, and the use of asynchronous replication to enhance scalability and reliability.

This article lists notable data engineering projects from late December 2025. It features a variety of pipelines and platforms, highlighting their purposes and technologies used, like Airflow, Kafka, and machine learning tools. Users can explore, vote, and share their own projects within the community.

This article details LinkedIn's transition from Zookeeper to a new scalable service discovery system designed to handle the demands of a growing number of microservices. The new system, which uses Kafka and a Service Discovery Observer, improves scalability, compatibility, and extensibility while supporting multiple programming languages.

This article explores the integration of Flink, Airflow, and StarRocks for real-time data processing. It details different methods for data ingestion, including routine loads and Kafka connectors, while sharing lessons learned from implementation. The author concludes with a preference for the Flink Connector due to its flexibility and existing infrastructure.

This article discusses how Expedia Group improved their Kafka Streams application by ensuring that identical keys from two topics were processed by the same instance. They faced issues with partition assignment and solved it by using a shared state store, which enhanced caching efficiency and reduced redundant API calls.

This article discusses Grab's approach to optimizing CPU provisioning for Flink applications using machine learning. It highlights the limitations of reactive autoscaling and proposes a predictive model that forecasts workload demands to improve resource allocation and reduce inefficiencies.

Set up the Tansu broker using SQLite on an AWS t3.micro instance, taking advantage of the AWS Free Tier. The guide covers installation, configuration, and performance testing, demonstrating how to launch a low-cost Kafka-compatible broker for early-stage projects.

WarpStream has introduced Tableflow, a solution for efficiently converting Kafka topic data into Iceberg tables with low latency. The article discusses the challenges of using Spark for this process, including high latency, small file issues, and the complexity of managing data lakes. It ultimately argues that relying on Kafka's tiered storage for building Iceberg tables is impractical due to various performance issues encountered in real-world scenarios.

The Kafka community faces a critical decision regarding the future of the project as it considers three competing KIPs aimed at reducing high replication costs across cloud availability zones while integrating object storage. The article explores two main approaches: a revolutionary path that embraces a direct-to-S3 architecture for greater elasticity and an evolutionary path that adapts existing components to reduce immediate refactoring needs. Ultimately, the choice made will shape the direction of Kafka for the next decade.

The article discusses the integration of natural language processing (NLP) with Apache Kafka, highlighting how Kafka can enhance data querying capabilities through NLP techniques. It emphasizes the importance of transforming and querying streaming data in a way that is intuitive for users, enabling better insights and decision-making from real-time data streams.

The concept of "zero-copy" integration between Apache Kafka and Apache Iceberg, which suggests that Kafka topics could directly function as Iceberg tables, is critiqued for its inefficiencies and potential pitfalls. The article argues that while it may seem to offer reduced duplication and storage costs, it actually imposes significant compute overhead on Kafka brokers and complicates data layout for analytics. Additionally, it highlights challenges related to schema evolution and performance optimization for both streaming and analytics workloads.

The article explores three approaches to diskless Kafka, focusing on Slack’s KIP-1176 (Fast Tiering), Aiven’s KIP-1150 (Diskless Topics), and KIP-1183 (AutoMQ). Each proposal aims to optimize Kafka's storage and replication strategies in the cloud, balancing cost, performance, and architectural integrity. The discussion highlights the strengths and weaknesses of these innovations while considering their potential integration into the Apache Kafka ecosystem.

The article explains Kafka consumer lag, which refers to the delay between data being produced and consumed by Kafka consumers. It highlights the significance of monitoring consumer lag to ensure efficient data processing and system performance, and discusses various methods to measure and manage this lag effectively.

ShareChat transitioned from open-source Kafka to WarpStream to optimize their machine learning logging and handle their highly elastic workloads more efficiently. By adopting WarpStream's stateless architecture, ShareChat achieved significant cost savings and improved scalability, eliminating inter-AZ networking fees and reducing operational complexities associated with Kafka. The article details their testing results, showing WarpStream's advantages in throughput and cost-effectiveness compared to traditional Kafka setups.

The article discusses the evolution and future of Apache Kafka, emphasizing its significance in modern data streaming and event-driven architectures. It highlights the challenges and opportunities that arise as Kafka continues to grow in popularity within the tech industry.

WarpStream is a Kafka-compatible streaming platform that utilizes object storage for enhanced durability and cost efficiency, especially when combined with Tigris, a multi-cloud storage solution that eliminates egress fees. This article provides a tutorial on deploying a WarpStream cluster backed by Tigris using Docker, allowing users to create a scalable message queue without hidden transfer costs. It covers prerequisites, setup steps, and basic operations to manage topics and messages within the queue.

This tutorial guides users through setting up a complete Change Data Capture (CDC) pipeline using Debezium and Kafka Connect to stream changes from a PostgreSQL database. It covers the prerequisites, infrastructure setup with Docker, PostgreSQL configuration, connector registration, and observing change events in Kafka topics.

Geocodio faced significant challenges in scaling their request logging system from millions to billions of requests due to issues with their deprecated MariaDB setup. They attempted to transition to ClickHouse, Kafka, and Vector but encountered major errors related to data insertion and system limits, prompting a reevaluation of their architecture. The article details their journey to optimize request tracking and overcome the limitations of their previous database solution.

The article provides a Kafka visualization tool to help users understand the data flow through a replicated Kafka topic, emphasizing the message processing model in a simulated environment. It also promotes an eBook that offers deeper insights into Apache Kafka's architecture and strategic use cases. SoftwareMill, the creator, specializes in Kafka-related architecture, development, and training services.

Eloelo's push notification architecture is designed to handle millions of personalized notifications in real-time, addressing challenges such as volume, latency, and reliability. The system employs an event-driven model with Kafka pipelines, dynamic template orchestration, and a resilient delivery mechanism that includes intelligent retries and fallback strategies to ensure effective communication with users.

Fresha successfully executed a zero-downtime upgrade from PostgreSQL 12 to 17 across over 200 databases by developing a tailored upgrade framework that addressed the complexities of maintaining data consistency and availability during the process. The approach involved leveraging logical replication, managing Debezium connectors, and implementing a two-phase switchover to ensure a seamless transition without disrupting production services.

Building Kafka on top of S3 presents several challenges, including data consistency, latency issues, and the need for efficient data retrieval. The article explores these obstacles in depth and discusses potential solutions and architectural considerations necessary for successful integration. Understanding these challenges is crucial for engineers looking to leverage Kafka with S3 effectively.

To transfer data from Apache Kafka to Apache Iceberg, various options exist, including Apache Flink SQL, Kafka Connect, and Confluent's Tableflow. Each method has its own strengths and considerations, such as data structure, existing deployment preferences, and the number of Kafka topics involved, guiding users in selecting the most suitable solution for their specific use case.

Klaviyo has developed a resilient event publisher using a dual failure capture design to ensure that no incoming events are lost during processing, even amidst network issues or serialization errors. By integrating Kafka topics and S3 for backup, the system can efficiently handle failures and maintain real-time event publishing for its customers. The implementation has proven effective, with significant automatic retries and event recovery in production.

Implementing the Saga pattern in microservices can improve data consistency across distributed systems. The article discusses how to leverage NestJS and Kafka for managing complex transactions in microservices architecture, providing examples and best practices for effective implementation.

The article delves into the working mechanism of Apache Kafka, a distributed event streaming platform. It explains the architecture, components, and key features that enable Kafka to handle real-time data feeds efficiently. Understanding Kafka's capabilities can help developers and organizations optimize their data processing strategies.

Agoda has developed a custom solution for Kafka consumer failover across data centers, addressing the limitations of existing options like stretch clusters and MirrorMaker 2. Their approach incorporates two-way synchronization of consumer group offsets to facilitate seamless failover and failback, ensuring data integrity and minimizing disruption during data center outages.

The article explores the ingestion of Debezium change events from Kafka into Apache Flink using Flink SQL. It details the use of two main connectors—the Apache Kafka SQL Connector and the Upsert Kafka SQL Connector—highlighting their functionalities in both append-only and changelog modes, along with key configurations and considerations for processing Debezium data effectively.

This guide demonstrates how to process ADS-B aviation data using Apache Flink and Kafka to identify missed landing approaches and runway landings. It provides steps to set up a Docker environment, collect real-time flight data, and execute SQL queries to analyze aircraft movements and relationships using user-defined functions and reference data.

SQLFlow is a high-performance stream processing engine that allows users to build data pipelines using SQL, integrating with various input sources like Kafka and WebSockets, and outputting to systems such as PostgreSQL and cloud storage. It leverages DuckDB and Apache Arrow for efficient processing, offering features like data aggregation, enrichment, and support for various serialization formats. The article provides a quickstart guide, setup instructions, and performance benchmarks for SQLFlow.

The article discusses the concept of cross-cloud cluster linking, which enables organizations to connect and manage Kafka clusters across multiple cloud environments. This capability facilitates seamless data sharing and resilience in operations, helping businesses to optimize their data architecture. It highlights the benefits of such integrations for enhancing scalability and reliability in data streaming applications.

LinkedIn has introduced Northguard, a scalable log storage system designed to improve the operability and manageability of data as the platform grows. Northguard addresses the challenges faced with Kafka, including scalability, operability, availability, and consistency, by implementing advanced features such as log striping and a refined data model. Additionally, Xinfra serves as a virtualized Pub/Sub layer over Northguard to further enhance data processing capabilities.

The article discusses the necessity of implementing the Google Agent-to-Agent Protocol using Apache Kafka to enhance communication and data exchange between agents. It emphasizes the benefits of using Kafka's scalable architecture to manage real-time data streams efficiently. Additionally, the piece outlines how this integration can improve the performance and reliability of agent interactions in various applications.

Kafka poses significant challenges for securing cardholder data in compliance with PCI-DSS, particularly due to its lack of built-in encryption for data at rest. Kroxylicious, a Kafka protocol-aware proxy, enables end-to-end encryption of sensitive payment information without requiring code changes to existing applications, thus simplifying the implementation of security measures in a microservices architecture. The article discusses how to set up Kroxylicious to encrypt Kafka messages effectively.

Understanding Kafka and Flink is essential for Python data engineers as these tools are integral for handling real-time data processing and streaming. Proficiency in these technologies enhances a data engineer's capability to build robust data pipelines and manage data workflows effectively. Learning these frameworks can significantly improve job prospects and performance in data-centric roles.

The author explores the potential for a new cloud-native event log system, dubbed Kafka.next, by outlining a wishlist of desirable features that could enhance the usability and performance of Kafka. Key improvements include eliminating partitions, implementing key-centric access, and incorporating broker-side schema support, among others, to better support modern event-driven applications. The post invites feedback from the community on additional features and architectural considerations.

The article discusses KIP-1150, a proposal for enabling diskless operation in Apache Kafka, which aims to enhance performance and reduce storage costs by allowing Kafka brokers to operate without local disk storage. This shift is expected to simplify deployments and improve scalability in cloud environments.

The article outlines how to build real-time dashboards using Apache Kafka, emphasizing the importance of real-time data processing and visualization. It provides insights into the necessary tools and steps to effectively leverage Kafka for creating dynamic dashboards that reflect live data streams. The focus is on enhancing data-driven decision-making through timely insights and user-friendly interfaces.

AWS Lambda now offers low latency processing for Kafka events, allowing sub-100ms event handling for Amazon MSK and self-managed Apache Kafka in Provisioned mode. By setting the MaximumBatchingWindowInSeconds parameter to 0, customers can achieve real-time processing, making it suitable for mission-critical applications across various industries. This feature is available in most AWS regions, enhancing the efficiency of latency-sensitive applications.

Klaviyo successfully migrated its event processing pipeline from RabbitMQ to a Kafka-based architecture, handling up to 170,000 events per second while ensuring zero data loss and minimal impact on ongoing operations. The new system enhances performance, scales for future growth, and improves operational efficiency, positioning Klaviyo to meet the demands of over 176,000 businesses worldwide. Key design principles focused on decoupling ingestion from processing, eliminating blocking issues, and ensuring reliability in the face of transient failures.

The article discusses the importance of understanding different types of time—event time and processing time—in data processing with systems like Apache Kafka and Apache Flink. It highlights how timestamps are handled in Kafka messages and the role of time attributes in Flink, including the concept of watermarks for managing data completeness and freshness. The author provides practical examples of defining time attributes in Flink SQL for querying data effectively.

Utilizing distributed tracing with OpenTelemetry can enhance visibility and performance monitoring in Kafka systems, which are inherently challenging due to their decoupled and asynchronous nature. The article compares zero-code and manual instrumentation approaches, detailing their pros and cons, and demonstrates how to effectively implement each to gain better insights into application performance.