Couchbase Kafka Connector启动失败：非法反射访问及Bucket配置异常求助

针对Couchbase v4.5 + Strimzi Kafka Operator v0.32 + Couchbase Kafka Connector v3.1.2组合下的启动失败问题，结合报错信息（Cannot fetch configuration for bucket my_bucket及Netty反射警告），给出以下分步解决方案：

1. 临时允许JVM非法反射访问 #

Strimzi v0.32默认使用Java 11，旧版core-io依赖的Netty组件在Java 11下会触发非法反射访问限制，这可能间接导致Bucket配置获取失败。需在Kafka Connect的JVM参数中添加允许规则：

编辑Strimzi KafkaConnect资源，追加JVM参数：

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
  name: your-connect-cluster
spec:
  # 保留原有其他配置
  jvmOptions:
    extraOptions:
      - "--illegal-access=permit"

应用配置后重启Kafka Connect集群，观察是否仍有启动报错。

2. 验证Couchbase用户权限 #

核心报错Cannot fetch configuration for bucket my_bucket大概率是权限问题：

• 确保用于连接的Couchbase用户拥有Bucket Admin或Full Admin权限（Couchbase 4.5对Bucket配置读取的权限要求较高）
• 使用Couchbase CLI手动验证权限：

couchbase-cli bucket-info -c <couchbase-cluster-host> -u <username> -p <password> --bucket=my_bucket

若命令返回Bucket信息，则权限正常；若报错，需在Couchbase控制台调整用户权限。

3. 替换兼容的core-io依赖（谨慎操作） #

若上述两步无效，可尝试替换core-io版本为修复了Java 11反射问题且与Connector v3.1.2兼容的版本（如core-io-1.7.13.jar）：

• 进入Kafka Connect容器的Couchbase Connector插件目录（默认路径：/opt/kafka/plugins/couchbase-connector/xxx/kafka-connect-couchbase-3.1.2/share/java/kafka-connect-couchbase/）
• 备份并删除原core-io-1.4.2.jar
• 放入下载好的core-io-1.7.13.jar
• 重启Kafka Connect集群，检查日志是否恢复正常

注意：替换前务必备份原依赖，避免引发新的依赖冲突。

4. 确认插件隔离配置 #

Strimzi默认开启插件隔离，需确保Couchbase Connector的依赖未与其他插件冲突：
检查KafkaConnect资源的plugin.path配置，确保插件目录独立：

spec:
  config:
    plugin.path: /opt/kafka/plugins

同时确认Couchbase Connector的所有jar包放置在单独的子目录中，避免与其他插件的依赖混淆。

内容的提问来源于stack exchange，提问作者user9537361