2016-10-14 5 views
0

私の嵐のトポロジ(2つのスパウトと1つのボルト)では、カフカ・スパウト消費者の1人のためのオフセットが進んでいますが、msgはカフカ・スパウトを介してボルトに送られません。私は嵐の中でその特定の噴出口が放出され、転送されたメッセージが0であることを見ることができます。 私の質問は、消費者がどのように進歩しているのかです、私は動物園のクライアントからの消費者の漸進的な増加を見ることができます。ストーム・カフカ・スパウトがメッセージを出さない

答えて

0

上記の理由は、登録されたシリアライザがkafkaキューからすべてのメッセージを除外していて、スパウトからボルトにメッセージが出力されなかったためです。これはまた、なぜカフカの消費者団体のオフセットが徐々に増加しているのかを説明します。

関連する問題