我按照官方文件执行 kakf-connect
从文件中读取数据。
我让Kafka跑得很好。发送和接收信息的生产者和消费者。
但是,当我运行以下命令时:
sudo ./bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties
我得到以下错误:
错误:找不到或加载主类org.apache.kafka.connect.cli.connectstandalone
我查过了,文件在这里 connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone
.
我的 connect-file-source.properties
具体如下:
name=local-file-source
connector.class=org.apache.kafka.connect.file.FileStreamSourceConnector
tasks.max=1
file=test.txt
topic=spark-kafka
少了什么吗?我应该怎么做才能消除这个错误?
1条答案
按热度按时间sqxo8psd1#
因此,相当无知的java,我认为问题是Kafka连接不包括在Kafka提供的tarball。
我转而使用confluent平台,而connect使用tarball非常有效:
http://www.confluent.io/developer#download