unfortunately i cannot reproduce, this happens every now and then
On Thu, Apr 12, 2012 at 5:01 PM, Jun Rao (Commented) (JIRA) <j...@apache.org> wrote: > > [ > https://issues.apache.org/jira/browse/KAFKA-331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13252476#comment-13252476 > ] > > Jun Rao commented on KAFKA-331: > ------------------------------- > > The producer is thread safe. Are you using the sync or the async mode in the > producer? Do you have a simple test that can reproduce this? > >> 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 is automatically generated by JIRA. > If you think it was sent incorrectly, please contact your JIRA > administrators: > https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa > For more information on JIRA, see: http://www.atlassian.com/software/jira > >
