eventExecutor.schedule(() -> {
LOG.warn("Reconnection is allowed! This can lead to unexpected errors at runtime.");
LOG.warn("{} : No more sources for schema context.", id);
eventExecutor.schedule(() -> {
LOG.warn("Reconnection is allowed! This can lead to unexpected errors at runtime.");
LOG.warn("{} : No more sources for schema context.", id);