Hi,
During the running of Samza, one of brokers in our Kafka cluster went
down, the states of relative topics are shown as pictures below. Then all the
task can’t fetch any messages any more, even after restarted the samza job. But
at the same time , another app consuming the same topic which using high level
api can still fetch messages as before.
After delete the relative topics and the broker went down was up again,
the samza job can fetch messages as normal.
Thanks for your help.
————————
ShuQi
