Continuous Data Import from Kafka Using Pipe