Confluent Developer Blog

Apache Kafka

Introducing the Confluent Rust Client for Apache Kafka

Confluent's officially supported Rust client for Apache Kafka is native, async, and follows the Java client's configuration, API and behavior.

Kafka Streams

Republished: 15 Kafka Streams deep dives from the Responsive archive

Fifteen in-depth Kafka Streams posts from the Responsive blog, published between 2023 and 2025, republished here with permission from the original authors.

Apache Kafka

Catching Schema Drift at Service Startup

How to catch breaking schema changes early, then verify the same contract again when a Spring Boot service starts against the registry it will actually use.

How We Build

Optimizing the Confluent Platform release pipeline

How Confluent Platform, an on-premises product, went from a 7.5-hour build and months-long releases to shipping in 3–4 days: parallelized builds, pilot builds gating every PR, pipeline failures treated as SEV-2 incidents, a single shared test quality score, and components released independently of the core.

Apache Kafka

Streaming IoT sensor data from MQTT to Kafka

Stream MQTT sensor data into Kafka: a walkthrough of Mosquitto, the Confluent MQTT Connector, HiveMQ, Zilla, AWS IoT Core & Kepware.

Apache Flink

Deduplicating Streams with Flink SQL

A deep dive into deduplicating streams with Flink SQL, weighing state growth, changelog modes, late events, and latency, and why a custom PTF can beat clever SQL.

Apache Flink

How I Review Flink SQL Solutions

A framework for reviewing Flink SQL solutions: state growth, append-only vs. updating output, late events, latency, and determinism before going to production.

Apache Flink

Flink SQL Evolution: Handling Custom CDC with FROM_CHANGELOG and TO_CHANGELOG

How the new FROM_CHANGELOG and TO_CHANGELOG built-in functions let Flink SQL read custom CDC formats and turn updating streams back into append-only ones.

Apache Flink

Absolutely Everything You Always Wanted to Know About Watermarks in Apache Flink - Part 2: Confluent Cloud for Apache Flink

Confluent Cloud for Apache Flink watermarks deep-dive. Differences and extensions to Apache Flink: default watermarks, idleness, alignment, late events handling, watermark observability.

Apache Flink

Absolutely Everything You Always Wanted to Know About Watermarks in Apache Flink - Part 1: Apache Flink

Deep-dive reference on Apache Flink watermarks: generation, propagation, idle partition detection, alignment, and why lateness is non-deterministic.