code: func (adapter *Adapter) Put(key string, data proto.Message) error {
  	if adapter.Publisher != nil {
  		return adapter.Publisher.Put(key, data)
  	}
  
  	return nil
  }
docs: // Put uses Kafka KeyValProtoWatcher Topic KeyProtoValWriter.