indexer.yaml

# 3-extract-deleted-rta.yaml, consulta la BD sqlite y extrae todos los registros que el campo DEL se encuentre a 1 (Registros dados de baja en la API de OPENRTA).
# Los registros extraidos se almacenan en fichero para ser posteriormente eliminados en otro proceso.
http:
  enabled: false

# Version llamando a SQLITE
input:
  kafka:
    addresses:
#      - des-kafka-kafka-0-des-pt-int-kafka.apps.paas-des.junta-andalucia.es:443
#      - des-kafka-kafka-bootstrap-des-pt-int-kafka.apps.paas-des.junta-andalucia.es:443
       - des-kafka-kafka-0.des-kafka-kafka-brokers.des-pt-int-kafka.svc:9092
       - des-kafka-kafka-1.des-kafka-kafka-brokers.des-pt-int-kafka.svc:9092
       - des-kafka-kafka-2.des-kafka-kafka-brokers.des-pt-int-kafka.svc:9092
       - des-kafka-kafka-3.des-kafka-kafka-brokers.des-pt-int-kafka.svc:9092   
    topics: 
      - content-receiver-batch
    target_version: 2.0.0 # No default (optional)
    consumer_group: "benthos-indexer"
    checkpoint_limit: 1024      

pipeline:
  processors:
    - bloblang: |
        root = this.contents
    - unarchive:
        format: "json_array"

output:
  stdout:
    codec: lines