Added kafka streaming tests and fixing streaming context start control.