Apache Kafka
ツリー内で右クリック ▸ 追加 ▸ Kafka リクエスト。
| フィールド | 役割 |
|---|---|
| URL | カンマ区切りのブローカーのリスト：hote1:9092,hote2:9092 — 文字列全体が分割される前に Handlebars で解決されます |
| クライアント識別子 | ブローカーに通知される clientId |
| トピック | トピック名。モードを問わず使われます |
| モード | produce、consume、browse |
| フィールド | 値 |
|---|---|
| SASL メカニズム | none、plain、scram-sha-256、scram-sha-512 |
| SASL ユーザー / SASL パスワード | パスワードには シークレット 型の値を指定できます |
| TLS | 独立して有効化できます — SASL なしの TLS ブローカーは none メカニズムで動作します |
produce モード
Section titled “produce モード”キー、値、レコードヘッダー、そして必要に応じてパーティションを指定します。 パーティションを明示しない場合は、クライアントライブラリの既定のパーティショナーが使われます。 レスポンスには、書き込まれたレコードのメタデータ（トピック、パーティション、オフセット）が返されます。
consume モード
Section titled “consume モード”| フィールド | 役割 |
|---|---|
| グループ | コンシューマーの groupId |
| 開始オフセット | earliest、latest、specific |
| 特定のオフセット | 文字列で指定します — Kafka のオフセットは 64 ビット整数です |
| パーティション | クライアント側のフィルターです。パーティションの割り当ては引き続きグループが行います |
browse モード
Section titled “browse モード”コンシューマーグループを使わずにパーティションを検査します。 Restorm は上限を決めた数のメッセージを取り出し、その後接続を切ります。 このモードではパーティションの指定が必須です。
グループを作らずオフセットも動かさずに、トピックの中身を覗きたいときに適したツールです。
シナリオでの利用
Section titled “シナリオでの利用”- Kafka プロデュース — 単発のアクションで、レコードのメタデータを返します。
- Kafka コンシューム — コンシューマーグループ経由で購読し、メッセージごとにイベントを発行します。
- Kafka 接続を閉じる — コンシュームを停止します。
接続とストリーミングを参照してください。
コードスニペット
Section titled “コードスニペット”5 つのターゲットがあります。JavaScript（kafkajs。プロデュースとコンシューム）と
kcat（プロデュース、コンシューム、グループなしの検査）。