Per accedere ai dati con Apache Kafka, crea un asset di connessione per esso.
Apache Kafka è una piattaforma di streaming eventi distribuita. Connettersi a un server di elaborazione in tempo reale Apache Kafka per scrivere e leggere flussi di eventi da e verso argomenti.
Versioni supportate
Apache Kafka versioni 0.11 - 2.x
Crea una connessione a Apache Kafka
Per creare l'asset di connessione, sono necessari questi dettagli di connessione.
Kafka server hostname: nome host e numero di porta del server Kafka . Utilizzare questo formato: hostname:port-number. Per collegarti a un cluster Kafka , separa i valori con le virgole: hostname1:port-number1,hostname2:port-number2,hostname3:port-number3. Se ci si connette a un cluster, la connessione utilizza tutti i server indipendentemente dai server specificati per il bootstrap. Poiché questi server vengono utilizzati per la connessione iniziale per rilevare l'appartenenza al cluster completo, che può cambiare dinamicamente, questo elenco non deve contenere la serie completa di server. Ma se il cluster Kafka ha tre host o meno, includi tutti gli host in questo elenco per evitare la perdita di dati.
Connessione protetta
Seleziona il protocollo di autenticazione di rete configurato sul server Kafka . Nessuno è il valore predefinito. Queste sono le altre selezioni e le relative proprietà:
SASL OAUTHBEARER
Selezionare OAuth 2.0
- URL server: URL endpoint token. Esempio:
https://example.com/oauth2/default/v1/token. - ID client: l'ID client OAuth.
- Segreto client: il segreto del client OAuth
- Ambito L'ambito facoltativo a cui fare riferimento nella chiamata al server OAuth.
- Ulteriori proprietà: opzioni di configurazione OAuth aggiuntive. Immettere come coppie
key=value. Il valore di questa proprietà multilinea deve essere conforme ai requisiti della classe delle proprietà Java. - Certificati truststore: certificati attendibili in formato PEM. Sono supportati solo i certificati X.509.
SASL_Plain
Nome principal utente: l'utente autenticato nel server o cluster Kafka .
Password: password per il nome principal dell'utente.
SASL_SSL
Nome principal utente: l'utente autenticato nel server o cluster Kafka .
Password: password per il nome principal dell'utente.
Certificati truststore: certificati truststore in formato PEM. Sono supportati solo i certificati X.509.
SCRAM-SHA-256 o SCRAM-SHA-512
Nome principal utente: l'utente autenticato nel server o cluster Kafka .
Password: password per il nome principal dell'utente.
Certificati truststore: certificati truststore in formato PEM. Sono supportati solo i certificati X.509.
SSL
Certificati truststore: certificati truststore in formato PEM. Sono supportati solo i certificati X.509.
Chiave: chiave privata in formato PEM. La chiave deve utilizzare la sintassi PKCS #8 .
Catena di certificati chiave: catena di certificati per la chiave privata in formato PEM. Sono supportati solo i certificati X.509.
Password chiave: questo valore è richiesto se la chiave è codificata.
Formato del messaggio
Un registro di schemi è un software di terzi che gestisce i messaggi e associa gli schemi agli argomenti in modo che i producer sappiano quali argomenti stanno accettando quali tipi (schemi) di messaggi e i consumer sanno come leggere e analizzare i messaggi in un argomento. Se si seleziona Utilizza registro schema per il formato del messaggio, è possibile selezionare questi dettagli aggiuntivi per connettersi in modo sicuro al servizio registro schema.
Prerequisito
Configurare il registro degli schemi per il server Kafka con Confluent (sono supportate le versioni 6.x e 7.x di Confluent) o con IBM Event Streams.
URL registro schema: URL del servizio registro schema.
Autenticazione
Selezionare il metodo di autenticazione per il servizio di registro dello schema. Nessuno è il valore predefinito. Queste sono le altre selezioni e le relative proprietà:
Utilizza le credenziali utente SASL del server Kafka: È possibile scegliere questa selezione se sono state immesse proprietà per SASL_Plain o SASL_SSL per la connessione sicura al server Kafka . Il nome utente e la password per le impostazioni di sicurezza SASL verranno utilizzati per l'autenticazione al servizio di registro schema.
Credenziali utente: nome utente e password per il servizio di registro dello schema.
Connessione protetta
Selezionare il protocollo di autenticazione di rete sicura per il servizio di registro dello schema. Nessuno è il valore predefinito. Queste sono le altre selezioni e le relative proprietà:
Utilizza le credenziali utente SSL del server Kafka: puoi scegliere questa selezione se hai immesso le proprietà per SSL per la connessione sicura al server Kafka . La configurazione dei certificati dalla connessione server Kafka verrà utilizzata per la connessione sicura al servizio di registro dello schema.
SSL
- Certificati truststore: certificati truststore in formato PEM. Sono supportati solo i certificati X.509.
- Chiave: chiave privata in formato PEM. La chiave deve utilizzare la sintassi PKCS #8 .
- Catena di certificati chiave: catena di certificati per la chiave privata in formato PEM. Sono supportati solo i certificati X.509.
- Password chiave: questo valore è necessario se la chiave è codificata.
Tipo di registro degli schemi
Selezionare il tipo di registro dello schema:
- Confluent
- IBM Event Streams (API compatibile con Confluent)
Scegliere il metodo per la creazione di una connessione in base alla posizione in cui ci si trova nella piattaforma
In un progetto
Fare clic su Asset> Nuovo asset> Connetti a una origine dati. Consultare Aggiunta di una connessione a un progetto.
In un catalogo
Fare clic su Aggiungi a catalogo> Connessione. Consultare Aggiunta di un asset di connessione a un catalogo.
Nel Platform assets catalog
Fare clic su Nuova connessione. Consultare Aggiunta di connessioni di piattaforma.
Passo successivo: aggiungere gli asset di dati dalla connessione
Dove è possibile utilizzare questa connessione
Puoi utilizzare la connessione Apache Kafka nei seguenti spazi di lavoro e strumenti:
Progetti
- Data Replication (servizioData Replication ). Puoi replicare i dati da altri database a Apache Kafka utilizzando Data Replication. Vedi Replica dei dati Apache Kafka.
- DataStage (servizioDataStage ). Consultare Connessione a un'origine dati in DataStage.
Cataloghi
Platform assets catalog
Altri cataloghi (IBM Knowledge Catalog)
Nota:Anteprima, profilo e mascheramento non sono certificati per questa connessione in IBM Knowledge Catalog.
Configurazione di Apache Kafka
Ulteriori informazioni
- Documentazione suKafka
- Panoramica del registro Schema di Confluent
- Utilizzo del registro degli schemi Event Streams
Argomento principale: Connessioni supportate