Currently, a consumer will wait indefinitely if a file does not exist. A timeout controlled via environment variable might be useful. In addition, if there is an error while reading a file on the producer side, the error should be passed to the consumer.
Currently, a consumer will wait indefinitely if a file does not exist. A timeout controlled via environment variable might be useful. In addition, if there is an error while reading a file on the producer side, the error should be passed to the consumer.