検索

第32章 Kafka Source

download PDF

Kafka トピックからデータを受信します。

32.1. 設定オプション

次の表は、kafka-source Kameletで利用できる設定オプションをまとめたものです。

プロパティーName (名前)詳細デフォルト

Topic *

トピック名

Kafka トピック名のコンマ区切りリスト

string

  

bootstrapServers *

ブローカー

Kafka Broker URL のコンマ区切りリスト

string

  

securityProtocol

セキュリティープロトコル

ブローカーとの通信に使用されるプロトコル。SASL_PLAINTEXT、PLAINTEXT、SASL_SSL、および SSL がサポートされます。

string

"SASL_SSL"

 

saslMechanism

SASL メカニズム

使用される Simple Authentication and Security Layer(SASL)メカニズム。

string

"PLAIN"

 

user *

ユーザ名

Kafka に対して認証を行うためのユーザー名

string

  

Password *

パスワード

kafka に対して認証を行うためのパスワード

string

  

autoCommitEnable

自動コミットの有効化

true の場合、コンシューマーによってすでにフェッチされたメッセージのオフセットを ZooKeeper に定期的にコミットします。

ブール値

true

 

allowManualCommit

手動コミットを許可する

手動コミットを許可するかどうか。

ブール値

false

 

autoOffsetReset

自動オフセットリセット

初期オフセットがない場合のアクション。列挙は 3 つあり、値は latest、earliest、none のいずれかです。

string

"latest"

 

pollOnError

poll On エラー動作

新しいメッセージのポーリング中に、kafka が例外をスローした場合のアクション。5 つの列挙があり、値は DISCARD、ERROR_HANDLER、RECONNECT、RETRY、STOP のいずれかです。

string

"ERROR_HANDLER"

 

deserializeHeaders

ヘッダーの自動デシリアライズ

Kamelet ソースを有効にすると、すべてのメッセージヘッダーが String 表現にデシリアライズされます。デフォルトは false です。

ブール値

true

 
注記

アスタリスク(*)のマークが付いたフィールドは必須です。

Red Hat logoGithubRedditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

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

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

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

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

会社概要

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

© 2024 Red Hat, Inc.