I'm not an expert but I prefer keeping zookeepers on the same hosts as
kafka brokers and mimic each-others topology. The reason is to minimize
the chance of e.g. kafka brokers being able to talk to one another but
zookeepers not, or vice-versa. So, I'd say I /do/ want my kafka broker
and the co
Hi Matthias,
Ok, that clarifies quite a bit. I never really went into the timestamp
aspects, as time does not really play a role in my application (aside from
the repartition topics, I have no KStreams or Windowed operation, just
different kind of KTable join).
I do think that the fail case I see
Unless you're experiencing any connection issues then I would say this is a
benign warning message.
Essentially what it's saying here is that the connection was closed (broken
pipe) before it (wherever you're getting the log from) was able to send the
last close_notify message. When one party deci
Could not agree more!
But then I think the easiest is still: print exception and die.
From there on its the easiest way forward: fix, redeploy, start => done
All the other ways to recover a pipeline that was processing partially
all the time
and suddenly went over a "I cant take it anymore" thr
