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
Postępuj zgodnie z instrukcjami krok po kroku w artykule Tworzenie centrum zdarzeń , aby utworzyć przestrzeń nazw usługi Event Hubs i centrum zdarzeń.
Parametry połączenia
Wykonaj kroki opisane w artykule Pobieranie parametrów 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 centrum zdarzeń. Nazwę FQDN można znaleźć w parametrach 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 pliku, 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 strukturze, znajdź konfiguracje używane do ustawiania nazwy użytkownika i hasła SASL i użyj ich zamiast tego. Ustaw nazwę użytkownika na $ConnectionString 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 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. Wyświetlenie komunikatów odebranych może potrwać kilka sekund.
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: