これは、Ubuntu Online、Fedora Online、Windows オンライン エミュレーター、または MAC OS オンライン エミュレーターなどの複数の無料オンライン ワークステーションの XNUMX つを使用して、OnWorks 無料ホスティング プロバイダーで実行できるコマンド kafkacat です。
プログラム:
NAME
カフカキャット — Apache Kafka の汎用プロデューサーおよびコンシューマー
SYNOPSIS
カフカキャット -C | -P | -L -t トピック [-p パーティション] -b ブローカー [, ...] [-D デリム] [-K デリム]
[-c cnt] [-X リスト] [-X プロパティ=値] [-X ダンプ] [-d dbgの [, ...]][-q] [-v] [-Z]
【具体的なオプション】
カフカキャット -C [一般的なオプション] [-o オフセット] [-e] [-O] [-u] [-J] [-f fmtstr]
カフカキャット -P [一般的なオプション] [-z スナッピー | gzip] [-p -1][file [...]]
カフカキャット -L [一般的なオプション] [-t トピック]
DESCRIPTION
カフカキャット これは、Apache Kafka 0.8 の汎用の非 JVM プロデューサーおよびコンシューマーであり、
Kafka 用の netcat。
プロデューサーモードでは( -P ), カフカキャット 構成可能な文字列で区切られたメッセージを標準入力から読み取ります。
区切り文字を使用して、提供された Kafka クラスター、トピック、およびパーティションにそれらを生成します。 消費者において
モード( -C ), カフカキャット トピックとパーティションからメッセージを読み取り、stdout に出力します。
構成されたメッセージ区切り文字を使用します。
どちらでもない場合 -P or -C 指定されています カフカキャット モードを自動的に理解しようとします
stdin/stdout tty タイプに基づきます。
カフカキャット メタデータ リスト モード ( -L )、現在の状態を表示します。
Kafka クラスターとそのトピックおよびパーティション。
onworks.net サービスを使用してオンラインで kafkacat を使用する