Kafka バックエンド¶

KafkaBackend インタフェース¶

このクラスは、Kafka バックエンド実装が公開しなければならないメソッドを列挙します。この場合、次のものがあります。

boolean topicExists(String topic) throws Exception;

指定されたトピックが存在するかどうかを取得します。

void createTopic(String topic, int partitions, int replicationFactor);

名前、パーティション数、および複製係数を指定してトピックを作成します。

void send(ProducerRecord<String, String> record);

Kafka にレコードを送信します。レコードはトピック名と送信するデータで構成されます。

KafkaBackendImpl クラス¶

これは上記の KafkaBackend インタフェースを実装する Kafka の便利なバックエンドクラスです。

KafkaBackendImplは、本当にKafkaProducer とAdminUtilsJavaクラスをラップします。

エンコーディングに関しては何も特別なことはありません。Cygnus は一般的に UTF-8 文字セットで動作するため、これはデータがトピックに書き込まれる方法です。Kafka のコンシューマは、読み込んだバイトを UTF-8 に変換する責任があります。