* Fixes change to the error api in the kafka project.

* Updated test to reflect the change.

* Update kafka to match master branch.