[jira] [Resolved] (KAFKA-331) recurrent produce errors

["Jay Kreps (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jay Kreps resolved KAFKA-331.
-----------------------------
    Resolution: Incomplete

> recurrent produce errors
> ------------------------
>
>                 Key: KAFKA-331
>                 URL: https://issues.apache.org/jira/browse/KAFKA-331
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Pierre-Yves Ritschard
>
> I am using trunk and regularily see such errors popping up:
> 32477890 [kafka-processor-7] ERROR kafka.server.KafkaRequestHandlers  - Error processing ProduceRequest on pref^@^@^@:0
> java.io.FileNotFoundException: /mnt/kafka/logs/pref^@^@^@-0/00000000000000000000.kafka (Is a directory)
>         at java.io.RandomAccessFile.open(Native Method)
>         at java.io.RandomAccessFile.<init>(RandomAccessFile.java:233)
>         at kafka.utils.Utils$.openChannel(Utils.scala:324)
>         at kafka.message.FileMessageSet.<init>(FileMessageSet.scala:75)
>         at kafka.log.Log.loadSegments(Log.scala:144)
>         at kafka.log.Log.<init>(Log.scala:116)
>         at kafka.log.LogManager.createLog(LogManager.scala:149)
>         at kafka.log.LogManager.getOrCreateLog(LogManager.scala:204)
>         at kafka.server.KafkaRequestHandlers.kafka$server$KafkaRequestHandlers$$handleProducerRequest(KafkaRequestHandlers.scala:69)
>         at kafka.server.KafkaRequestHandlers.handleProducerRequest(KafkaRequestHandlers.scala:53)
>         at kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$1.apply(KafkaRequestHandlers.scala:38)
>         at kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$1.apply(KafkaRequestHandlers.scala:38)
>         at kafka.network.Processor.handle(SocketServer.scala:296)
>         at kafka.network.Processor.read(SocketServer.scala:319)
>         at kafka.network.Processor.run(SocketServer.scala:214)
>         at java.lang.Thread.run(Thread.java:679)
> 32477890 [kafka-processor-7] ERROR kafka.network.Processor  - Closing socket for /xx.xx.xx.xx because of error
> java.io.FileNotFoundException: /mnt/kafka/logs/pref^@^@^@-0/00000000000000000000.kafka (Is a directory)
>         at java.io.RandomAccessFile.open(Native Method)
>         at java.io.RandomAccessFile.<init>(RandomAccessFile.java:233)
>         at kafka.utils.Utils$.openChannel(Utils.scala:324)
>         at kafka.message.FileMessageSet.<init>(FileMessageSet.scala:75)
>         at kafka.log.Log.loadSegments(Log.scala:144)
>         at kafka.log.Log.<init>(Log.scala:116)
>         at kafka.log.LogManager.createLog(LogManager.scala:149)
>         at kafka.log.LogManager.getOrCreateLog(LogManager.scala:204)
>         at kafka.server.KafkaRequestHandlers.kafka$server$KafkaRequestHandlers$$handleProducerRequest(KafkaRequestHandlers.scala:69)
>         at kafka.server.KafkaRequestHandlers.handleProducerRequest(KafkaRequestHandlers.scala:53)
>         at kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$1.apply(KafkaRequestHandlers.scala:38)
>         at kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$1.apply(KafkaRequestHandlers.scala:38)
>         at kafka.network.Processor.handle(SocketServer.scala:296)
>         at kafka.network.Processor.read(SocketServer.scala:319)
>         at kafka.network.Processor.run(SocketServer.scala:214)
>         at java.lang.Thread.run(Thread.java:679)
> This results in a "pref" directory created inside the log dir. The original topic should be prefix, somehow a NUL gets inserted there.
> The producing was done with a kafka.javaapi.producer.Producer instance, on which send was called with a kafka.javaapi.producer.ProducerData instance.
> There are no log entries created inside that dir and no impact on the overall operation of the broker operations and consumers.
> Is the producer thread-safe ?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)