Brent Bradbury created KAFKA-1315: ------------------------------------- Summary: log.dirs property in KafkaServer intolerant of trailing slash Key: KAFKA-1315 URL: https://issues.apache.org/jira/browse/KAFKA-1315 Project: Kafka Issue Type: Bug Affects Versions: 0.8.0, 0.8.1 Reporter: Brent Bradbury
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-...@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 -- This message was sent by Atlassian JIRA (v6.2#6252)