Re: automatic topic creation question

Hi, I see a single partition for the newly created topic, and it has only one replica. Is there a way to specify a replication factor greater than 1? you can set default.replication.factor config property, This property is used to set default replication factor for auto created topics.

Re: LeaderNotAvailableException, although leader elected

AFAIK not topics, but only partitions of topics have leaders. What controllers do you mean? I haven't read about such. Thanks for the explanation regarding the metadata request, in the meantime I found out that this is an expected (!) failure

[jira] [Commented] (KAFKA-899) LeaderNotAvailableException the first time a new message for a partition is processed.

[ https://issues.apache.org/jira/browse/KAFKA-899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150648#comment-14150648 ] Andras Hatvani commented on KAFKA-899: -- This isn't fixed in 0.8.1.1 as the behavior is

[jira] [Comment Edited] (KAFKA-899) LeaderNotAvailableException the first time a new message for a partition is processed.

[ https://issues.apache.org/jira/browse/KAFKA-899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150648#comment-14150648 ] Andras Hatvani edited comment on KAFKA-899 at 9/27/14 4:13 PM:

[jira] [Commented] (KAFKA-1494) Failed to send messages after 3 tries.

[ https://issues.apache.org/jira/browse/KAFKA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150650#comment-14150650 ] Andras Hatvani commented on KAFKA-1494: --- As a workaround increase retry.backoff.ms

[jira] [Commented] (KAFKA-1419) cross build for scala 2.11

[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150693#comment-14150693 ] Dan Di Spaltro commented on KAFKA-1419: --- [~herriojr] It looks like the patchfile

[jira] [Commented] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent commented on KAFKA-1387: --- I have seen this issue in our QA environment (3

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 2:47 AM: I

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 2:50 AM: I

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 2:51 AM: I

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 2:50 AM: I

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 2:57 AM: I

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 3:02 AM: I

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 3:05 AM: I

[jira] [Comment Edited] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14150883#comment-14150883 ] James Lent edited comment on KAFKA-1387 at 9/28/14 3:05 AM: I