code: func NewConsumer(cfg *config.VentConfig, log *logger.Logger, eventChannel chan types.EventData) *Consumer {
  	return &Consumer{
  		Config:        cfg,
  		Log:           log,
  		Closing:       false,
  		EventsChannel: eventChannel,
  	}
  }
docs: // NewConsumer constructs a new consumer configuration.
  // The event channel will be passed a collection of rows generated from all of the events in a single block
  // It will be closed by the consumer when it is finished