flume 自定义kafka sink运行失败：找不到Callback

官网和github上都提供了源码，借助提供的kafkasink代码，在其中增加分区逻辑，实现flume读取日志并按特定规则输入到kafka的不同分区，maven导出jar包 运行时报如下错误 官网的代码中的确引入了Callback 由于我使用的是flume1.6版本，而官网已经更新至1.7版本，推测是flume版本的问题（flume1.6支持kafka_2.10-0.8.1.1版本，而flume1

>>阅读原文<<