@Test public void testGenerateDeploymentWithOAuthWithMissingClientSecret() { assertThrows(InvalidResourceException.class, () -> { KafkaConnect resource = new KafkaConnectBuilder(this.resource) .editSpec() .withAuthentication( new KafkaClientAuthenticationOAuthBuilder() .withClientId("my-client-id") .withTokenEndpointUri("http: .build()) .endSpec() .build(); KafkaConnectCluster kc = KafkaConnectCluster.fromCrd(resource, VERSIONS); }); }
public static KafkaConnectCluster fromCrd(KafkaConnect kafkaConnect, KafkaVersion.Lookup versions) { KafkaConnectCluster cluster = fromSpec(kafkaConnect.getSpec(), versions, new KafkaConnectCluster(kafkaConnect)); cluster.setOwnerReference(kafkaConnect); return cluster; }
KafkaConnectCluster extends AbstractModel { public static KafkaConnectCluster fromCrd(KafkaConnect kafkaConnect, KafkaVersion.Lookup versions) { KafkaConnectCluster cluster = fromSpec(kafkaConnect.getSpec(), versions, new KafkaConnectCluster(kafkaConnect)); cluster.setOwnerReference(kafkaConnect); return cluster; } }
KafkaConnectCluster extends AbstractModel { public static KafkaConnectCluster fromCrd(KafkaConnect kafkaConnect, KafkaVersion.Lookup versions) { KafkaConnectCluster cluster = fromSpec(kafkaConnect.getSpec(), versions, new KafkaConnectCluster(kafkaConnect)); cluster.setOwnerReference(kafkaConnect); return cluster; } protected  KafkaConnectCluster(HasMetadata resource); protected  KafkaConnectCluster(HasMetadata resource, String applicationName); }
KafkaConnectCluster extends AbstractModel { public static KafkaConnectCluster fromCrd(KafkaConnect kafkaConnect, KafkaVersion.Lookup versions) { KafkaConnectCluster cluster = fromSpec(kafkaConnect.getSpec(), versions, new KafkaConnectCluster(kafkaConnect)); cluster.setOwnerReference(kafkaConnect); return cluster; } protected  KafkaConnectCluster(HasMetadata resource); protected  KafkaConnectCluster(HasMetadata resource, String applicationName); static KafkaConnectCluster fromCrd(KafkaConnect kafkaConnect, KafkaVersion.Lookup versions); Service generateService(); Deployment generateDeployment(Map<String, String> annotations, boolean isOpenShift, ImagePullPolicy imagePullPolicy, List<LocalObjectReference> imagePullSecrets); PodDisruptionBudget generatePodDisruptionBudget(); @Override String getServiceAccountName(); NetworkPolicy generateNetworkPolicy(boolean namespaceAndPodSelectorNetworkPolicySupported, boolean connectorOperatorEnabled); Tracing getTracing(); ClusterRoleBinding generateClusterRoleBinding(); }
KafkaConnectCluster extends AbstractModel { public static KafkaConnectCluster fromCrd(KafkaConnect kafkaConnect, KafkaVersion.Lookup versions) { KafkaConnectCluster cluster = fromSpec(kafkaConnect.getSpec(), versions, new KafkaConnectCluster(kafkaConnect)); cluster.setOwnerReference(kafkaConnect); return cluster; } protected  KafkaConnectCluster(HasMetadata resource); protected  KafkaConnectCluster(HasMetadata resource, String applicationName); static KafkaConnectCluster fromCrd(KafkaConnect kafkaConnect, KafkaVersion.Lookup versions); Service generateService(); Deployment generateDeployment(Map<String, String> annotations, boolean isOpenShift, ImagePullPolicy imagePullPolicy, List<LocalObjectReference> imagePullSecrets); PodDisruptionBudget generatePodDisruptionBudget(); @Override String getServiceAccountName(); NetworkPolicy generateNetworkPolicy(boolean namespaceAndPodSelectorNetworkPolicySupported, boolean connectorOperatorEnabled); Tracing getTracing(); ClusterRoleBinding generateClusterRoleBinding(); static final int REST_API_PORT; static final Probe DEFAULT_HEALTHCHECK_OPTIONS; }