SPOI-2673 #resolve #comment Move exact once kafka output operator to
Malhar library
Merge branch 'master' of github.com:DataTorrent/Malhar
SPOI-2673 #comment Fix the client name and spelling mistake
SPOI-2673 #comment use default input port name
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'
Merge branch 'master' into release-1.0.2

Conflicts:
	contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraTransactionableOutputOperatorPS.java
	library/src/main/java/com/datatorrent/lib/io/fs/AbstractFSDirectoryInputOperator.java