Dodawanie źródła platformy Apache Kafka do strumienia zdarzeń (wersja zapoznawcza)

Artykuł
11/19/2024

W tym artykule pokazano, jak dodać źródło platformy Apache Kafka do strumienia zdarzeń.

Apache Kafka to rozproszona platforma typu open source do tworzenia skalowalnych systemów danych w czasie rzeczywistym. Dzięki zintegrowaniu platformy Apache Kafka jako źródła w strumieniu zdarzeń można bezproblemowo przenieść zdarzenia w czasie rzeczywistym z platformy Apache Kafka i przetworzyć je przed routingiem do wielu miejsc docelowych w usłudze Fabric.

Uwaga

To źródło nie jest obsługiwane w następujących regionach pojemności obszaru roboczego: Zachodnie stany USA3, Szwajcaria Zachodnia.

Wymagania wstępne

Dostęp do obszaru roboczego Sieć szkieletowa z uprawnieniami współautora lub wyższymi uprawnieniami.
Uruchomiony klaster platformy Apache Kafka.
Platforma Apache Kafka musi być publicznie dostępna i nie znajdować się za zaporą lub być zabezpieczona w sieci wirtualnej.

Uwaga

Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.

Dodawanie platformy Apache Kafka jako źródła

W obszarze Analiza w czasie rzeczywistym w sieci szkieletowej wybierz pozycję Eventstream , aby utworzyć nowy strumień zdarzeń.
Na następnym ekranie wybierz pozycję Dodaj źródło zewnętrzne.

Konfigurowanie platformy Apache Kafka i nawiązywanie z nią połączenia

Na stronie Wybieranie źródła danych wybierz pozycję Apache Kafka.
Na stronie Łączenie wybierz pozycję Nowe połączenie.
W sekcji Ustawienia połączenia w polu Bootstrap Server wprowadź adres serwera Apache Kafka.
W sekcji Poświadczenia połączenia jeśli masz istniejące połączenie z klastrem Apache Kafka, wybierz je z listy rozwijanej Połączenie. W przeciwnym razie wykonaj następujące kroki:
1. W polu Nazwa połączenia wprowadź nazwę połączenia.
2. W polu Rodzaj uwierzytelniania upewnij się, że wybrano pozycję Klucz interfejsu API.
3. W polu Klucz i Wpis tajny wprowadź klucz interfejsu API i klucz tajny.
Wybierz pozycję Połącz. 
Teraz na stronie Łączenie wykonaj następujące kroki.
1. W polu Temat wprowadź temat platformy Kafka.
2. W polu Grupa odbiorców wprowadź grupę odbiorców klastra platformy Apache Kafka. To pole zawiera dedykowaną grupę odbiorców na potrzeby pobierania zdarzeń.
3. Wybierz pozycję Resetuj automatyczne przesunięcie , aby określić, gdzie rozpocząć odczytywanie przesunięć, jeśli nie ma zatwierdzenia.
4. W polu Protokół zabezpieczeń wartość domyślna to SASL_PLAINTEXT.
  
  Uwaga
  
  Źródło platformy Apache Kafka obsługuje obecnie tylko nieszyfrowaną transmisję danych (SASL_PLAINTEXT i PLAINTEXT) między klastrem Platformy Apache Kafka i strumieniem zdarzeń. Obsługa szyfrowanej transmisji danych za pośrednictwem protokołu SSL będzie dostępna wkrótce.
5. Domyślny mechanizm SASL jest zwykle zwykły, chyba że skonfigurowano inaczej. Można wybrać mechanizm SCRAM-SHA-256 lub SCRAM-SHA-512 , który odpowiada wymaganiom w zakresie zabezpieczeń.
Wybierz Dalej. Na ekranie Przeglądanie i tworzenie przejrzyj podsumowanie, a następnie wybierz pozycję Dodaj.