Procesamiento de Clientes Kafka

Esta implementación consiste en:

  • Una implementación de Send Connector que serializa Initiate Component Processing Command como JSON y lo envía a Kafka. La ruta de configuración raíz para este conector es ipf-debulker.client-processing.

  • Un ReceiveConnector que consume Complete Component Processing Command y lo pasa a Component Processing Completion Port.

Configuración

Config Tipo Comentario Predeterminado

ipf.debulker.client-processing.connector.kafka.producer.topic

Cadena

El tema al que se enviará Initiate Component Processing Command.

CLIENT_PROCESSING_REQUEST

ipf.debulker.client-processing.connector.kafka.consumer.topic

Cadena

El tema del cual se consumirá Complete Component Processing Command.

CLIENT_PROCESSING_RESPONSE