Scénarios

L’exemple téléchargeable est beaucoup plus complet. Nous ne reprenons ici que l’entrée, un traitement et la sortie du flux de messages.

1. Flux d’entrée

Nous créons un message à partir d’une source externe en entrée. Nous configurons pour avoir tous les paramètres à leur maximum.

      SenderOptions<Integer, Person> senderOptions = senderOptions() 
         .producerProperty(ProducerConfig.ACKS_CONFIG, "all") 
         .producerProperty(ProducerConfig.MAX_BLOCK_MS_CONFIG, 
Long.MAX_VALUE) 
         .producerProperty(ProducerConfig.RETRIES_CONFIG, 
Integer.MAX_VALUE); 

Puis nous simulons une entrée :

      Flux<Person> srcFlux = source().flux(); 
    &n ...
couv_EPREAJASP.png

Découvrez 

le livre :

Aussi inclus dans nos :

Précédent
Consommateur
Suivant
Points clés