0 / 0
Go back to the English version of the documentation
Połączenie Apache Kafka
Last updated: 18 sie 2023
Połączenie Apache Kafka

Aby uzyskać dostęp do danych za pomocą Apache Kafka, utwórz dla niego zasób połączenia.

Apache Kafka to rozproszona platforma przetwarzania strumieniowego zdarzeń. Połącz się z serwerem przetwarzający Apache Kafka w czasie rzeczywistym, aby zapisywać i odczytywać strumienie zdarzeń z i do tematów.

Obsługiwane wersje

Apache Kafka wersje 0.11 - 2.x

Utwórz połączenie z serwerem Apache Kafka

Aby utworzyć zasób połączenia, należy podać te szczegóły połączenia.

Nazwa hosta serwera Kafka: nazwa hosta i numer portu serwera Kafka . Należy użyć następującego formatu: hostname:port-number. Aby połączyć się z klastrem Kafka , należy oddzielić wartości przecinkami: hostname1:port-number1,hostname2:port-number2,hostname3:port-number3. W przypadku połączenia z klastrem połączenie korzysta z wszystkich serwerów, niezależnie od tego, które serwery są określone jako startowe. Ponieważ te serwery są używane do początkowego połączenia w celu wykrycia pełnego członkostwa w klastrze, który może być dynamicznie zmieniany, lista ta nie musi zawierać pełnego zestawu serwerów. Jeśli jednak klaster Kafka ma trzy hosty lub mniej, należy dołączyć wszystkie hosty z tej listy, aby zapobiec utracie danych.

Bezpieczne połączenie

Wybierz protokół uwierzytelniania sieciowego, który jest skonfigurowany na serwerze Kafka . Wartością domyślną jest Brak . Są to inne wybory i ich właściwości:

SASL_Plain

Nazwa użytkownika użytkownika: uwierzytelniony użytkownik na serwerze lub w klastrze Kafka .

Hasło: Hasło dla nazwy użytkownika.

SASL_SSL

Nazwa użytkownika użytkownika: uwierzytelniony użytkownik na serwerze lub w klastrze Kafka .

Hasło: Hasło dla nazwy użytkownika.

Certyfikaty magazynu zaufanych certyfikatów: Certyfikaty magazynu zaufanych certyfikatów w formacie PEM. Obsługiwane są tylko certyfikaty X.509 .

SCRAM-SHA-256 lub SCRAM-SHA-512

Nazwa użytkownika użytkownika: uwierzytelniony użytkownik na serwerze lub w klastrze Kafka .

Hasło: Hasło dla nazwy użytkownika.

Certyfikaty magazynu zaufanych certyfikatów: Certyfikaty magazynu zaufanych certyfikatów w formacie PEM. Obsługiwane są tylko certyfikaty X.509 .

protokół SSL

Certyfikaty magazynu zaufanych certyfikatów: Certyfikaty magazynu zaufanych certyfikatów w formacie PEM. Obsługiwane są tylko certyfikaty X.509 .

Klucz: klucz prywatny w formacie PEM. Klucz musi używać składni PKCS #8 .

Łańcuch certyfikatów kluczy: łańcuch certyfikatów dla klucza prywatnego w formacie PEM. Obsługiwane są tylko certyfikaty X.509 .

Hasło klucza: ta wartość jest wymagana, jeśli klucz jest zaszyfrowany.

Format wiadomości

Rejestr schematów to oprogramowanie innych firm, które zarządza komunikatami i odwzorowuje schematy na tematy w taki sposób, aby producenci wiedzieli, które tematy akceptują typy (schematy) komunikatów i konsumentów, wiedzą, jak odczytywać i analizować komunikaty w temacie. Jeśli zostanie wybrana opcja Użyj rejestru schematów dla formatu komunikatów, można wybrać te dodatkowe szczegóły, aby bezpiecznie połączyć się z usługą rejestru schematów.

Wymaganie wstępne

Skonfiguruj rejestr schematów dla serwera Kafka za pomocą opcji Konfluent.
Obsługiwane są wersje konfluentowe 6.x i 7.x .

Adres URL rejestru schematów: adres URL do usługi rejestru schematów.

Uwierzytelnianie

Wybierz metodę uwierzytelniania do usługi rejestru schematów. Wartością domyślną jest Brak . Są to inne wybory i ich właściwości:

  • Użyj referencji użytkownika SASL serwera Kafka: Ten wybór można wybrać, jeśli dla bezpiecznego połączenia z serwerem Kafka wprowadzono właściwości dla SASL_Plain lub SASL_SSL . Nazwa użytkownika i hasło dla ustawień zabezpieczeń SASL będą używane na potrzeby uwierzytelniania w usłudze rejestru schematów.

  • Informacje autoryzacyjne użytkownika: Nazwa użytkownika i hasło do usługi rejestru schematów.

Bezpieczne połączenie

Wybierz bezpieczny protokół uwierzytelniania sieciowego do usługi rejestru schematów. Wartością domyślną jest Brak . Są to inne wybory i ich właściwości:

  • Użyj danych uwierzytelniających użytkownika SSL serwera Kafka: ten wybór można wybrać, jeśli dla bezpiecznego połączenia z serwerem Kafka wprowadzono właściwości dla protokołu SSL . Konfiguracja certyfikatów z połączenia z serwerem Kafka będzie używana do bezpiecznego połączenia z usługą rejestru schematów.

  • protokół SSL

    • Certyfikaty magazynu zaufanych certyfikatów: Certyfikaty magazynu zaufanych certyfikatów w formacie PEM. Obsługiwane są tylko certyfikaty X.509 .
    • Klucz: klucz prywatny w formacie PEM. Klucz musi używać składni PKCS #8 .
    • Łańcuch certyfikatów kluczy: łańcuch certyfikatów dla klucza prywatnego w formacie PEM. Obsługiwane są tylko certyfikaty X.509 .
    • Hasło klucza: ta wartość jest wymagana, jeśli klucz jest zaszyfrowany.

Wybierz metodę tworzenia połączenia na podstawie miejsca, w którym użytkownik znajduje się na platformie

W projekcie
Kliknij opcję Zasoby > Nowy zasób > Narzędzia dostępu do danych > Połączenie. Więcej informacji na ten temat zawiera sekcja Dodawanie połączenia z projektem.

W katalogu
Kliknij opcję Dodaj do katalogu > Połączenie. Więcej informacji na ten temat zawiera sekcja Dodawanie zasobu połączenia do katalogu.

W Platform assets catalog
kliknij opcję Nowe połączenie. Patrz sekcja Dodawanie połączeń platformy.

Następny krok: dodawanie zasobów danych z połączenia

Miejsce, w którym można korzystać z tego połączenia

Połączenia Apache Kafka można używać w następujących obszarach roboczych i narzędziach:

Projekty

Katalogi

  • Platform assets catalog

  • Inne katalogi (Watson Knowledge Catalog)

    Uwaga:

    Podgląd, profil i maskowanie nie działają dla tego połączenia w katalogu Watson Knowledge Catalog.

Konfiguracja produktu Apache Kafka

Więcej inform.

DokumentacjaKafka

Temat nadrzędny: Obsługiwane połączenia

Generative AI search and answer
These answers are generated by a large language model in watsonx.ai based on content from the product documentation. Learn more