examples/consumer-group.rb in ruby-kafka-0.5.5 vs examples/consumer-group.rb in ruby-kafka-0.6.0.beta1

@@ -20,8 +20,14 @@
 consumer.subscribe(topic)
 
 trap("TERM") { consumer.stop }
 trap("INT") { consumer.stop }
 
-consumer.each_message do |message|
-  puts message.value
+begin
+  consumer.each_message do |message|
+  end
+rescue Kafka::ProcessingError => e
+  warn "Got #{e.cause}"
+  consumer.pause(e.topic, e.partition, timeout: 20)
+
+  retry
 end