ruby-kafka
ruby-kafka copied to clipboard
Added after_fetch_message callback
I've added fetch_message_callback to each_message instance method of Consumer class. I think it might be useful for sending heartbeat events to other services.