private PulsarKafkaAdminClient()

in pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java [66:84]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    private PulsarKafkaAdminClient(AdminClientConfig config) {
        properties = new Properties();
        log.info("config originals: {}", config.originals());
        config.originals().forEach((k, v) -> {
            log.info("Setting k = {} v = {}", k, v);
            // properties do not allow null values
            if (k != null && v != null) {
                properties.put(k, v);
            }
        });

        PulsarAdminBuilder builder = PulsarClientKafkaConfig.getAdminBuilder(properties);
        try {
            admin = builder.build();
        } catch (PulsarClientException e) {
            log.error("Could not create Pulsar Admin", e);
            throw new RuntimeException(e);
        }
    }