Documentation for a newer release is available. View Latest

Configuración de topics de Kafka

Use esta guía para configurar una aplicación de process flow para el egreso de tipos de datos específicos hacia topics de Kafka específicos.

Esta guía depende de que su aplicación añada y habilite el módulo Egress Kafka Transport.

Configuración por defecto del topic

Por defecto, todos los tipos de datos se publican en el topic predeterminado IPF_PROCESSING_DATA. Puede cambiarlo mediante configuración, por ejemplo: ipf.processing-data.egress.kafka.producer.topic = SOME_OTHER_TOPIC.

Configuración de múltiples topics

Cada tipo de IPF Processing Data puede configurarse para entregarse a distintos topics. Los tipos disponibles son:

Tipo Descripción Ruta de config

Events

Eventos producidos por los flujos de procesamiento de pagos de IPF

ipf.processing-data.egress.transports.events

Data Structures

Objetos MDS y PDS, normalmente producidos por los flujos de procesamiento de pagos de IPF

ipf.processing-data.egress.transports.data-structures

Message Logs

Registros de mensajes de todos los mensajes intercambiados con otros sistemas

ipf.processing-data.egress.transports.message-logs

System Events

Eventos del sistema producidos por la aplicación en ejecución

ipf.processing-data.egress.transports.system-events

Models

Definiciones de process flow de IPF, p. ej., metadatos sobre los propios flujos

ipf.processing-data.egress.transports.models

Ejemplos

Message Logs y System Events

ipf.processing-data.egress {
  transports {
    message-logs.kafka.producer.topic = MESSAGE_LOG_TOPIC
    system-events.kafka.producer.topic = SYSTEM_EVENT_TOPIC
  }
}

Con esta configuración, cualquier plugin de egress que exporte un message log o un system event producirá esos datos a los topics configurados. Cualquier tipo de dato restante se producirá al topic predeterminado IPF_PROCESSING_DATA.

Todos los tipos de datos

Es posible entregar todos los tipos de datos a distintos topics, por ejemplo:

ipf.processing-data.egress {
  transports {
    events.kafka.producer.topic = EVENTS_TOPIC
    data-structures.kafka.producer.topic = DATA_STRUCTURES_TOPIC
    message-logs.kafka.producer.topic = MESSAGE_LOGS_TOPIC
    system-events.kafka.producer.topic = SYSTEM_EVENTS_TOPIC
    models.kafka.producer.topic = MODELS_TOPIC
  }
}

Con esta configuración, no se exportará ningún dato al topic predeterminado IPF_PROCESSING_DATA.

Consumo desde Kafka

Por defecto, todos los tipos de datos se producen al topic predeterminado IPF_PROCESSING_DATA. Puede cambiarlo mediante configuración, por ejemplo: ipf.processing-data.ingress.kafka.consumer.topic = SOME_OTHER_TOPIC.

Si los tipos de IPF Processing Data se producen a distintos topics, puede configurarlo con ipf.processing-data.ingress.kafka.consumer.topics = [ EVENTS_TOPIC, DATA_STRUCTURES_TOPIC, MESSAGE_LOGS_TOPIC, SYSTEM_EVENTS_TOPIC, MODELS_TOPIC ].

NOTA: Debe configurarse ipf.processing-data.ingress.kafka.consumer.topic o ipf.processing-data.ingress.kafka.consumer.topics, pero no ambos.