search

redpanda-data / redpanda-operator

39 stars 10 forks source link

Kafka connect bootstrap servers issue #216

Open ajurcenk opened 2 months ago

ajurcenk commented 2 months ago

Operator version: operator-0.4.25 v2.1.26-24.1.9

The error message from the connect pod: org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:554) at org.apache.kafka.clients.admin.Admin.create(Admin.java:147) at org.apache.kafka.connect.runtime.WorkerConfig.lookupKafkaClusterId(WorkerConfig.java:284) at org.apache.kafka.connect.runtime.WorkerConfig.kafkaClusterId(WorkerConfig.java:415) at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:124) at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94) at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:113) Caused by: org.apache.kafka.common.config.ConfigException: You must set either bootstrap.servers or bootstrap.controllers at org.apache.kafka.clients.admin.internals.AdminBootstrapAddresses.fromConfig(AdminBootstrapAddresses.java:62) at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:523) ... 6 more

From the connector config, the bootstrap server's property is empty: bootstrap.servers We didn't set the bootstrapServers the configuration property for the connect cluster.

JIRA Link: K8S-340

ajurcenk commented 2 months ago

The cluster spec example: values_single_3-nodes_console_connectors_no_tls .txt