def METHOD_NAME(self):
    document = {
        'doc_type': 'CommCareCase',
        'type': 'mother',
        'domain': 'kafka-test-domain',
    }
    self.pillow.process_change(Change(id='test-id', sequence_id='3', document=document))
    message = next(self.consumer)
    change_meta = change_meta_from_kafka_message(message.value)
    self.assertEqual(SOURCE_COUCH, change_meta.data_source_type)
    self.assertEqual(self._fake_couch.dbname, change_meta.data_source_name)
    self.assertEqual('test-id', change_meta.document_id)
    self.assertEqual(document['doc_type'], change_meta.document_type)
    self.assertEqual(document['type'], change_meta.document_subtype)
    self.assertEqual(document['domain'], change_meta.domain)
    self.assertEqual(False, change_meta.is_deletion)
    with self.assertRaises(StopIteration):
        next(self.consumer)