apache-kafka

8Ciepło

2Odpowiedz

Apache Storm java.nio.channels.ClosedChannelException: null

Próbujemy użyć Apache Storm do przetwarzania dużej ilości (fałszywych) wiadomości. Przykładem Wiadomość: "{"clientName":"Sergey Bakulin","sum":12925,"group":"property","suspicious":false,"clientId":2,

5Ciepło

2Odpowiedz

burza nimbus nie zaczyna się: Powrót poniżej błędu

$ storm nimbus Traceback (most recent call last): File "/home/chefsolo/apache-storm-0.9.1-incubating/bin/storm", line 455, in <m odule> main() File "/home/chefsolo/apache-

5Ciepło

1Odpowiedz

Jak powinniśmy czytać tematy Kafki w danym przedziale czasowym?

Muszę przeczytać wiadomości w danym przedziale czasowym z tematu Kafki. Rozwiązaniem, które przychodzi mi na myśl, jest najpierw znalezienie największego przesunięcia na początku zakresu czasowego, a

5Ciepło

2Odpowiedz

Integracja Camel Kafka

Ostatnio zauważyłem, że Camel ma teraz swój własny komponent dla Kafki, więc postanowiłem dać mu wir. postanowiłem spróbować piękny prosty plik -> temat Kafka następująco ... <route> <from uri="

5Ciepło

1Odpowiedz

Domyślny koder Apache Kafka nie działa

Używam Kafki 0.8 beta, a ja po prostu próbuję zadzwonić z wysyłaniem różnych obiektów, serializując je za pomocą mojego własnego kodera i wysyłając je do istniejącej konfiguracji brokera. Na razie sta

11Ciepło

6Odpowiedz

Jak uzyskać listę tematów z serwera kafka w Javie

Używam wersji kafka 0.8 i bardzo wiele nowych. Chcę poznać listę tematów utworzonych w kafka server wraz z jej metadanymi . Czy jest dostępne jakieś API, aby się tego dowiedzieć? Zasadniczo, muszę nap

9Ciepło

2Odpowiedz

dlaczego plik .index istnieje w katalogu kafka-log?

Właśnie napisałem nowy temat, nie napisałem jeszcze żadnej wiadomości. Plik o nazwie "00000000000000000000.index" utworzony w katalogu "/ tmp/kafka-logs-1/topicname-0 /", a rozmiar tego pliku jest nap

9Ciepło

1Odpowiedz

Kafka: Nie mogę tworzyć wielu klientów strumieniowych

Po prostu zacząłem działać z Kafką 0.8 beta 1. Mam naprawdę prosty przykład i działa, problem polega na tym, że mogę uzyskać tylko jednego klienta do pracy, a nie kilku. Oznacza to, że działa metoda r

8Ciepło

2Odpowiedz

Wpisanie danych offsetu do zookeepera w kafkowskiej burzy

Utworzenie klastra burzowego do obliczania trendów w czasie rzeczywistym i innych statystyk, jednak mam pewne problemy z wprowadzeniem funkcji "odzyskiwania" do tego projektu, umożliwiając przesunięci

5Ciepło

1Odpowiedz

Kafka Tylko jeden konsument w Consumer Group Pierwsze wiadomości

W mojej konfiguracji mam grupę konsumentów z trzema procesami (3 wystąpienia usługi), które mogą spożywać od Kafki. To, co odkryłem, że się dzieje, to to, że pierwszy węzeł odbiera cały ruch. Jeśli je