Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1315

log.dirs property in KafkaServer intolerant of trailing slash

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Fixed
    • 0.8.0, 0.8.1
    • 0.8.1.1
    • None

    Description

      A trailing slash in log.dirs causes a java.util.NoSuchElementException on the producer and a kafka.common.NotLeaderForPartitionException on the consumer.

      Per this thread: http://mail-archives.apache.org/mod_mbox/kafka-users/201307.mbox/%3CCAFbh0Q18PLacokCBy8+JG6Ef3N8+ysGKfqGhW4YB2Up18H-Eew@mail.gmail.com%3E

      This is because we populate the key in
      ReplicaManager.highWatermarkCheckpoints using the "dirs" config, but look
      up the key using log.dir.getParent. So, if you have a trailing slash in the
      config, they won't match. This seems a bug that we should fix. Could you
      file a jira?

      Thanks,

      Jun

      Still occuring for me, using org.apache.kafka:kafka_2.10:0.8.1

      Attachments

        1. KAFKA-1315_2014-03-20_13:28:06.patch
          6 kB
          Timothy Chen
        2. KAFKA-1315_2014-03-20_14:03:34.patch
          6 kB
          Timothy Chen
        3. KAFKA-1315.patch
          7 kB
          Timothy Chen

        Issue Links

          Activity

            People

              tnachen Timothy Chen
              brentbradbury Brent Bradbury
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: