search

skroutz / rafka

Kafka proxy with a simple API, speaking the Redis protocol
https://engineering.skroutz.gr/blog/kafka-rails-integration/
GNU General Public License v3.0
8 stars 0 forks source link

producer: Make Flush timeout configurable #35

Open agis opened 7 years ago

agis commented 7 years ago

Currently it's hard-coded to 5 seconds: https://github.com/skroutz/rafka/blob/f9311550d7ec82bf7ddec7e5094d34912780bf60/producer.go#L78

We should also make it clear that this timeout sets a lower bound on how much time the shutdown process may take.