问Kafka连接S3源代码抛出java.io.IOException

EN

Caused by: java.io.IOException: Attempted read on closed stream.
    at org.apache.http.conn.EofSensorInputStream.isReadAllowed(EofSensorInputStream.java:107)
    at org.apache.http.conn.EofSensorInputStream.read(EofSensorInputStream.java:133)
    at com.amazonaws.internal.SdkFilterInputStream.read(SdkFilterInputStream.java:90)
    at com.amazonaws.event.ProgressInputStream.read(ProgressInputStream.java:180)

WARN Not all bytes were read from the S3ObjectInputStream, aborting HTTP connection. This is likely an error and may result in sub-optimal behavior. Request only the bytes you need via a ranged GET or drain the input stream after use. (com.amazonaws.services.s3.internal.S3AbortableInputStream:178)

{
    "connector.class":"io.confluent.connect.s3.source.S3SourceConnector",
    "tasks.max":"1",
    "s3.region":"eu-central-1",
    "s3.bucket.name":"test-bucket-yordan",
    "topics.dir":"test-bucket/topics",
    "format.class": "io.confluent.connect.s3.format.json.JsonFormat",
    "partitioner.class":"io.confluent.connect.storage.partitioner.DefaultPartitioner",
    "schema.compatibility":"NONE",
    "confluent.topic.bootstrap.servers": "blockchain-kafka-kafka-0.blockchain-kafka-kafka-headless.default.svc.cluster.local:9092",
    "transforms":"AddPrefix",
   "transforms.AddPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.AddPrefix.regex":".*",
    "transforms.AddPrefix.replacement":"$0_copy"
}