detect and fix kafka issues
Abstract
Common issues:
- topic name: how to make a mess
- nb partition: how to waste a precious resource
- retention: how to waste storage
ack != all
: how to loose datamin.isr
: how to loose data againlinger.ms
: how to be slow and penalize kafkacompression.codec
: how to waste storage and network- consumer group names: how make bad magic appear
- poison pill: how to fail miserably
- invalid schema: how to fail miserably again
- latency: how to fail at
kstream
orksqlDB
at the worst timefetch.min.bytes
: how to be a smart ass and breaking kafka- duplicates: how to discover you’re not idempotent
- rebalance storm: how to discover you’re half-alive
- old version: how to play with fire
- over transacting: how to no understand transactions
Protocol to extend: https://kafka.apache.org/protocol. They present a way to enforce the way to communicate with Kafka, e.g. enforce the topic syntax, by using a proxy in front of Kafka.