Migracja do usługi Azure Event Hubs z ekosystemu Apache Kafka
Usługa Azure Event Hubs uwidacznia punkt końcowy platformy Apache Kafka, który umożliwia nawiązywanie połączenia z usługą Event Hubs przy użyciu protokołu Kafka. Dokonując minimalnych zmian w istniejącej aplikacji platformy Kafka, możesz nawiązać połączenie z usługą Azure Event Hubs i czerpać korzyści z ekosystemu platformy Azure. Usługa Event Hubs współpracuje z wieloma istniejącymi aplikacjami platformy Kafka, w tym z aplikacją MirrorMaker. Aby uzyskać więcej informacji, zobacz Event Hubs for Apache Kafka (Usługa Event Hubs dla platformy Apache Kafka)
Przed migracją
Tworzenie konta platformy Azure
Jeśli nie masz subskrypcji platformy Azure, przed rozpoczęciem utwórz bezpłatne konto.
Tworzenie przestrzeni nazw usługi Event Hubs
Aby utworzyć przestrzeń nazw usługi Event Hubs i centrum zdarzeń, postępuj zgodnie z instrukcjami krok po kroku w artykule Tworzenie centrum zdarzeń.
Connection string
Wykonaj kroki opisane w artykule: Pobieranie parametry połączenia z portalu. Zanotuj parametry połączenia do późniejszego użycia.
w pełni kwalifikowanej nazwy domeny (FQDN),
Może być również potrzebna nazwa FQDN wskazująca przestrzeń nazw usługi Event Hubs. Nazwę FQDN można znaleźć w parametry połączenia w następujący sposób:
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Jeśli przestrzeń nazw usługi Event Hubs jest wdrożona w chmurze innej niż publiczna, nazwa domeny może się różnić (na przykład *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net lub *.servicebus.cloudapi.de).
Migracja
Aktualizowanie konfiguracji klienta platformy Kafka
Aby nawiązać połączenie z centrum zdarzeń z obsługą platformy Kafka, należy zaktualizować konfiguracje klienta platformy Kafka. Jeśli masz problemy ze znalezieniem Twoich danych, spróbuj wyszukać lokalizację bootstrap.servers ustawioną w aplikacji.
Wstaw następujące konfiguracje wszędzie tam, gdzie ma sens w aplikacji. Pamiętaj, aby zaktualizować bootstrap.servers wartości i sasl.jaas.config , aby skierować klienta do punktu końcowego platformy Kafka usługi Event Hubs przy użyciu poprawnego uwierzytelniania.
bootstrap.servers={MYNAMESPACE}.servicebus.windows.net:9093
request.timeout.ms=60000
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{CONNECTION STRING TO YOUR NAMESPACE}";
Jeśli sasl.jaas.config nie jest obsługiwaną konfiguracją w twojej strukturze, znajdź konfiguracje używane do ustawiania nazwy użytkownika i hasła w warstwie Simple Authentication and Security Layer (SASL) i użyj ich zamiast tego. Ustaw nazwę użytkownika na $ConnectionString wartość i hasło na parametry połączenia usługi Event Hubs.
Po migracji
Uruchom aplikację platformy Kafka, która wysyła zdarzenia do centrum zdarzeń. Następnie sprawdź, czy centrum zdarzeń odbiera zdarzenia przy użyciu witryny Azure Portal. Na stronie Przegląd przestrzeni nazw usługi Event Hubs przejdź do widoku Komunikaty w sekcji Metryki. Odśwież stronę, aby zaktualizować wykres. Może upłynąć kilka sekund, aby pokazać, że komunikaty są odbierane.
Następne kroki
Aby dowiedzieć się więcej o usłudze Event Hubs i usłudze Event Hubs dla platformy Kafka, zobacz następujące artykuły: