0熱
1答えて
カフカのトピックから利用可能なすべてのメッセージが消費された後に、どのように将来のメッセージリストを返すのですか?
アッカカフカストリームsupervison戦略は、私がアッカストリームカフカのアプリケーションを実行していると私は、そのようなブローカーがダウンして、ストリームの消費者は、停止タイムアウト後に死亡した場合、そのストリームの消費者の監督の戦略を組み込みたい
NoSuchMethodError:KafkaConsumer.subscribe