Kafka Connect JDBC Connectorと呼ばれるオープン ソース プロジェクトには、 JDBCSourceConnectorとJDBCSourceTaskの関係を理解しようとしている 2 つのクラスがあります。
スレッドとして動作する 1 つ以上のタスクがすべて並行してデータベースをポーリングしている可能性があるため、タスク オブジェクトがデータベース接続を行う理由を理解できます。私が理解できないのは、1 つのスレッドのみを使用したい場合にタスクを使用してそれを行うことができるのに、Connector クラスに同じ接続ロジックを使用する理由です。
接続ロジックを変更する分岐バージョンを書いているので、これは私に関係があります。まだ特定していない何らかの理由で、コネクタ データベース接続を維持することを検討する必要があるかどうかを知りたいです。タスク接続ロジックを既に変更しています。
この選択が行われた設計上の理由はありますか?