Configurando Kafka Temas

Utilice esta guía para configurar un process flow solicitud de salida de específico data type s a específico Kafka Temas.

Esta guía se basa en su aplicación dependiendo de y habilitando el Salida Kafka Transporte módulo.

Configuración de Tema Predeterminado

Por defecto, todos data type s se publican en el predeterminado IPF_PROCESSING_DATA tema. Puede cambiar esto a través de la configuración, por ejemplo,ipf.processing-data.egress.kafka.producer.topic = SOME_OTHER_TOPIC.

Configuración de Múltiples Temas

Cada IPF Processing Data El tipo se puede configurar para ser entregado a diferentes temas. Los tipos disponibles son:

Tipo Descripción Ruta de Configuración

Events

Events producido por los flujos de procesamiento de pagos de IPF

ipf.processing-data.egress.transports.events

Estructuras de Datos

MDS y PDS objetos, generalmente producidos por los flujos de procesamiento de pagos del IPF

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

Message Logs

Message logs de todos los mensajes intercambiados con otros sistemas

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

System Events

System events producido por la aplicación en ejecución

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

Modelos

Definiciones del flujo de procesamiento de pagos IPF, por ejemplo, metadatos sobre los flujos en sí mismos

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 complemento de salida que exporte ya sea un message log or system event, producirá esos datos a los temas configurados. Cualquier restante data type s se producirán por defecto IPF_PROCESSING_DATA` tema.

Todo Data Type s

Es posible entregar todo data type s a diferentes temas, p. ej.

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 predeterminado.IPF_PROCESSING_DATA tema.

Registro

Un resumen de la configuración Kafka Los temas se registran al iniciar.

Ejemplo kafka registro de resumen del tema 
11:04:42. 035 [main] INFO com.iconsolutions.ipf.processingdata. KafkaTopicLogger --
------------------------------------------------------------------------------------------------------------------------------------------------------
 Configuraciones de Transporte KafkaConnector para la Salida de Datos de Procesamiento IPF
------------------------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------------
                Tipo de dato                  Nombre del Transporte del Conector                                                                  Nombre del tema de Kafka
----------------------------------------------------------------------------------------------------------------------------------------------
                   EVENTOS            IpfProcessingDataEgressKafka-1                                                                      EVENTOS_TEMA
          ESTRUCTURAS_DE_DATOS            IpfProcessingDataEgressKafka-2                                                             TEMA_DE_ESTRUCTURAS_DE_DATOS
             REGISTROS_DE_MENSAJES            IpfProcessingDataEgressKafka-3                                                                REGISTROS_DE_MENSAJES
            EVENTOS_DEL_SISTEMA            IpfProcessingDataEgressKafka-4                                                               TEMA_DE_EVENTOS_DEL_SISTEMA
                   MODELOS            IpfProcessingDataEgressKafka-5                                                                      MODELOS_TEMA

Consuma de Kafka

Por defecto, todos data type s se producen según el valor predeterminado IPF_PROCESSING_DATA tema. Puede cambiar esto a través de la configuración, por ejemplo,ipf.processing-data.ingress.kafka.consumer.topic = SOME_OTHER_TOPIC.

Si IPF Processing Data los tipos se producen para diferentes temas, puede configurar esto con ipf.processing-data.ingress.kafka.consumer.topics = [ EVENTS_TOPIC, DATA_STRUCTURES_TOPIC, MESSAGE_LOGS_TOPIC, SYSTEM_EVENTS_TOPIC, MODELS_TOPIC ].

Ya sea ipf.processing-data.ingress.kafka.consumer.topic or ipf.processing-data.ingress.kafka.consumer.topics debe ser configurado, pero no ambos.