Fix the kafka interface

[abbiemery]

Currently trying to use Kafka as the state interface results in it failing to run. This needs investigating and resolving.