Failed to find any class that implements Connector and which name matches FileStream-Source

2023-01-28 Thread Hieu Nguyen
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 conne

Re: Failed to find any class that implements Connector and which name matches FileStream-Source

2023-01-28 Thread Gregory Harris
Hieu, The FileStreamSource and FileStreamSink (no hyphen) connectors are no longer included on the classpath by default since minor version 3.2.0 (and some earlier patch releases) due to security concerns. See the release notes that mention this, and contain a workaround here: https://kafka.apache

Re: Failed to find any class that implements Connector and which name matches FileStream-Source

2023-01-28 Thread Hieu Nguyen
OK, I've made it work. Steps to fix: + Build https://github.com/a0x8o/kafka + Collect the "connect-file-3.5.0-SNAPSHOT.jar" + Update the "plugin.path" in "connect-distributed.properties" to the directory containing that jar file + Start Kafka Connect + The connect