問題タブ [embedded-kafka]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
scala - Kafka Streams を使用した Scala Embedded Kafka でのプロデューサー エラー
私は、オープン プロデューサー スレッドを気まぐれに残し、継続的なエラー ログを記録するテストを行っています。
テストは機能しますが、上記のように失敗することがあります。
特殊性は、ストリーム アプリケーションが消費元と同じトピックに対して削除イベントを生成することです。
このスイートには 2 つの同様のテストがあります。次のように、sbt でテスト スイートを実行します。
5 回の実行のうち 4 回は、これらのエラーを無期限に投稿する未解決のスレッドを残します。3匹一組で出現するが、その理由も不明。
close() の呼び出し後に遅延を設定しようとしましたが、役に立たないようです。プロデューサースレッドのぶら下がりを避けるには?
apache-kafka - 異なる @StreamListener を持つ 2 つのインスタンス間の埋め込み Kafka 移行状態ストア
Spring Cloud を介してマップされた 2 つのストリーム プロセッサを備えた SpringBoot アプリケーションがあります。各プロセッサには、さまざまなトピック用の独自の @StreamListener があります。1 つのプロセッサが集計データを quarable ステート ストアに書き込みます。@Service (サービスは状態ストアから集計データを取得します) を介してデータを取得するときに、単体テストで問題に直面しています。何らかの理由で時々例外をキャッチします：
org.apache.kafka.streams.errors.InvalidStateStoreException: the state store, recently-played-store, may have migrated to another instance.
at org.apache.kafka.streams.state.internals.QueryableStoreProvider.getStore(QueryableStoreProvider.java:60)
at org.apache.kafka.streams.KafkaStreams.store(KafkaStreams.java:1043)
at org.springframework.cloud.stream.binder.kafka.streams.QueryableStoreRegistry.getQueryableStoreType(QueryableStoreRegistry.java:47)
別のプロセッサから StreamListener を削除すると、すべて正常に安定して動作します。
適切なプロセッサで正確なインスタンスの状態ストアをバインドする方法は?