Matteo Ferroni mattferroni

vikas-tikoo-zefr / Namespacefy.java

Created December 13, 2017 18:46

Add namespace to connect schema

	import org.apache.kafka.common.config.ConfigDef;
	import org.apache.kafka.connect.connector.ConnectRecord;
	import org.apache.kafka.connect.data.Field;
	import org.apache.kafka.connect.data.Schema;
	import org.apache.kafka.connect.data.SchemaBuilder;
	import org.apache.kafka.connect.data.Struct;
	import org.apache.kafka.connect.transforms.Transformation;
	import org.apache.kafka.connect.transforms.util.SchemaUtil;
	import org.apache.kafka.connect.transforms.util.SimpleConfig;