code: func (plugin *ExamplePlugin) syncEventHandler() {
  	plugin.Log.Info("Started Kafka event handler...")
  	msgCounter := 0
  	if messageCountNum == 0 {
  		// Set as done
  		plugin.syncRecv = true
  	}
  
  	// Watch on message channel for sync kafka events
  	for message := range plugin.subscription {
  		plugin.Log.Infof("Received Kafka Message, topic '%s', partition '%v', offset '%v', key: '%s', ",
  			message.GetTopic(), message.GetPartition(), message.GetOffset(), message.GetKey())
  		// mark the offset
  		plugin.kafkaWatcher.MarkOffset(message, "")
  		msgCounter++
  		if msgCounter == messageCountNum {
  			plugin.syncRecv = true
  		}
  	}
  }
docs: /*************
   * Consumers *
   *************/
  // syncEventHandler is a Kafka consumer synchronously processing events from
  // a channel associated with a specific topic. If a producer sends a message
  // matching this destination criteria, the consumer will receive it.