Kafka Connect could not laod config provider class `InternalSecretConfigProvider `

Kafka Connect
1

I follow cp-demo/docker-compose.yml to deploy my Kafka Connect, but an error occurred.

Invalid value io.confluent.connect.secretregistry.rbac.config.provider.InternalSecretConfigProvider for configuration config.providers.secret.class: Could not load config provider class or one of its dependencies

I think i write a incorrect plugin path, however it still happens after i commented that env variable. This is part of my config, i hope anyone can tell my the path to InternalSecretConfigProvider 

    containers:
        - name: kafka-connect
          image: confluentinc/cp-kafka-connect:7.4.1
          env:
            - name: CUB_CLASSPATH
              value: /usr/share/java/confluent-security/connect/*:/usr/share/java/kafka/*:/usr/share/java/cp-base-new/*

            # Kafka
            - name: CONNECT_BOOTSTRAP_SERVERS
              value: "kafka.kafka.svc.cluster.local:9092"

            # Kafka Connect
            - name: CONNECT_LISTENERS
              value: "https://0.0.0.0:8080" # A list of URIs the REST API

            # Other Configs
            - name: CONNECT_REST_ADVERTISED_HOST_NAME
              value: kafka-connect.kafka.svc.cluster.local
            - name: CONNECT_PLUGIN_PATH
              value: "/usr/share/java,/usr/share/confluent-hub-component"
            - name: CONNECT_LOG4J_ROOT_LOGLEVEL
              value: INFO
            - name: CONNECT_LOG4J_LOGGERS
              value: org.reflections=ERROR
            - name: CLASSPATH
              value: /usr/share/java/monitoring-interceptors/*

            # io.confluent.connect.security.ConnectSecurityExtension - RBAC
            # io.confluent.connect.secretregistry.ConnectSecretRegistryExtension - Secret Registry
            - name: CONNECT_REST_EXTENSION_CLASSES
              value: io.confluent.connect.security.ConnectSecurityExtension,io.confluent.connect.secretregistry.ConnectSecretRegistryExtension

            # Secret Registry
            - name: CONNECT_CONFIG_PROVIDERS
              value: secret
            - name: CONNECT_CONFIG_PROVIDERS_SECRET_CLASS
              value: io.confluent.connect.secretregistry.rbac.config.provider.InternalSecretConfigProvider
            - name: CONNECT_CONFIG_PROVIDERS_SECRET_PARAM_MASTER_ENCRYPTION_KEY
              value: b2ZeDwSUc0z86oYz5EOp
            - name: CONNECT_CONFIG_PROVIDERS_SECRET_PARAM_KAFKASTORE_BOOTSTRAP_SERVERS
              value: kafka.kafka.svc.cluster.local:9092
2

Also i got one more error, when i completely remove Secret Registry config section

ERROR Failed to start Connect (org.apache.kafka.connect.cli.ConnectDistributed)
org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements interface org.apache.kafka.connect.rest.ConnectRestExtension and which name matches
3

I found the example uses cp-server-connect image instead of cp-kafka-connect, i don’t know what special features that cp-server-connect contains. But i think cp-server-connect need a Commercial license.

4

This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.