test setting kafka producer properties
Add support for retrying processing of files on which read failed in middle.
added @ShipContatingJars and benchmark application

Conflicts:
	contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraTransactionableOutputOperatorPS.java
Add test case for handling failed files.
Merge branch 'SPOI-2620' of https://github.com/tushargosavi/Malhar into tushargosavi-SPOI-2620
Merge branch 'tushargosavi-SPOI-2620'
Merge branch 'master' of https://github.com/siyuanh/Malhar into siyuanh-master
Fix unit test.
Merge branch 'siyuanh-master'
Setting stream codec on all the input ports of the stream