updating for latest kafka