时间戳

首页 > 解决方案 > Kafka ConnectStandalone - java.lang.IllegalArgumentException：格式错误的 \uxxxx 编码

snowflake-cloud-data-platform - Kafka ConnectStandalone - java.lang.IllegalArgumentException：格式错误的 \uxxxx 编码

问题描述

我正在独立运行 Kafka Connect

$ kafka_2.13-2.8.0/bin$ connect-standalone.sh ../config/connect-standalone.properties ../config/connect-snowflake-kafka-connector.properties ../libs/snowflake-kafka-connector-1.5.5.jar

收到 Snowflake Apache Kafka 错误。附在图片中的错误

在此处输入图像描述

[2021-09-07 14:56:45,843] DEBUG WorkerSinkTask{id=snowflakeslink-0} Initializing and starting task for topics test-topic (org.apache.kafka.connect.runtime.WorkerSinkTask:299)
[2021-09-07 14:56:45,844] INFO 
[SF_KAFKA_CONNECTOR] SnowflakeSinkTask[ID:0]:start (com.snowflake.kafka.connector.SnowflakeSinkTask:101)
[2021-09-07 14:56:45,856] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:117)
java.lang.IllegalArgumentException: Malformed \uxxxx encoding.
    at java.util.Properties.loadConvert(Properties.java:574)

标签： snowflake-cloud-data-platformapache-kafka-connect

解决方案

connect-standalone.sh 只接受属性文件参数。如果您将 JAR 文件作为 shell 参数提供给它，它会尝试将其解析为属性文件，并且会失败

您的雪花驱动程序 JAR 应该CLASSPATH通过一个被添加到 Java 中export，而不是作为脚本的参数。

例如

$ export CLASSPATH='/path/to/snowflake-client-driver.jar'
$ connect-standalone.sh connect-standalone.properties snowflake-demo-standalone.properties

但是（推荐），使用confluent hub install- https://www.confluent.io/hub/snowflakeinc/snowflake-kafka-connector

相关文章-在不安装 Confluent 平台的情况下使用 Confluent Hub

这将更新配置属性plugin.path以添加连接器类

推荐阅读