()
return ElasticProcessor(
        elasticsearch=get_es_new(),
        index_info=GROUP_INDEX_INFO,
    )
Inserts group changes into ES

    Reads from:
      - Kafka topics: group
      - Group data source (CouchDB)

    Writes to:
      - GroupES index
Inserts group changes into ES
Inserts group changes into ES
def get_group_to_elasticsearch_processor():
    """Inserts group changes into ES

    Reads from:
      - Kafka topics: group
      - Group data source (CouchDB)

    Writes to:
      - GroupES index
    """
    return ElasticProcessor(
        elasticsearch=get_es_new(),
        index_info=GROUP_INDEX_INFO,
    )
def get_group_to_elasticsearch_processor ( ) : return ElasticProcessor ( elasticsearch = get_es_new ( ) , index_info = GROUP_INDEX_INFO , )