lib/racecar/runner.rb in racecar-0.2.0 vs lib/racecar/runner.rb in racecar-0.2.1

- old
+ new

@@ -22,12 +22,13 @@ offset_commit_interval: config.offset_commit_interval, offset_commit_threshold: config.offset_commit_threshold, heartbeat_interval: config.heartbeat_interval, ) - # Stop the consumer on SIGINT and SIGQUIT. + # Stop the consumer on SIGINT, SIGQUIT or SIGTERM. trap("QUIT") { consumer.stop } trap("INT") { consumer.stop } + trap("TERM") { consumer.stop } config.subscriptions.each do |subscription| consumer.subscribe( subscription.topic, start_from_beginning: subscription.start_from_beginning,