参照
JeffZhang简锋的教程进行FlinkonZeppelin的实时Streaming读写数据，学习在Zeppelin中使用Flink的Streaming功能。但在练习过程中，在搭建环境和进行测试数据导入时，出现了问题。由于这个问题在特定环境下出现（CentOS),所以在JeffZhang简锋教程里也没提及，而且在kafkadatagen的作者github里也没提及，下面就这个问题做的探索和解决进行了一一记录，利于同样环境下的同学参考和解决。好了，下面就问题一一说来和对应的解决之道。最后的幕后黑手也是令人惊叹。美国国安局
搭建Kafka并准备数据
首先进行kafka的搭建。按
JeffZhang简锋进行kafka的docker搭建。运行kafka起来后，并进行对应的kafka数据生成。
运行：
curl-XPOST83/connectors-HContent-Type:application/json-HAccept:application/json-d
connect.source.datagen.jsonkafka的docker搭建
问题出现
出现问题：
{error_code:,message:FailedtofindanyclassthatimplementsConnectorandwhichnamematches