code: func (p *Plugin) NewPartitionWatcher(name string) messaging.ProtoPartitionWatcher {
  	return p.NewProtoManualConnection(name)
  }
docs: // NewPartitionWatcher creates a watcher that allows to start/stop consuming of messaging published to given topics, offset and partition