1 package worker 2 3 // Worker interface for starting and stopping the consumption of messages from Kafka topic and publish them to Google Pub/Sub 4 type Worker interface { 5 Start() 6 Stop() 7 } 8
View as plain text