Remove concurrency and error-handling from the content replayer.
ThreadPoolExecutor hides errors, so failures to copy an object wouldn't
prevent committing to Kafka.
Also, libcloud (or maybe only its S3 backend) does not work well with
threads.
Remove concurrency and error-handling from the content replayer. Tags None Subscribers None
Description
Details
|