Hi,

I'm upgrading a kafka streams application from 0.10.2.1 to 0.11.0.1,
running against a kafka cluster with version 0.10.2.1. The application uses
a couple of state stores.

When stopping/starting the application prior to the upgrade (with 0.10.2.1
client) on 2 instances, it was up and running in less than 30s to a minute
on all nodes. However, after client was upgraded to 0.11.0.1, when the
instances started (during some load), it took about 6 minutes for one of
the nodes to reach "RUNNING" state, and the second one didn't get there.
After 10 minutes I had to roll back.

Is it expected that this initial rebalancing takes a little longer with
0.11.0.1, and is there a way to configure or tweak the client, or otherwise
optimize this to make this go faster?

Thanks,
Johan

Reply via email to