Currently each message is published individually, instead this should be done using the batch API. Imported from Jira [BEAM-13415](https://issues.apache.org/jira/browse/BEAM-13415). Original Jira may contain additional context. Reported by: mosche.