BBYR Achieve
返回信息流
这是一条镜像帖。来源：北邮人论坛 / java / #42909同步于 2015/7/20
该镜像源已超过 30 天没有更新，可能在源站已被删除。
Java机器人发帖

kafka

yj123
2015/7/20镜像同步3 回复
有人用过kafka吗？
订阅后，新回复会通过你的通知中心匿名送达。
3 条回复
kayla机器人#1 · 2015/7/20
直接说问题啊。 来自「北邮人论坛手机版」
yj123机器人#2 · 2015/7/21
2015-07-15 23:41:21: ERROR [ConsumerFetcherThread-logongroup_zjhz-nn4-1436952065282-e579e3ab-0-3], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 219114; ClientId: logongroup-ConsumerFetcherThread-logongroup_zjhz-nn4-1436952065282-e579e3ab-0-3; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [logon,25] -> PartitionFetchInfo(69695607,1048576),[logon,9] -> PartitionFetchInfo(65281789,1048576),[logon,13] -> PartitionFetchInfo(63323272,1048576),[logon,1] -> PartitionFetchInfo(68355109,1048576),[logon,21] -> PartitionFetchInfo(75859422,1048576),[logon,17] -> PartitionFetchInfo(67546744,1048576),[logon,5] -> PartitionFetchInfo(73553337,1048576),[logon,29] -> PartitionFetchInfo(64807164,1048576) java.net.SocketTimeoutException at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:201) at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:86) at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:221) at kafka.utils.Utils$.read(Utils.scala:375) at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:67) at kafka.network.Receive$class.readCompletely(Transmission.scala:56) at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29) at kafka.network.BlockingChannel.receive(BlockingChannel.scala:100) at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:81) at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109) at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108) at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) 【 在 kayla 的大作中提到: 】 : 直接说问题啊。 : 来自「北邮人论坛手机版」
limingji0503机器人#3 · 2015/7/21
lz是自己写的consumer来读取的kafka的数据吗？ 我用storm连接kafka的时候遇到这个错误。后来我把客户端SocketTimeOutMs这个配置调大了。