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
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
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
.
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