[ https://issues.apache.org/jira/browse/KAFKA-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Neha Narkhede resolved KAFKA-1966. ---------------------------------- Resolution: Won't Fix It is easier to discuss these types of issues on the mailing list and create a JIRA if it is determined to be something that should be fixed in kafka. > Cannot read just created index > ------------------------------ > > Key: KAFKA-1966 > URL: https://issues.apache.org/jira/browse/KAFKA-1966 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8.2.0 > Environment: Docker "FROM dockerfile/ubuntu" > Oracle Java 1.7.0_72 > Kafka Scala 2.11 > Kafka 0.8.2.0 > Reporter: Igor Artamonov > Priority: Critical > > Created a fresh {{test}} topic by using {{kafka-console-producer.sh}}, but > Kafka fails to process this topic: > {code} > WARN Failed to send producer request with correlation id 24 to broker 1 with > data for partitions [test,0] (kafka.producer.async.DefaultEventHandler) > java.io.IOException: Broken pipe > at sun.nio.ch.FileDispatcherImpl.writev0(Native Method) > at sun.nio.ch.SocketDispatcher.writev(SocketDispatcher.java:51) > at sun.nio.ch.IOUtil.write(IOUtil.java:148) > at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:524) > at java.nio.channels.SocketChannel.write(SocketChannel.java:493) > at > kafka.network.BoundedByteBufferSend.writeTo(BoundedByteBufferSend.scala:56) > at kafka.network.Send$class.writeCompletely(Transmission.scala:75) > at > kafka.network.BoundedByteBufferSend.writeCompletely(BoundedByteBufferSend.scala:26) > at kafka.network.BlockingChannel.send(BlockingChannel.scala:92) > at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:72) > {code} > Cannot receive it using {{kafka-console-receiver.sh}} too, getting infinite: > {code} > WARN > [console-consumer-65093_a3607751fab8-1424346729085-3a3736f8-leader-finder-thread], > Failed to add leader for partitions [test,0],[test,1]; will retry > (kafka.consumer.ConsumerFetcherManager$LeaderFinderThread) > kafka.common.NotLeaderForPartitionException > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) > at > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) > at > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > at java.lang.reflect.Constructor.newInstance(Constructor.java:526) > at java.lang.Class.newInstance(Class.java:379) > at kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:73) > at > kafka.consumer.SimpleConsumer.earliestOrLatestOffset(SimpleConsumer.scala:160) > {code} > Even cannot read the index: > {code} > kafka-run-class.sh kafka.tools.DumpLogSegments --files > /kafka-logs/test-0/00000000000000000000.index --deep-iteration > Dumping /kafka-logs/test-0/00000000000000000000.index > Exception in thread "main" java.io.IOException: Invalid argument > at sun.nio.ch.FileChannelImpl.map0(Native Method) > at sun.nio.ch.FileChannelImpl.map(FileChannelImpl.java:874) > at kafka.log.OffsetIndex.<init>(OffsetIndex.scala:74) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)