Kafka Connectのシンクとソースの設計方法

Question

トピックを購読し、メッセージを変換し、変換されたメッセージを別のトピックに戻すKafka-Connectorを開発しています。

これまではSinkTaskクラスとして実装しており、各タスクはETLを実行し、パブリッシャオブジェクトをインスタンス化し、メッセージを別のトピックに書き戻します。

これを実装するクリーナーの方法はありますか？私は、これがコネクターがシンクでもソースでもある一般的な使用例だと考えています。

Answer 1

これはKafka Connectの基本的な使用例ではありません。すでにKafka 0.10.xをご利用の場合は、新しいKafka Streams APIが作成されました。