Integrazione utilizzando Apache Kafka
Puoi integrare la piattaforma di messaggistica Apache Kafka per pubblicare e utilizzare i messaggi in modo asincrono dalla piattaforma Kafka . Kafka può essere configurato come provider di messaggi esterno che accetta e memorizza i messaggi in uscita e in entrata.
Introduzione all'integrazione Kafka
Il prodotto fornisce il client di messaggistica Kafka che supporta l'utilizzo, la produzione e l'esplorazione degli argomenti Kafka . Per utilizzare le funzioni Kafka nel prodotto, devi ottenere e configurare un'istanza del server Kafka del provider. Puoi scegliere qualsiasi provider Kafka compatibile con le librerie client Kafka 2.8.x .
Il provider Kafka gestisce gli argomenti e le partizioni e l'archiviazione corrispondenti che persistono i messaggi di integrazione. Il framework di integrazione fornisce il framework client Kafka per leggere, scrivere ed esplorare i messaggi negli argomenti Kafka .
Il framework di integrazione utilizza la consegna point - to - point dei messaggi Kafka . Pertanto, tutti gli argomenti Kafka vengono utilizzati dal framework di integrazione come coda di messaggistica. Solo un gruppo di consumatori per argomento viene utilizzato per utilizzare i messaggi. Per la ricerca viene utilizzato un gruppo di consumatori separato. Tuttavia, un altro gruppo di consumatori per argomento è disponibile per la ricerca di argomenti.
Il framework di integrazione utilizza solo le funzioni di messaggistica di Kafka e non utilizza alcuna delle funzioni di streaming Kafka .
Il framework di integrazione supporta l'elaborazione asincrona dei messaggi che utilizzano provider Kafka in modo simile al modo in cui il framework di integrazione utilizza JMS. Gli argomenti Kafka conservano i messaggi in un archivio dati per i messaggi del canale di pubblicazione o notifica in uscita e i messaggi del servizio aziendale in entrata. In entrambi i casi, è supportata l'elaborazione di messaggi sequenziali e continui.
Maximo Manage componenti per code messaggi Kafka
- Crontask Maximo Manage per l'utilizzo di messaggi dalle code.
- Il framework di integrazione per il caricamento file e il servlet e la crontask della tabella di interfaccia che scrivono o producono messaggi nelle code.
- Configurazione dell'applicazione dei sistemi esterni per supportare la registrazione del fornitore Kafka e l'elaborazione della coda.
- Maximo Manage REST API for Kafka che abilita la ricerca dei messaggi nella coda. Kafka i messaggi non possono essere eliminati da Maximo Manage. È preferibile utilizzare l'applicazione Rielaborazione messaggi per rimuovere i messaggi Kafka , che in realtà ignora solo il messaggio per quello successivo.
Differenze tra l'elaborazione della coda JMS e l'elaborazione della coda Kafka
Se si sta considerando di passare dall'utilizzo delle code JMS all'utilizzo delle code Kafka per l'elaborazione dei messaggi, sebbene le funzioni di elaborazione in Kafka siano simili, tenere presente alcune differenze. Molte delle seguenti differenze vengono discusse in modo più dettagliato in altri argomenti nel contenuto di Kafka .
- In Maximo Manage, un tipo di messaggio Kafka è sempre byte e non testo. I messaggi JMS possono essere di testo o byte.
- Un messaggio Kafka è sempre compresso.
- Il limite della dimensione del messaggio Kafka viene configurato nella proprietà di sistema mxe.kafka.messagesize in Maximo Manage. Impostare il valore in byte in modo che corrisponda al valore utilizzato nel server Kafka per Maximo Manage.
- I messaggi Kafka non vengono eliminati quando vengono elaborati. Vengono rimossi dalla coda una volta superato il tempo di conservazione configurato.
- L'utilizzo continuo dei messaggi viene gestito dalle crontask Maximo Manage e non dagli MDB (message - driven bean).
- L'API REST Maximo Manage viene utilizzata per sfogliare i messaggi in una coda.