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

consumer: Switch to Poll() #20

Closed agis closed 7 years ago

agis commented 7 years ago

Using Poll() means we have a more direct mapping to librdkafka functionality. Poll may also prioritize messages from Kafka, whereas with the channel-based approach we may end up with outdated events.