package worker // Worker interface for starting and stopping the consumption of messages from Kafka topic and publish them to Google Pub/Sub type Worker interface { Start() Stop() }