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,