Also to let you all know I get this error too on server console
log4j:ERROR Failed to rename
[D:\kafka_2.10-0.10.2.0-SNAPSHOT/logs/controller.log] to
[D:\kafka_2.10-0.10.2.0-SNAPSHOT/logs/controller.log.2016-12-15-11].

Looks like related. It seems some central process in new version if failing
to rename files.

Thanks
Sachin


On Wed, Dec 14, 2016 at 10:29 PM, Sachin Mittal <sjmit...@gmail.com> wrote:

> I created a new topic from shell.
> I published some messages to it via java producer thread and consume some
> messages via streams application.
> Then I terminated streams application using ctrl c.
>
> Then I delete the topic via shell.
>
> I get this exception.
>
> [2016-12-14 22:24:43,529] ERROR [KafkaApi-0] Error when handling request
> {controller_id=0,controller_epoch=1,delete_partitions=
> true,partitions=[{topic=test-window-stream,partition=0}]}
> (kafka.server.KafkaApis)
> kafka.common.KafkaStorageException: Failed to rename log directory from
> D:\tmp\kafka-logs\test-window-stream-0 to D:\tmp\kafka-logs\test-window-
> stream-0.b21fedf3f87040c4aa76cd3f96e7bd31-delete
>         at kafka.log.LogManager.asyncDelete(LogManager.scala:451)
>         at kafka.cluster.Partition$$anonfun$delete$1.apply$mcV$sp(
> Partition.scala:164)
>         at kafka.cluster.Partition$$anonfun$delete$1.apply(
> Partition.scala:158)
>         at kafka.cluster.Partition$$anonfun$delete$1.apply(
> Partition.scala:158)
>
> The same process used to delete the topic when using kafka_2.10-0.10.0.1.
> I am right now using  kafka_2.10-0.10.2.0-SNAPSHOT.
>
> Note if I delete same topic before publishing any message then it deletes.
> Looks like some process is keeping a lock on the perpetually.
>
> Thanks
> Sachin
>
>
> On Wed, Dec 14, 2016 at 12:44 AM, Apurva Mehta <apu...@confluent.io>
> wrote:
>
>> How are you trying to delete the topic? Next time this occurs, can you
>> check whether the process has permissions to perform that operation?
>>
>> On Mon, Dec 12, 2016 at 10:55 PM, Sachin Mittal <sjmit...@gmail.com>
>> wrote:
>>
>> > Hi,
>> > I recently built an application from source and I get the following
>> > exception when trying to delete a topic
>> >
>> > kafka.common.KafkaStorageException: Failed to rename log directory from
>> > D:\tmp\kafka-logs\test-window-stream-0 to
>> > D:\tmp\kafka-logs\test-window-stream-0.0ce9f9150000431397d1c2dad4f535
>> > a3-delete
>> >         at kafka.log.LogManager.asyncDelete(LogManager.scala:451)
>> >         at
>> > kafka.cluster.Partition$$anonfun$delete$1.apply$mcV$sp(
>> > Partition.scala:164)
>> >
>> >
>> > Note that I have set delete.topic.enable=true
>> >
>> > Also this was all working fine when using kafka_2.10-0.10.0.1.
>> > Issue happens with kafka_2.10-0.10.2.0-SNAPSHOT
>> >
>> > Thanks
>> > Sachin
>> >
>>
>
>

Reply via email to