Kakfa output support for DataGenerator