Hello,
I'm reading the book "Kafka: The Definitive Guide: Real-Time Data and Stream
Processing at Scale" by by Neha Narkhede, Gwen Shapira, and Todd Palino.
In the chapter "Kafka Connect", section "Connector Example: File Source and
File Sink", I run the below command and got the missing connector error.
hieunguyenduc@hieugioi kafka_2.13-3.3.1 % echo '{"name":"load-kafka-config",
"config":{"connector.class":"FileStream-Source","file":"config/server.properties","topic":"kafka-config-topic"}}'
| curl -X POST -d @- http://localhost:8083/connectors --header
"Content-Type:application/json"
{"error_code":500,"message":"Failed to find any class that implements Connector
and which name matches FileStream-Source, available connectors are:
PluginDesc{klass=class
org.apache.kafka.connect.mirror.MirrorCheckpointConnector,
name='org.apache.kafka.connect.mirror.MirrorCheckpointConnector',
version='3.3.1', encodedVersion=3.3.1, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.mirror.MirrorHeartbeatConnector,
name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector',
version='3.3.1', encodedVersion=3.3.1, type=source, typeName='source',
location='classpath'}, PluginDesc{klass=class
org.apache.kafka.connect.mirror.MirrorSourceConnector,
name='org.apache.kafka.connect.mirror.MirrorSourceConnector', version='3.3.1',
encodedVersion=3.3.1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector,
name='org.apache.kafka.connect.tools.MockSinkConnector', version='3.3.1',
encodedVersion=3.3.1, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector,
name='org.apache.kafka.connect.tools.MockSourceConnector', version='3.3.1',
encodedVersion=3.3.1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector,
name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='3.3.1',
encodedVersion=3.3.1, type=source, typeName='source', location='classpath'},
PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector,
name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='3.3.1',
encodedVersion=3.3.1, type=sink, typeName='sink', location='classpath'},
PluginDesc{klass=class
org.apache.kafka.connect.tools.VerifiableSourceConnector,
name='org.apache.kafka.connect.tools.VerifiableSourceConnector',
version='3.3.1', encodedVersion=3.3.1, type=source, typeName='source',
location='classpath'}"}%
How can I fix it?
The part after that says "
If all went well, you should see something along the lines of:
{"schema":{"type":"string","optional":false},"payload":"# Licensed to the
Apache Software Foundation (ASF) under one or more"}
"
I run the command and it shows nothing.
Regards,
Hieu
