refactor(ingest/kafka-connect): define interface for new connector impl

refactor(ingest/kafka-connect): define interface for new connector impl #31920