我在尝试将消息从 Kafka 读取到 S3 时遇到了将 jar 添加到 Kafka 连接类路径的问题。
目标是根据时间戳在分区中写入消息，时间戳是 Kafka 消息中 Key 的一部分。
为了使故事简短，我必须提供自定义时间戳提取器。按照此处的文档创建了一个实现TimestampExtractor接口的类并将 JAR 位置添加到plugin.path属性中。
问题是当我开始连接时，找不到类。不知何故，jar 不在类路径中，我得到了
org.apache.kafka.common.config.ConfigException: Invalid timestamp extractor: partitioner.SpotadDateTimeExtractor
附加数据：
版本：融合 4.0.0
连接：连接独立
启动命令：
sudo /home/ubuntu/confluent-4.0.0/bin/connect-standalone \
/home/ubuntu/confluent-4.0.0/etc/kafka/connect-standalone.properties \
/home/ubuntu/confluent-4.0.0/etc/kafka-connect-s3/quickstart-s3.properties
Apreaciate任何帮助。