code: func (plugin *ExamplePlugin) syncEventHandler() {
  	plugin.Log.Info("Started Kafka sync event handler...")
  
  	// Producer sends several messages (set in messageCount).
  	// Consumer should receive only messages from desired partition and offset.
  	receivedMessageCounter := 0
  	for message := range plugin.subscription {
  		plugin.Log.Infof("Received sync Kafka Message, topic '%s', partition '%v', offset '%v', key: '%s', ",
  			message.GetTopic(), message.GetPartition(), message.GetOffset(), message.GetKey())
  		// Note: mark the offset if required
  		receivedMessageCounter++
  		if message.GetPartition() != syncMessagePartition {
  			plugin.Log.Errorf("Received sync message with unexpected partition: %v", message.GetOffset())
  		}
  		if message.GetOffset() < messageOffset {
  			plugin.Log.Errorf("Received sync message with unexpected offset: %v", message.GetOffset())
  		}
  	}
  
  }
docs: /*************
   * Consumers *
   *************/
  // syncEventHandler is a Kafka consumer synchronously processing events from
  // a channel associated with a specific topic, partition and a starting offset.
  // If a producer sends a message matching this destination criteria, the consumer
  // will receive it.