Learn Java Kafka In Action

Stateful processing, joins, and aggregations in Kafka Streams for advanced Java engineers: KGroupedStream, KTable, reduce, aggregate, count, stream-table duality, repartition topics, changelog topics, state stores, joins, foreign-key thinking, tombstones, compaction, testing, observability, and architecture review discipline.

Exactly-once stream processing in Kafka Streams for advanced Java engineers: processing guarantees, transactions, idempotent production, state-store consistency, changelog coordination, output correctness, external side-effect boundaries, failure matrix, testing, observability, and architecture review discipline.

ksqlDB mental model for advanced Java Kafka engineers: SQL over Kafka, STREAM vs TABLE, persistent queries, push queries, pull queries, materialized views, Kafka Streams relationship, deployment architecture, query lifecycle, schema/key semantics, operational boundaries, and decision framework.

ksqlDB stream/table query design for advanced Java Kafka engineers: CREATE STREAM/TABLE, CSAS/CTAS, persistent queries, repartitioning, joins, windowed aggregation, key formats, schema inference, materialization, push/pull query access, lifecycle management, testing, performance, and production governance.

Kafka Connect integration architecture for advanced Java Kafka engineers: source and sink connectors, workers, tasks, distributed mode, converters, Schema Registry, SMTs, offset/config/status topics, connector lifecycle, DLQ/error handling, backpressure, observability, security, deployment, and production runbooks.

Batching, backpressure, and flow control for production-grade Java Kafka systems: producer batching, consumer polling, fetch tuning, downstream pressure, bounded concurrency, adaptive throttling, retry pressure, and operational control loops.

Ordering, consistency, and idempotency for production-grade Java Kafka systems: partition ordering, causal ordering, per-aggregate sequencing, duplicate suppression, idempotent side effects, consistency boundaries, projection correctness, and regulatory-grade workflow invariants.

Multi-service transaction boundaries for Java Kafka systems: local database transactions, Kafka transactions, transactional outbox, CDC, inbox pattern, saga, orchestration, compensation, auditability, and regulatory-grade failure modeling.

Security, ACL, SASL, mTLS, and governance for production Java Kafka systems: threat modeling, encryption, authentication, authorization, service identity, tenant isolation, secrets rotation, topic governance, data classification, auditability, and security operations.

Observability handbook for production Kafka systems: metrics, logs, traces, lag, SLOs, alerting, dashboards, and incident runbooks.

Performance benchmarking and capacity planning handbook for Kafka platforms: throughput, latency, partitions, broker sizing, producer/consumer tuning, storage, and load test methodology.

Production deployment models for Kafka across bare metal, virtual machines, containers, and managed cloud; includes topology, storage, networking, rack awareness, failure domains, deployment checklists, and architecture review templates.

Kafka on Kubernetes handbook covering Strimzi, Confluent for Kubernetes, KRaft, KafkaNodePools, storage classes, listeners, scheduling, disruption budgets, upgrades, observability, and production failure modes.

Production operations handbook for Apache Kafka covering runbooks, upgrades, partition reassignment, broker recovery, lag incidents, Kafka Streams/Connect/ksqlDB operations, and disaster recovery strategy.

Architecture review handbook for Kafka-based systems covering design invariants, review questions, anti-pattern catalog, failure modeling, governance, and production-readiness scoring.

Capstone handbook for designing, implementing, deploying, operating, and reviewing a production-grade Java Kafka platform with Kafka Streams, ksqlDB, Kafka Connect, Schema Registry, observability, security, and runbooks.