Plugging a Kafka leak in a high throughput data pipeline