Move _get_key from the kafka writer to serializers
Use the opportunity to add some trivial smoke tests