第33章 Kafka Sink

データを Kafka トピックに送信します。

Kamelet は、設定するヘッダーについて理解することができます。

  • key/ce-key: メッセージキーとして
  • partition-key/ce-partitionkey: メッセージパーティションキーとして

ヘッダーはいずれもオプションです。

33.1. 設定オプション

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

プロパティー名前説明デフォルト

bootstrapServers *

ブローカー

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

string

  

Password *

Password

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

string

  

Topic *

トピック名

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

string

  

user *

Username

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

string

  

saslMechanism

SASL メカニズム

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

string

"PLAIN"

 

securityProtocol

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

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

string

"SASL_SSL"

 
注記

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