Riepilogo del supporto per tutti i client consigliati

Collegamento del tuo client a Event Streams

Per informazioni su come configurare il tuo client Java per il collegamento a Event Streams, consulta Configurazione del tuo client.

Utilizzo di SASL PLAIN

Utilizzare le seguenti stringhe e proprietà.

• Utilizza la stringa bootstrap_endpoints come elenco di server di avvio e passa questa stringa di coppie host e porta al tuo client Kafka.
• Utilizzare le proprietà user e api_key come nome utente e password.

Per un client Java, l'esempio seguente mostra l'insieme minimo di proprietà, dove ${USERNAME}, ${PASSWORD} e ${BOOTSTRAP_ENDPOINTS} devono essere sostituiti dai valori recuperati in precedenza.

bootstrap.servers=${BOOTSTRAP_ENDPOINTS}
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${USERNAME}" password="${PASSWORD}";
security.protocol=SASL_SSL
ssl.protocol=TLSv1.2
ssl.enabled.protocols=TLSv1.2
ssl.endpoint.identification.algorithm=HTTPS

Se si utilizza un client Kafka precedente alla versione 0.10.2.1, la proprietà sasl.jaas.config non è supportata e occorre fornire la configurazione del client in un file di configurazione JAAS.

Utilizzo di SASL OAUTHBEARER

Prima di configurare il meccanismo SASL per il client Java, esistono due prerequisiti.

• La versione client Kafka Java minima supportata è 3.1.0.
• Il pacchetto jar aggiuntivo deve essere scaricato da Maven Central e reso disponibile nel percorso classi.

Se Maven viene utilizzato nel sistema di build, aggiungi le seguenti informazioni al file pom.xml nella sezione delle dipendenze.

<dependency>
    <groupId>com.ibm.cloud.eventstreams</groupId>
    <artifactId>oauth-client</artifactId>
    <version>1.3.1</version>
</dependency>

Se Gradle viene utilizzata nel sistema di creazione, aggiungi le seguenti informazioni al file build.gradle nella sezione delle dipendenze.

implementation com.ibm.cloud.eventstreams:oauth-client:1.3.1

Utilizzare le seguenti stringhe e proprietà.

• Utilizza la stringa bootstrap_endpoints come elenco di server di avvio e passa questa stringa di coppie host e porta al tuo client Kafka.
• Utilizza la stringa api_key come chiave API.
• IAMOAuthBearerLoginCallbackHandler viene fornita dal package jar com.ibm.cloud.eventstreams:oauth-client:+.
• L'endpoint token di IBM Cloud® Identity and Access Management https://iam.cloud.ibm.com/identity/token è configurato per generare il token dalla chiave API utilizzando il tipo di concessione specificato nella configurazione jaas. Viene eseguito sul lato client, quindi la chiave API non viene mai inviata al lato server e fornisce una sicurezza migliore rispetto a una chiave API di lunga durata.
• L'endpoint chiave di Cloud Identity and Access Management https://iam.cloud.ibm.com/identity/keys è configurato per convalidare il token.

Per un client Java, l'esempio seguente mostra l'insieme minimo di proprietà, dove ${BOOTSTRAP_ENDPOINTS} e ${APIKEY} devono essere sostituiti dai valori recuperati in precedenza.

bootstrap.servers=${BOOTSTRAP_ENDPOINTS}
sasl.mechanism=OAUTHBEARER
sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required grant_type="urn:ibm:params:oauth:grant-type:apikey" apikey="${APIKEY}";
sasl.login.callback.handler.class=com.ibm.eventstreams.oauth.client.IAMOAuthBearerLoginCallbackHandler
sasl.oauthbearer.token.endpoint.url=https://iam.cloud.ibm.com/identity/token
sasl.oauthbearer.jwks.endpoint.url=https://iam.cloud.ibm.com/identity/keys
security.protocol=SASL_SSL
ssl.protocol=TLSv1.2
ssl.enabled.protocols=TLSv1.2
ssl.endpoint.identification.algorithm=HTTPS

Il codice di esempio fa riferimento agli esempi Event Streams.

Per altre librerie client Kafka, fare riferimento alla relativa documentazione su come implementare il supporto OAUTHBEARER. Ad esempio:.

• sarama: è richiesta un'implementazione dell'interfaccia AccessTokenProvider.
• librdkafka: è richiesta un'implementazione del callback oauthbearer_token_refresh_cb.

Per informazioni su come generare un token IAM IBM Cloud utilizzando una chiave API, consulta il documento di IBM Cloud® Identity and Access Management.