kafka.apache.org

Apply a Kafka Connect SMT conditionally using Predicates to scope transforms to specific topics or record shapes

handle a jbod broker disk failure in kraft-mode kafka and confirm log directory failover behavior

configure kafka client and broker authentication using sasl/scram

enable kafka kip-392 follower fetching so consumers read from the closest replica instead of the leader

Design a Kafka topic and schema strategy for streaming real-time vehicle telemetry from a fleet into downstream consumers.

Configure Kafka broker rack awareness so replicas are spread across availability zones

Configure Kafka producer acks=all with topic min.insync.replicas for strong durability guarantees

Enable Kafka static consumer group membership with group.instance.id to avoid rebalances on restart

Enable Kafka topic log compaction to retain only the latest value per key

Configure Kafka Connect with a custom SMT to mask or hash PII fields before records reach a sink connector

Configure Kafka Streams RocksDB state store with custom block cache and bloom filter settings to optimize read performance for large state

Implement Kafka Connect exactly-once source support with a transactional producer and offset management inside a custom SourceConnector

Configure Kafka Streams to handle topology changes between versions using a state store migration and changelog topic rebuild strategy

Configure Kafka Connect JSON converter with Schema Registry to enforce schema validation and evolve schemas safely across connector restarts

Implement a Kafka Streams punctuator on stream time to emit periodic aggregation results without relying on wall-clock time

Use Kafka Streams Global KTable for broadcast lookups without co-partitioning

Implement a KStream-KTable join in Kafka Streams

Implement Kafka Streams windowed aggregations with grace period configuration

Use Kafka Streams state stores and interactive queries for live lookups

Configure Kafka Streams exactly-once processing with processing.guarantee=exactly_once_v2

Implement event-time windowing in Kafka Streams using stream-time punctuators and suppress to emit only final window results

Configure a Kafka Connect sink connector dead-letter queue with header reporting for failed record diagnosis

Enable exactly-once source support on an existing Kafka Connect distributed cluster via the two-phase rollout

Configure MirrorMaker 2 for active-active bidirectional replication between two Kafka clusters with cycle prevention

Enable Kafka tiered storage for a topic and verify remote segment offload using the built-in RemoteLogMetadataManager

Tune Kafka Streams standby replicas and RocksDB changelog compaction for fast task failover

Perform a rolling ZooKeeper-to-KRaft migration on an existing Kafka cluster using the five-phase procedure

Tune Kafka transactional producer transaction.timeout.ms against broker transaction.max.timeout.ms to avoid spurious aborts

Use the Kafka Connect HeaderFrom SMT to promote record value fields into message headers before sink delivery

Configure Kafka exactly-once delivery using EOS v2 transactions for producer-to-consumer pipelines

Apply Kafka Connect Single Message Transforms for topic routing and field masking

Deploy a Kafka Connect source and sink connector

Implement Kafka exactly-once semantics using transactions

Configure Kafka consumer group cooperative sticky rebalancing

Kafka Connect REST create connector