apache-kafka

6Ciepło

2Odpowiedz

Jak sprawić, by kafka stał się czytelnikiem z ostatnio skonsumowanego offsetu, ale nie od początku.

Jestem nowy w kafce i próbuję zrozumieć, czy istnieje sposób na odczytanie wiadomości z ostatniego przesuniętego przesunięcia, ale nie od początku. Piszę przykładowy przypadek, więc moja intencja nie

6Ciepło

1Odpowiedz

Strumień wyjściowy Apache Spark w Pythonie

Próbuję technologii, które będę używać do budowania potoku danych w czasie rzeczywistym, i mam uruchomić niektóre problemy eksportowania mojej zawartości do pliku. Mam zainstalowanego lokalnego klastr

8Ciepło

4Odpowiedz

Maksymalna liczba powtórzeń krotki na wylocie Storm Kafka

Używamy burzy z wylewką Kafki. Gdy zawiadamiamy o błędach, chcielibyśmy je odtworzyć, ale w niektórych przypadkach złe dane lub błędy w kodzie spowodują, że wiadomości będą zawsze zawierane przez Bolt

10Ciepło

3Odpowiedz

Czy Apache Kafka jest w stanie obsłużyć transakcje?

planujemy wykorzystać Kafkę jako główny komponent w naszej hurtowni danych, biorąc pod uwagę, że producent jest w stanie obsługiwać transakcje (w skrócie: wycofywanie zmian i zatwierdzenia). Kiedy goo

11Ciepło

6Odpowiedz

Błąd podczas tworzenia tematów Kafki - Współczynnik replikacji większy niż dostępne brokery

Próbuję tworzyć tematy w Kafce, postępując zgodnie z przewodnikiem po witrynie Apache Kafka za pośrednictwem wiersza poleceń. Podczas uruchamiania polecenia: bin/kafka-topics.sh --create --zookeeper l

12Ciepło

1Odpowiedz

Tworzenie systemu powiadamiania push w czasie rzeczywistym dla aplikacji komputerowych/mobilnych/internetowych przy użyciu kafka jako brokera komunikatów

Mam przypadek użycia, w którym musi istnieć komunikacja w czasie rzeczywistym między serwerami i klientami w czasie rzeczywistym, zgodnie ze wzorcem powiadamiania pub/sub . Producenci będą serwerami w

7Ciepło

2Odpowiedz

Jak utworzyć InputDStream z przesunięciami w PySpark (używając KafkaUtils.createDirectStream)?

Jak korzystać z KafkaUtils.createDirectStream z przesunięciami dla określonego Topic w Pyspark?

5Ciepło

5Odpowiedz

przy użyciu protokołu mqtt z kafka jako brokera wiadomości

Jak możemy używać protokołu mqtt z kafka jako brokerem wiadomości? Klienci (aplikacje Android/iOS/desktop java itp.) Będą produkować i konsumować wiadomości za pomocą bibliotek po stronie klienta mqtt

7Ciepło

1Odpowiedz

Jak wyświetlić listę producentów w kafce

Tak jak monitor Kafka Offset Monitor może wyświetlać listę aktywnych konsumentów danego tematu, czy istnieje narzędzie lub interfejs wiersza poleceń lub cokolwiek, co może zawierać nazwę producentów p

10Ciepło

4Odpowiedz

Lista konsumentów Kafki

Muszę znaleźć sposób, aby poprosić Kafkę o listę tematów. Wiem, że mogę to zrobić za pomocą skryptu kafka-topics.sh zawartego w katalogu bin\. Kiedy już będę mieć tę listę, potrzebuję wszystkich konsu