in src/fluent-plugin-mdsd/lib/fluent/plugin/out_mdsd.rb [207:213]
def get_new_schema_id() @schema_id_mutex.synchronize do @schema_id += 1 return @schema_id end end