Hentai 发表于 2016-10-9 09:23
我把kafka的jar包放在flume的lib文件夹里面就解决了，我的配置是没有问题的

那就是版本兼容问题了

nextuser 发表于 2016-10-8 21:19
是flume的问题，还是忘了什么配置的原因

我把kafka的jar包放在flume的lib文件夹里面就解决了，我的配置是没有问题的

Hentai 发表于 2016-10-8 09:50
已经解决了

是flume的问题，还是忘了什么配置的原因

nextuser 发表于 2016-10-1 23:56
flume怎么配置的

已经解决了

Hentai 发表于 2016-9-30 11:02
这是我kafka的配置

delete.topic.enable=true

flume怎么配置的

nextuser 发表于 2016-9-30 07:43
楼主把全部的配置都贴出来看下

这是我kafka的配置

delete.topic.enable=true


broker.id=0

port=9092

host.name=10.0.118.208


num.network.threads=3
num.io.threads=8

socket.send.buffer.bytes=102400

socket.receive.buffer.bytes=102400

socket.request.max.bytes=104857600



log.dirs=/tmp/kafka-logs

num.partitions=1

num.recovery.threads.per.data.dir=1



log.retention.hours=168


log.segment.bytes=1073741824


log.retention.check.interval.ms=300000

log.cleaner.enable=false

zookeeper.connect=localhost:2181

zookeeper.connection.timeout.ms=6000

Hentai 发表于 2016-9-29 17:46
按照网上的方式各种改  然而还是无限报这种错，真心无语了

楼主把全部的配置都贴出来看下

按照网上的方式各种改  然而还是无限报这种错，真心无语了

easthome001 发表于 2016-9-29 16:35
这个问题
warn async.defaulteventhandler:failed to send producer request with correlation id 2 to br ...

刚刚试过了 完全没有卵用 我简直无语了