Re: Getting the KafkaStream ID

2014-06-11 Thread Bogdan Dimitriu (bdimitri)
get the lag that way. Then, you just need to slow down the iteration on the fast partition. Thanks, Jun On Mon, Jun 9, 2014 at 4:07 AM, Bogdan Dimitriu (bdimitri) bdimi...@cisco.com wrote: Certainly. I know this may not sound like a great idea but I am running out of options here: I¹m

Re: Getting the KafkaStream ID

2014-06-09 Thread Bogdan Dimitriu (bdimitri)
Rao jun...@gmail.com wrote: Could you elaborate on the use case of the stream ID? Thanks, Jun On Fri, Jun 6, 2014 at 2:13 AM, Bogdan Dimitriu (bdimitri) bdimi...@cisco.com wrote: Hello folks, I¹m using Kafka 0.8.0 with the high level consumer and I have a situation where I need to obtain

Getting the KafkaStream ID

2014-06-06 Thread Bogdan Dimitriu (bdimitri)
Hello folks, I’m using Kafka 0.8.0 with the high level consumer and I have a situation where I need to obtain the ID for each of the KafkaStreams that I create. The KafkaStream class has a method called “clientId()” that I expected would give me just that, but unfortunately it returns the name

Re: Getting the KafkaStream ID

2014-06-06 Thread Bogdan Dimitriu (bdimitri)
. Guozhang On Fri, Jun 6, 2014 at 2:13 AM, Bogdan Dimitriu (bdimitri) bdimi...@cisco.com wrote: Hello folks, I¹m using Kafka 0.8.0 with the high level consumer and I have a situation where I need to obtain the ID for each of the KafkaStreams that I create. The KafkaStream class has a method