apache-kafka

8Ciepło

2Odpowiedz

Połączyć wyniki z partii RDD z strumieniowaniem RDD w Apache Spark

Kontekst: Używam Apache Spark do agregowania liczby uruchomień różnych typów zdarzeń z logów. Dzienniki są przechowywane w obu Cassandra do celów analizy historycznej i Kafka do celów analizy w czasie

5Ciepło

6Odpowiedz

Kafka węzeł, konsument dostaje zawsze stare wiadomości

im pomocą modułu Kafki węzeł https://github.com/SOHU-Co/kafka-node i za każdym razem, kiedy ponownie uruchomić konsumenta dostali wszystkie stare wiadomości, IM za pomocą okrągłego systemu Robin (load

8Ciepło

1Odpowiedz

WebSocket zamyka się po 1000 wiadomościach

Piszę aplikację do przesyłania wiadomości do przeglądarki z Apache Kafka za pomocą WebSocket. Gdy serwer nie zużywa komunikatów przez pewien czas, a przesunięcie się kończy, websocket zamyka się po 10

57Ciepło

3Odpowiedz

ActiveMQ vs Apollo vs Kafka

Nie mam żadnego wcześniejszego doświadczenia z * MQs i zamierzam budować wiedzę na temat JMS i ogólnie kolejki wiadomości. W ten sposób, zastanawiam się, czy powinienem zacząć od ActiveMQ, czy po pros

9Ciepło

7Odpowiedz

Nie znaleziono klasy KafkaUtils w Spark streaming

Właśnie zacząłem od Spark Streaming i próbuję zbudować przykładową aplikację, która zlicza słowa ze strumienia Kafka. Chociaż kompiluje się z sbt package, po uruchomieniu otrzymuję NoClassDefFoundErro

9Ciepło

5Odpowiedz

Jak utworzyć temat w kafejce Apache za pomocą pythona

Do tej pory nie widziałem klienta Pythona, który implementuje tworzenie tematu jawnie bez użycia opcji konfiguracji do automatycznego tworzenia tematów.

5Ciepło

1Odpowiedz

Jak utworzyć Kafka ZKStringSerializer w Javie?

W poszukiwaniu sposobu tworzenia tematu Kafka poprzez API, znalazłem ten przykład w Scala: import kafka.admin.AdminUtils import kafka.utils.ZKStringSerializer import org.I0Itec.zkclient.ZkClient /

7Ciepło

1Odpowiedz

Kafka - najprostszy sposób na uzyskanie ostatniej offsetu

Buduję aplikację, która umożliwia dynamiczne dodawanie i usuwanie subskrypcji tematów kafka. Po dodaniu subskrypcji tematów chciałem co godzinę uruchomić zadanie wsadowe, które pobiera wszystkie nowe

6Ciepło

3Odpowiedz

jaka jest różnica między partycją a repliką tematu w klastrze kafki

Czym różnią się partycje od repliki tematu w klastrze kafka. Mam na myśli przechowywanie kopii wiadomości w temacie. Więc jakie jest prawdziwe zróżnicowanie?

20Ciepło

1Odpowiedz

Jak działa rebalancing konsumenta w Kafce?

Po dodaniu lub opuszczeniu nowego konsumenta/brokera, Kafka uruchamia operację równoważenia. Czy Kafka Rebalancing jest operacją blokującą. Czy konsumenci Kafki są zablokowani podczas operacji równowa