in src/main/java/com/aliyun/odps/kafka/connect/utils/JsonHandler.java [39:53]
public static String readJson(String jsonPath) {
InputStream inputStream = ConfigHelper.class.getClassLoader().getResourceAsStream(jsonPath);
assert inputStream != null;
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
StringBuilder stringBuilder = new StringBuilder();
String line;
try {
while ((line = reader.readLine()) != null) {
stringBuilder.append(line);
}
} catch (IOException e) {
e.printStackTrace();
}
return stringBuilder.toString();
}