conduktor.io ↗

Most people just use Kafka. You want to know how it works.

Protocol schemas field by field, wire format byte by byte, and the KIP behind every change.

Try

Built by Conduktor, the enterprise platform for Apache Kafka.

See Conduktor →
Reference

Configuration Explorer

Every config property side by side across releases, with the defaults that moved highlighted where they moved.

log.retention.hours · num.io.threads · linger.ms
Reference

Protocol Explorer

Every API, field by field, straight from the message schemas — with the KIP behind each change.

Produce v3–v13 · Fetch v4–v18 · JoinGroup v0–v9
Reference

Wire Format Visualizer

What a request actually looks like on the socket: byte offsets, varints, tagged fields, annotated.

00 00 00 23 · api_key · api_version · client_id
Reference

API Versions Matrix

Which protocol versions a broker speaks — the table you want before pointing an old client at a new cluster.

1.0 · 2.1 · 2.5 · 2.8 · 3.3.1 · 3.6 · 4.0 · 4.3
Reference

KIP Explorer

Every improvement proposal, summarised and tagged, with the release it actually landed in.

KIP-405 Tiered Storage · KIP-500 Remove ZooKeeper
Debug

Error Decoder

Every protocol error code: what triggers it, whether retrying helps, and the command that confirms it.

NOT_LEADER_OR_FOLLOWER · UNKNOWN_TOPIC_OR_PARTITION
Debug

Exception Explorer

The stack trace you just pasted into Slack, with the cause, the fix, and a real example.

CommitFailedException · TimeoutException · SerializationException
Operate

Upgrade Guide

Pick two releases, see exactly what moves: config diffs, protocol bumps, removals, and the KIPs behind them.

4.0 → 4.1 · 4.1 → 4.2 · 4.2 → 4.3
Operate

Config Advisor

Tuning profiles for throughput, latency, durability and cost — each one telling you what it costs.

High throughput · Low latency · Durable · Cost
Operate

Policy Pack

Opinionated ResourcePolicy YAMLs, ready to drop into a self-service catalog.

topic-name-convention · partition-count-bounds · isr-alignment
Ecosystem

Debezium

CDC across every supported connector: config matrix, event envelope, snapshot modes, errors.

MariaDB · MongoDB · MySQL · PostgreSQL · SQL Server
Ecosystem

SMT Explorer

Chain Connect transforms against a real record and watch the output change at every step.

ReplaceField · MaskField · Cast · TimestampConverter
Ecosystem

Flink SQL Playground

Paste a query, get its topic flow, window semantics, state growth and the warnings nobody mentions.

TUMBLE · HOP · SESSION · MATCH_RECOGNIZE

How a record travels through Kafka

PRODUCERS TOPIC · ORDERS CONSUMER GROUPS Produce v11 Produce v11 Produce v11 orders-svc producer acks=all compression.type=lz4 linger.ms=5 web-events producer acks=1 batch.size=64KB enable.idempotence=true cdc-pg producer transactional.id=cdc-1 max.in.flight=5 P0 leader=broker-1 log_end_offset P1 leader=broker-2 log_end_offset P2 leader=broker-3 log_end_offset BROKER CONFIGS min.insync.replicas=2 · retention.ms=7d segment.bytes=1GB · remote.log.storage.enable=true Fetch v17 ShareFetch v0 analytics-cg coord: JoinGroup v9 c0 c1 c2 isolation.level=read_committed max.poll.records=500 fraud-cg coord: ShareFetch v0 c0 c1 c2 session.timeout.ms=10s fetch.max.bytes=50MB