Imports github.com/IBM/sarama gocloud.dev/gcerrors gocloud.dev/pubsub gocloud.dev/pubsub/batcher gocloud.dev/pubsub/driver Standard library imports context errors fmt net/url os path reflect strings sync time