Add validation for attributes that may be null in S3 Metadata.

streamthoughts / kafka-connect-file-pulse

🔗 A multipurpose Kafka Connect connector that makes it easy to parse, transform and stream any file, in any format, into Apache Kafka

https://streamthoughts.github.io/kafka-connect-file-pulse/

Apache License 2.0

324 stars 65 forks source link

Add validation for attributes that may be null in S3 Metadata. #678

Closed zongwei007 closed 1 week ago

zongwei007 commented 1 month ago

The ObjectMetadata#getStorageClass method and the ObjectMetadata#getETag method may both return null. In such cases, these attributes need to be ignored to prevent a NPE issue in ConnectSchemaMapper.