def METHOD_NAME(self):
    # make a domain
    domain_name = 'domain-pillowtest-kafka'
    with drop_connected_signals(commcare_domain_post_save):
        domain = create_domain(domain_name)
    # send to kafka
    since = get_topic_offset(topics.DOMAIN)
    publish_domain_saved(domain)
    # send to elasticsearch
    pillow = get_domain_kafka_to_elasticsearch_pillow()
    pillow.process_changes(since=since, forever=False)
    manager.index_refresh(domain_adapter.index_name)
    # verify there
    self._verify_domain_in_es(domain_name)