[ https://issues.apache.org/jira/browse/KAFKA-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Igor Artamonov updated KAFKA-1966: ---------------------------------- Description: 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} was: Created a fresh {{test}} topic by using {{kafka-console-producer.sh}}, but Kafka fails to process this topic. 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} > 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)