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