CONNECT_LOG4J_LOGGERS=org.apache.kafka.connect.runtime.rest=WARN,org.reflections=ERROR
[2020-07-14 16:51:16,847] ERROR [source-datagen-01|task-0] Failed to send HTTP request to endpoint: http://schema-registry:8081/subjects/ratings-value/versions (io.confluent.kafka.schemaregistry.client.rest.RestService:268)
[2020-07-14 16:51:16,854] ERROR [source-datagen-01|task-0] WorkerSourceTask{id=source-datagen-01-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:186)
[2020-07-14 16:51:16,856] ERROR [source-datagen-01|task-0] WorkerSourceTask{id=source-datagen-01-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:187)