KafkaInputOperator: transfer cacheSize during partitioning.
Merge branch 'dt-dev' of https://github.com/DataTorrent/Malhar into dt-dev