FileChanges Listener

FileChangedListener.kt

import org.springframework.kafka.annotation.KafkaListener
import org.springframework.stereotype.Component

@Component
class FileChangedListener {
    @KafkaListener(topics = ["changed_files"])
    fun listen(file: String) {
        // Process the file here
        uploadFileToSFTP(file)
    }

    private fun uploadFileToSFTP(file: String) {
        // Implement SFTP upload logic here
        // Use a library like JSch or Spring Integration SFTP
    }
}