Use UTF8 to read Avro schema file

This commit is contained in:
Lari Hotari 2023-02-06 09:04:23 +02:00
parent a5b0b3cb2d
commit d5bdca6f28

View File

@ -380,7 +380,7 @@ public class PulsarActivityUtil {
if (schemaDefinitionStr.startsWith("file://")) {
try {
Path filePath = Paths.get(URI.create(schemaDefinitionStr));
schemaDefinitionStr = Files.readString(filePath, StandardCharsets.US_ASCII);
schemaDefinitionStr = Files.readString(filePath, StandardCharsets.UTF_8);
} catch (IOException ioe) {
throw new RuntimeException("Error reading the specified \"Avro\" schema definition file: " + definitionStr + ": " + ioe.getMessage());
}