Search the library

Search concepts, questions & guides

Topic

3 matching resultsArticles and interview answers

Q&A

How do you prevent Kafka CommitFailedException when processing is slow?

Keep consumer liveness within max.poll.interval.ms and commit only after durable work.

Read the concise answer

If processing exceeds max.poll.interval.ms, the group may consider the member failed and reassign its partitions; a later commit from the old generation is rejected. Reduce records per poll, process with bounded workers while preserving partition ordering, pause/resume appropriately, or adjust the interval based on measured worst-case work. Keep the fix from merely delaying failure detection indefinitely.

java

9 min

Spring Transaction Boundaries: Where to Commit and When to Split

A transaction is only as good as the boundary you choose. Learn how service-layer design, isolation levels, and idempotent writes affect correctness in Java systems.

distributed systems

12 min

Kafka Consumer Groups: Architecture & Common Pitfalls

Consumer groups are the mechanism that turns Kafka partitions into scalable, failure-tolerant work units. Learn how rebalances, offsets, and lag interact under load before you ship your first serious pipeline.