search

Netflix / suro

Netflix's distributed Data Pipeline
Apache License 2.0
794 stars 170 forks source link

Implement pause() on KafkaConsumer side not to accumulate too many messages on the sink queue #102

Closed metacret closed 9 years ago