[
https://issues.apache.org/jira/browse/KAFKA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13942947#comment-13942947
]
Michael Noll edited comment on KAFKA-1310 at 3/21/14 10:23 AM:
---------------------------------------------------------------
Also, I can confirm the errors above do not occur with Kafka 0.8.0, using the
following test commands:
{code}
$ bin/kafka-create-topic.sh --topic testing --zookeeper zookeeper1:2181
--partition 1 --replica 1
creation succeeded!
$ bin/kafka-list-topic.sh --zookeeper zookeeper1:2181
topic: testing partition: 0 leader: 0 replicas: 0 isr: 0
# Trying to produce data works!
$ bin/kafka-console-producer.sh --topic testing --broker-list localhost:9092
foo
^C
$ bin/kafka-console-consumer.sh --topic testing --zookeeper zookeeper1:2181
--from-beginning
foo
{code}
was (Author: miguno):
Also, I can confirm the errors above do not occur with Kafka 0.8.0, using the
following test commands:
{code}
$ bin/kafka-create-topic.sh --topic testing --zookeeper zookeeper1:2181
--partition 1 --replica 1
creation succeeded!
$ bin/kafka-list-topic.sh --zookeeper zookeeper1:2181
topic: testing partition: 0 leader: 0 replicas: 0 isr: 0
# Trying to produce dat works!
$ bin/kafka-console-producer.sh --topic testing --broker-list localhost:9092
foo
^C
$ bin/kafka-console-consumer.sh --topic testing --zookeeper zookeeper1:2181
--from-beginning
foo
{code}
> Zookeeper timeout causes deadlock in Controller
> -----------------------------------------------
>
> Key: KAFKA-1310
> URL: https://issues.apache.org/jira/browse/KAFKA-1310
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8.1
> Reporter: Fedor Korotkiy
> Assignee: Neha Narkhede
> Priority: Blocker
>
> Steps to reproduce:
> 1. Checkout and build 0.8.1 branch from github:
> git clone [email protected]:apache/kafka.git && cd kafka && git checkout
> origin/0.8.1 && ./gradlew jar
> 2. Start zookeeper server:
> ./bin/zookeeper-server-start.sh config/zookeeper.properties
> 3. Start kafka server:
> ./bin/kafka-server-start.sh config/server.properties
> 4. Suspend zookeeper process for 10 seconds (ctrl-Z, then %1).
> 5. And kafka hasn't been re-registered in zookeeper.
> ./bin/zookeeper-shell.sh
> ls /brokers/ids
> >> []
> Root cause of the problem seems to be the deadlock between DeleteTopicsThread
> and SessionExpirationListener in KafkaController.
> 1. DeleteTopicsThread acquires controllerLock and await()-s on
> deleteTopicsCond in awaitTopicDeletionNotification()
> 2. SessionExpirationListener fires. It acquires controllerLock and tries to
> shutdown deleteTopicManager(in onControllerResignation()). This interrupts
> DeleteTopicsThread.
> 3. DeleteTopicsThread can't return from deleteTopicsCond.await() because
> controllerLock is taken. We got a deadlock.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
