Documentation for a newer release is available. View Latest

Client Processing Kafka

Esta implementación consiste en:

  • Una implementación de SendConnector que serializa InitiateComponentProcessingCommand 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 CompleteComponentProcessingCommand y lo pasa a ComponentProcessingCompletionPort.

Configuración

Config Type Comment Default

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

String

The topic to which InitiateComponentProcessingCommand will be sent.

CLIENT_PROCESSING_REQUEST

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

String

The topic from which CompleteComponentProcessingCommand will be consumed.

CLIENT_PROCESSING_RESPONSE