Class VitessSource


  • public class VitessSource
    extends Object
    A builder to build a SourceFunction which can read and process vitess database changes. The Vitess connector subscribes to VTGate's VStream gRPC service. VTGate is a lightweight, stateless gRPC server, which is part of the Vitess cluster setup.
    • Constructor Detail

      • VitessSource

        public VitessSource()