class PodDisruptionBudgetExample {
  private static final Logger logger = LoggerFactory.getLogger(PodDisruptionBudgetExample.class);

  public static void main(String[] args) {<FILL_FUNCTION_BODY>}
}

    final ConfigBuilder configBuilder = new ConfigBuilder();
    if (args.length > 0) {
      configBuilder.withMasterUrl(args[0]);
      logger.info("Using master with URL: {}", args[0]);
    }
    try (KubernetesClient client = new KubernetesClientBuilder().withConfig(configBuilder.build()).build()) {
      final String namespace = "default";
      PodDisruptionBudget podDisruptionBudget = new PodDisruptionBudgetBuilder()
          .withNewMetadata().withName("zk-pkb").endMetadata()
          .withNewSpec()
          .withMaxUnavailable(new IntOrString("1%"))
          .withNewSelector()
          .withMatchLabels(Collections.singletonMap("app", "zookeeper"))
          .endSelector()
          .endSpec()
          .build();

      logger.info("Current namespace is {}", namespace);
      client.policy().v1().podDisruptionBudget().inNamespace(namespace).resource(podDisruptionBudget).createOrReplace();

    } catch (KubernetesClientException e) {
      logger.error("Could not create resource: {}", e.getMessage(), e);
    }
  
<no_super_class>