Returning an error code to the producer when it tries writing to topic being deleted

Hi, When a topic is marked for deletion it gets put into a queue. and then processed by the controller's delete topic thread. It may take a while for the topic to actually get deleted (if a broker hosting one of it's replicas is down), but during that time the producer can continue writing messag

How to move a broker to a new host/ip

Hi! If I change the host.name, or the port properties of a broker, what's the easiest way to get Zookeeper to pick up the changes. Note that that no data is being moved, just the configurations of the broker changes to use a different port, network interface or DNS address. Cheers, Eugene

When to use advertised.host.name ?

The FAQ says: "When a broker starts up, it registers its ip/port in ZK. You need to make sure the registered ip is consistent with what's listed in metadata.broker.list in the producer config. By default, the registered ip is given by InetAddress.getLocalHost.getHostAddress. Typically, this should

[jira] [Comment Edited] (KAFKA-1683) Implement a "session" concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693676#comment-14693676 ] Eugene Miretsky edited comment on KAFKA-1683 at 8/12/15 3:4

[jira] [Comment Edited] (KAFKA-1683) Implement a "session" concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693676#comment-14693676 ] Eugene Miretsky edited comment on KAFKA-1683 at 8/12/15 3:3

[jira] [Comment Edited] (KAFKA-1683) Implement a "session" concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693676#comment-14693676 ] Eugene Miretsky edited comment on KAFKA-1683 at 8/12/15 3:3

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693676#comment-14693676 ] Eugene Miretsky commented on KAFKA-1683: My apologies, didn't word the

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14681149#comment-14681149 ] Eugene Miretsky commented on KAFKA-1683: Would this patch include the abilit

Re: Gauging Interest in adding Encryption to Kafka

ly more preferable. > > Jiangjie (Becket) Qin > > On Thu, Jul 30, 2015 at 12:16 PM, eugene miretsky < > eugene.miret...@gmail.com > > wrote: > > > Hi, > > > > Based on the security wiki page > > <https://cwiki.apache.org/confluence/display/KAF

Gauging Interest in adding Encryption to Kafka

Hi, Based on the security wiki page encryption of data at rest is out of scope for the time being. However, we are implementing encryption in Kafka and would like to see if there is interest in submitting a patch got it. I suppose tha