Major Tez has an interface to integrate various input and output types into Tez. This makes jobs pluggable where compatible inputs and outputs can be plugged in/out without changing the main processing logic of the job. This jira tracks adding support for Kafka as an input and output for Tez jobs/tasks.