Last batch of events is not published to Google Pub/Sub

[palin]

Using Logstash 7.1.1

While using this plugin, me and my team discovered that a last batch of events is not published.
We retrieve data using JDBC plugin, process the data with some json filters and output jsons to Pub/Sub using this plugin.

What happens?
It looks like when a pipelines finishes, Logstash triggers a shutdown phase but that is not communicated to the plugin to send remaining events.

How to fix?
The fix I implemented was to overwrite this plugin and add a method in the main class:

def close
  @logger.info("Received shutdown command. Sending all outstanding messages!")
  stop
end

The original stop method of the plugin is not triggered by Logstash but the close is!
I hope it helps if anyone else has this issue.