in src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java [137:153]
public static Boolean parseBoolean(String s) {
if (s != null) {
if (s.equalsIgnoreCase("true") || s.equalsIgnoreCase("false")) {
return Boolean.valueOf(s);
}
if (s.equals("1")) {
return Boolean.TRUE;
}
if (s.equals("0")) {
return Boolean.FALSE;
}
}
throw new IllegalArgumentException();
}