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

>>阅读原文<<