Cloudera Stream Builder è un'interfaccia utente interattiva completa utilizzata per creare processi di elaborazione stateful dello streaming utilizzando SQL, che viene convertito in processi Flink ottimizzati. Con SQL, è possibile dichiarare in modo semplice e agevole le espressioni che filtrano, aggregano, instradano e mutano in altro modo flussi di dati. SQL Stream Builder è un'interfaccia di gestione del lavoro utilizzabile per comporre ed eseguire SQL sui flussi e per creare API di dati durevoli per i risultati.

Assicurati che i dati vengano elaborati in modalità exactly once anche in caso di errori e nuovi tentativi. Ad esempio, un'azienda di servizi finanziari deve utilizzare l'elaborazione dello streaming per coordinare centinaia di sistemi di transazioni di back-office quando i consumatori pagano i propri mutui.

Rileva e gestisci gli eventi insoliti dello streaming. Ad esempio, i servizi fraudolenti in tempo reale devono garantire che i dati vengano elaborati nell'ordine giusto anche se alcuni arrivano in ritardo.

Ottieni le prestazioni di elaborazione dei flussi in memoria e uno alla volta. Ad esempio, elabora richieste di 30 milioni di utenti attivi che effettuano pagamenti con carta di credito, trasferimenti e controlli di saldo con latenza di millisecondi.

Attiva gli eventi quando si affrontano centinaia di fonti di streaming e milioni di eventi al secondo per ciascuno. Ad esempio, quando un paziente viene accettato in PS, il sistema si collega a sistemi esterni per estrarre dati specifici sul paziente da centinaia di fonti, in modo che sia disponibile in una cartella clinica elettronica ancor prima che arrivi in ambulatorio.

Lo streaming dei dati ha poco valore, a meno che non sia in grado di integrare, unire e mettere in rete facilmente i flussi con altre fonti di dati a riposo, tra cui warehouse, database relazionali e data lake. Configura i provider di dati utilizzando connettori predefiniti o un connettore personalizzato per qualsiasi fonte di dati. Una volta creati i provider di dati, l'utente potrà creare facilmente tabelle virtuali utilizzando DDL. L'integrazione complessa tra più flussi e origini dati in batch diventa più semplice con costrutti SQL noti, come join e aggregazioni.

Supporta milioni di messaggi al secondo con bassa latenza e throughput elevato, scalando elasticamente e in trasparenza senza tempi di interruzione. È destinato a diverse iniziative di streaming di dati, consentendo alle imprese di rimanere al passo con la domanda dei clienti, fornire servizi migliori e gestire proattivamente i rischi.

Streams Messaging Manager offre un unico pannello di visualizzazione con visibilità end-to-end su come i dati si muovono su cluster Kafka fra produttori, broker, argomenti e consumatori, permettendoti di monitorare la derivazione dei dati e la governance dall'edge al cloud. Inoltre, semplifica la risoluzione dei problemi in ambienti Kafka con ordinamento e filtri intelligenti.

Streams Replication Manager, basato su Mirrormaker 2, offre una replicazione cross-cluster degli argomenti Kafka fault-tolerant, scalabile e solida, insieme a monitoring e metriche di replicazione a livello di cluster e argomenti. Offre alta disponibilità, disaster recovery, migrazioni cloud, geo-proximity e molto altro.

Schema Registry consente di gestire, condividere e supportare l'evoluzione di tutti gli schemi di produttori e clienti in un repository di schemi condiviso che consente alle applicazioni di interagire in modo flessibile l'uno con l'altro in tutto il panorama Kafka. Riduci in modo sicuro le interruzioni che potrebbero verificarsi a causa degli errori di corrispondenza della struttura.

Cruise Control permette di gestire ed equilibrare i carichi su grandi installazioni Kafka e di individuare e correggere automaticamente le anomalie. Affronta i problemi più gravi, come i guasti frequenti di macchine hardware o virtuali, l'espansione/riduzione dei cluster e le distorsioni fra i broker.

Cloudera SDX offre sicurezza centralizzata, politiche di controllo, governance e derivazione dei dati su tutte le componenti. Vengono impostate una volta e applicate automaticamente e sono indipendenti dal fornitore, permettendo di adottare con tranquillità strategie multi-cloud e hybrid cloud. Supporta i quattro pilastri della sicurezza: identità, accesso, protezione dei dati e visibilità.