采用的配置如下:
producer.topic=drps_push
bootstrap.servers=192.168.100.118:9092
request.required.acks=1
serializer.class=kafka.serializer.DefaultEncoder
key.serializer=org.apache.kafka.common.serialization.ByteArraySerializer
value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer
linger.ms=10
batch.size=32768
服务控制台一直刷屏:
exception causing close of session 0x0 due to java.io.EOFException (org.apache.zookeeper.server.NIOServerConn)