KafkaOauthExampleClients oauthInternalClientProducerJob = new KafkaOauthExampleClients.Builder()
        .withProducerName(OAUTH_CLIENT_AUDIENCE_PRODUCER)
        .withBootstrapAddress(KafkaResources.bootstrapServiceName(oauthClusterName) + ":" + customClaimListenerPort)
        .withTopicName(TOPIC_NAME)
        .withMessageCount(MESSAGE_COUNT)
        .withOAuthClientId(OAUTH_CLIENT_AUDIENCE_PRODUCER)
        .withOAuthClientSecret(OAUTH_CLIENT_AUDIENCE_SECRET)
        .withOAuthTokenEndpointUri(keycloakInstance.getOauthTokenEndpointUri())
        .build();

KafkaOauthExampleClients oauthInternalClientConsumerJob = new KafkaOauthExampleClients.Builder()
        .withConsumerName(OAUTH_CLIENT_AUDIENCE_CONSUMER)
        .withBootstrapAddress(KafkaResources.bootstrapServiceName(oauthClusterName) + ":" + customClaimListenerPort)
        .withTopicName(TOPIC_NAME)
        .withMessageCount(MESSAGE_COUNT)
        .withOAuthClientId(OAUTH_CLIENT_AUDIENCE_CONSUMER)
        .withOAuthClientSecret(OAUTH_CLIENT_AUDIENCE_SECRET)
        .withOAuthTokenEndpointUri(keycloakInstance.getOauthTokenEndpointUri())
        .build();