Re: Kafka 0.8 delete log failed

2013-12-11 Thread CuiLiang
I tried the sample code and it works. I also can delete the old index file manually. Thanks, Liang Cui 2013/12/12 Jay Kreps > Is the path d:\kafka-logs\test001-0\00507600.index correct? > > The tricky thing here is we don't have access to windows for testing so we > will need a bit

Re: Kafka 0.8 delete log failed

2013-12-11 Thread Jay Kreps
Is the path d:\kafka-logs\test001-0\00507600.index correct? The tricky thing here is we don't have access to windows for testing so we will need a bit more help for debugging. If you write a simple Java program that does System.out.println(new File("d:\kafka-logs\test001-0\ 0

Re: Kafka 0.8 delete log failed

2013-12-11 Thread CuiLiang
Update this issue. I update the log config to log.dirs=\\kafka-logs. The log file is deleted but still can't delete the index file. I got below error message. [2013-12-11 00:07:59,671] INFO Deleting index d:\kafka-logs\test001-0\00507600.index (kafka.log.OffsetIndex) [2013-12-11 00:07:

Re: Kafka 0.8 delete log failed

2013-12-10 Thread CuiLiang
The Kafka folder is d:\kafka_2.8.0-0.8.0. Kafka log folder is d:\data\kafka-logs. kafka batch folder is d:\kafka_2.8.0-0.8.0\bin. log.dirs=..\\..\\data\\kafka-logs The log segments files is created correct, but can't delete the log file. My machine has C, D, E,F, G, k partitions. Thanks, Liang Cu

Re: Kafka 0.8 delete log failed

2013-12-10 Thread Jay Kreps
What is your configuration for data.dirs (the path where data is) and what is the set of disks/volumes on the machine? -Jay On Tue, Dec 10, 2013 at 12:50 AM, CuiLiang wrote: > Hi All, > > I'm use Kafka 0.8 release build with 1 partition, 1 replica. My OS is > Windows server 2012 and JDK is 1.7

Kafka 0.8 delete log failed

2013-12-10 Thread CuiLiang
Hi All, I'm use Kafka 0.8 release build with 1 partition, 1 replica. My OS is Windows server 2012 and JDK is 1.7. I got below error when Kafka delete logs. Any guidance would be of great help. [2013-12-09 04:00:10,525] ERROR error in loggedRunnable (kafka.utils.Utils$)kafka.common.KafkaStorageExc