in src/main/java/com/amazonaws/mskdatagen/producer/SchemaValueResultBuilder.java [101:117]
private Schema getPrimitiveSchema(Object value) {
if (value == null) {
return Schema.OPTIONAL_BYTES_SCHEMA;
} else if (value instanceof Integer) {
return Schema.OPTIONAL_INT32_SCHEMA;
} else if (value instanceof Long) {
return Schema.OPTIONAL_INT64_SCHEMA;
} else if (value instanceof Float) {
return Schema.OPTIONAL_FLOAT32_SCHEMA;
} else if (value instanceof Double) {
return Schema.OPTIONAL_FLOAT64_SCHEMA;
} else if (value instanceof Boolean) {
return Schema.OPTIONAL_BOOLEAN_SCHEMA;
}
return Schema.OPTIONAL_STRING_SCHEMA;
}