Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

66.10. 一時停止可能なコンシューマー

Kafka コンポーネントは一時停止可能なコンシューマーをサポートします。このタイプのコンシューマーは、そのコンポーネントの外部の状態 (外部システムが利用できない場合やその他の一時的な状態など) に基づきデータ消費を一時停止できます。 

from("kafka:topic")
    .pausable(new KafkaConsumerListener(), () -> canContinue()) // the pausable check gets called if the exchange fails to be processed ...
    .routeId("pausable-route")
    .process(this::process) // Kafka consumer will be paused if this one throws an exception ...
    .to("some:destination"); // or this one

この例では、canContinue の結果が false の場合、Kafka の Consumer pause メソッドを呼び出すことで消費メッセージを一時停止できます。

重要

一時停止可能な EIP は、ルートのどこかに 例外が発生 してエクスチェンジが処理されない場合に、サポートメカニズムとして使用するためのものです。具体的には、pausable EIP が呼び出すチェックを使用して、エクスチェンジの処理を妨げる一時的な状態をテストします。

注記

ルートをより適切に制御できるため、ほとんどのユーザーが選択します。

Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

Legal Notice

Theme

© 2026 Red Hatトップに戻る