Added specs for kafka input and output
Remove unused require
fix timestamp test hard coding for UTC-7