Re: [DISCUSS] KIP-78: Cluster Id

Hey Sumit, I have no doubt that there are benefits with using tags. But the usage of tags is actually orthogonal to the usage of cluster.id. I am not sure the benefits of using tags that you provided can help us decide whether randomly generated cluster.id is better than readable cluster.id from

[jira] [Created] (KAFKA-4122) Consumer startup swallows DNS resolution exception and infinitely retries

Shane Hender created KAFKA-4122: --- Summary: Consumer startup swallows DNS resolution exception and infinitely retries Key: KAFKA-4122 URL: https://issues.apache.org/jira/browse/KAFKA-4122 Project: Kafka

Re: [DISCUSS] KIP-78: Cluster Id

Hi Dong, Please find my comments inline. Hopefully they address your concerns. Have a great weekend ! Sumit On Sat, Sep 3, 2016 at 3:17 PM, Dong Lin wrote: > Hi Sumit, > > Please see my comments inline. > > On Sat, Sep 3, 2016 at 10:33 AM, sumit arrawatia < >

[DISCUSS] KIP-78: Cluster Id

Hi Sumit, Please see my comments inline. On Sat, Sep 3, 2016 at 10:33 AM, sumit arrawatia wrote: > Hi Dong, > > Please see my comments inline. > > Sumit > > On Sat, Sep 3, 2016 at 9:26 AM, Dong Lin wrote: > > > Hey Sumit, > > > > Thanks Sumit

[jira] [Updated] (KAFKA-4121) Allow creating broker listeners from hostname

[ https://issues.apache.org/jira/browse/KAFKA-4121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joaquin Casares updated KAFKA-4121: --- Description: I'm attempting to start a docker container using the parameter: {CODE}

[jira] [Created] (KAFKA-4121) Allow creating broker listeners from hostname

Joaquin Casares created KAFKA-4121: -- Summary: Allow creating broker listeners from hostname Key: KAFKA-4121 URL: https://issues.apache.org/jira/browse/KAFKA-4121 Project: Kafka Issue Type:

Re: [VOTE] KIP-77: Improve Kafka Streams Join Semantics

This vote is now closed. KIP-77 is accepted with +3 (binding) +5 (non-binding) Thanks for voting and feedback! -Matthias On 08/31/2016 06:16 PM, Jim Jagielski wrote: > +1 > >> On Aug 29, 2016, at 5:50 AM, Matthias J. Sax wrote: >> >> I’d like to initiate the voting

[jira] [Created] (KAFKA-4120) byte[] keys in RocksDB state stores do not work as expected

Greg Fodor created KAFKA-4120: - Summary: byte[] keys in RocksDB state stores do not work as expected Key: KAFKA-4120 URL: https://issues.apache.org/jira/browse/KAFKA-4120 Project: Kafka Issue

Re: [DISCUSS] KIP-78: Cluster Id

Hi Dong, Please see my comments inline. Sumit On Sat, Sep 3, 2016 at 9:26 AM, Dong Lin wrote: > Hey Sumit, > > Thanks Sumit for your explanation. It seems that the concern is that we can > not easily change cluster.id if we read this from config. Maybe the KIP > should

Re: [DISCUSS] KIP-78: Cluster Id

Hi Flavio, I have added some comments inline based on my understanding of the implementation but Ismael probably can add more to this from an architectural perspective. Cheers, Sumit On Sat, Sep 3, 2016 at 8:48 AM, Flavio Junqueira wrote: > Thanks for the KIP, Ismael, looks

Re: [DISCUSS] KIP-78: Cluster Id

Hey Sumit, Thanks Sumit for your explanation. It seems that the concern is that we can not easily change cluster.id if we read this from config. Maybe the KIP should also specify the requirement for users to change the cluster.id. But it seems to me that it is equally straightforward to change

Re: [DISCUSS] KIP-78: Cluster Id

Thanks for the KIP, Ismael, looks great. I have just a couple of comments and questions: - I assume the znode containing the cluster id is persistent. Is there ever the need to delete that znode to force a new instance id, and if so, how is it expected to happen? I'm thinking about a scenario

[jira] [Updated] (KAFKA-4119) Get topic offset with Kafka SSL

[ https://issues.apache.org/jira/browse/KAFKA-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhang shuai updated KAFKA-4119: --- Description: I have a kafka cluster with SSL when i trun off ACL,i can get offset form

Re: [DISCUSS] KIP-78: Cluster Id

Hi Dong, If you set the cluster.id in the config, the problem is how you change/update the cluster.id . You will need to change the all the config files and make sure every one of them is correct as well as update the ZK metadata. This will require a reboot/downtime of the entire cluster,

[jira] [Created] (KAFKA-4119) Get topic offset with Kafka SSL

zhang shuai created KAFKA-4119: -- Summary: Get topic offset with Kafka SSL Key: KAFKA-4119 URL: https://issues.apache.org/jira/browse/KAFKA-4119 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-78: Cluster Id

Hey Ismael, Thanks for your reply. Please see my comment inline. On Fri, Sep 2, 2016 at 8:28 PM, Ismael Juma wrote: > Hi Dong, > > Thanks for your feedback. Comments inline. > > On Thu, Sep 1, 2016 at 7:51 PM, Dong Lin wrote: > > > > I share the view