fix log messages to say "kafka"
Merge branch 'aitfive-203' into qa