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

相关文章推荐

坚强的啄木鸟 · Unity 之 ...· 4 月前 ·

酒量小的枕头 · windows控制鼠标api - CSDN文库· 5 月前 ·

帅气的玉米 · mysql 实现 ...· 1 年前 ·

没有腹肌的香菇 · HW140701的博客_CSDN博客-C++ ...· 1 年前 ·

坐怀不乱的跑步机 · yarn.lock 你锁明白了吗？ - 掘金· 1 年前 ·

腾讯云

备案控制台

开发者社区

TVP

文章/答案/技术大牛

写文章

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

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",

推荐文章

坚强的啄木鸟 · Unity 之 AndroidStudio打开导出Android工程详解-阿里云开发者社区

4 月前

酒量小的枕头 · windows控制鼠标api - CSDN文库

5 月前

帅气的玉米 · mysql 实现 generate_series()_mysql generate-CSDN博客

1 年前

没有腹肌的香菇 · HW140701的博客_CSDN博客-C++,VS/VC/MFC,Python领域博主

1 年前

坐怀不乱的跑步机 · yarn.lock 你锁明白了吗？ - 掘金

1 年前