Merge "Added kafka interface stub"