consumer-group.rb in ruby-kafka-0.5.0.beta6

- old
+ new

@@ -18,9 +18,10 @@
 
 consumer = kafka.consumer(group_id: "test")
 consumer.subscribe(topic)
 
 trap("TERM") { consumer.stop }
+trap("INT") { consumer.stop }
 
 consumer.each_message do |message|
   puts message.value
 end