【新人贴求助】kafkaChannel实践遇到的问题

看到1.6版本支持kafkaChannel想用下，但是只要配置了sink就会报错，配置如下：

flume配置

报错信息：

报错信息

试了很多办法都没能解决，求助

楼主kafka 集群是否正常

atsky123 发表于 2016-2-19 11:18
楼主kafka 集群是否正常

我都布在一台机器上的，如果把sink注视掉，kafka consumer 是可以收到数据的

下面类似，仅供楼主参考，多做测试
kafkaChannel和kafkaSink如何配合使用？
http://www.aboutyun.com/forum.php?mod=viewthread&tid=13602

xuanxufeng 发表于 2016-2-19 18:09
下面类似，仅供楼主参考，多做测试
kafkaChannel和kafkaSink如何配合使用？
http://www.aboutyun.com/for ...

额....这个我看过了，官方文档写的是可以使用的

问题已经解决了，晕死了，用度娘搜了好几天也没有找到解决办法，今天用google搜了一下下，就解决了，哎~~

出现这个问题是因为kafkaChannel需要用到zookeeper.jar这个jar包，只要把这个放到flume的lib下就OK了
参考连接：https://issues.apache.org/jira/browse/FLUME-2735

问题已经解决了，晕死了，用度娘查了好久都没查到，今天用google查了一下下就解决了，哎·~~差距啊，度娘全是广告，google更实用，期待google重回内陆

解决方法：将 zookeeper.jar拷贝到flume的lib路径即可，因为kafkaChannel需要用到这个jar包
参考连接：https://issues.apache.org/jira/browse/FLUME-2735

guoxiaokai527 发表于 2016-2-22 09:22
额....这个我看过了，官方文档写的是可以使用的

问题已经解决了，晕死了，用某度查了好久都没查到，今天用某goo查了一下下就解决了，哎·~~差距啊，某度全是广告，某goo更实用，期待某goo重回内陆

解决方法：将 zookeeper.jar拷贝到flume的lib路径即可，因为kafkaChannel需要用到这个jar包
参考连接：https://issues.apache.org/jira/browse/FLUME-2735