RxJava 2 API

Service importers do not have a generated RxJava 2 implementation.

You must create an instance and wrap it with ServiceImporter:

JsonObject defaultConf = new JsonObject();
ServiceImporter rxServiceImporter = new ServiceImporter(new KubernetesServiceImporter());
serviceDiscovery.registerServiceImporter(rxServiceImporter, defaultConf);