Connect Supabase CSV file and Kafka in our serverless environment

class SupabaseSourceReadRemoteCsv {
    async init() {
        // TODO: Create your supabase credential
        // More info at https://yepcode.io/docs/integrations/supabase/#credential-configuration
        this.supabase = yepcode.integration.supabase(
            "your-supabase-credential-name"
        );
    }

    async fetch(publish, done) {
        // You may check the full API documentation at:
        // https://supabase.com/docs/reference/javascript/storage-from-download
        const {
            data,
            error
        } = await this.supabase.storage
            .from("your-bucket-name")
            .download(`your-file-name.csv`);
        if (error) {
            throw error;
        }
        data
            .stream()
            .pipe(
                csv.parse({
                    delimiter: ",",
                    columns: true,
                })
            )
            .on("data", publish)
            .on("end", done);
    }

    async close() {}
}

class KafkaTargetSendMessage {
    async init() {
        // TODO: Create your kafka credential
        // More info at https://yepcode.io/docs/integrations/kafka/#credential-configuration
        const kafka = yepcode.integration.kafka("your-kafka-credential-name");
        this.producer = kafka.producer();
        await this.producer.connect();
    }

    async consume(item) {
        // TODO: customize your message and topic
        const message = `Your message content ${item.name}`;
        await this.producer.send({
            topic: "your-topic",
            messages: [{
                value: message
            }],
        });
    }

    async close() {
        await this.producer.disconnect();
    }
}