apache-kafka

12Ciepło

2Odpowiedz

Czy ktoś może mi powiedzieć, jaki jest algorytm ponownego równoważenia dla konsumentów Kafki? Chciałbym zrozumieć, jak wpływa na to liczba partycji i wątki konsumenckie. Dziękuję

5Ciepło

2Odpowiedz

Kafka w systemie rozproszonym

Jestem nowy w kafce, używam kafka na jednym komputerze od teraz. Chcę uruchomić kafka w środowisku rozproszonym na wielu komputerach. Nie ma odpowiedniej dokumentacji do tego. Każda dokumentacja lub s

5Ciepło

3Odpowiedz

Dodawanie niestandardowych nagłówków w wiadomości Kafki

Wysyłam plik jako wiadomość, konwertując go do tablicy bajtów za pomocą producenta kafka. Potrzebuję również dodać nagłówki do wiadomości, na przykład nazwę pliku, sygnaturę czasową itp., Więc po stro

8Ciepło

1Odpowiedz

Konfiguracja kafka-net, aby przestać wysyłać najnowsze wiadomości

Używam kafka 0.8.1.1 na maszynie Red Hat VM z wtyczką kafka-net. Jak mogę skonfigurować mojego klienta, aby przestał otrzymywać wcześniejsze wiadomości od kafka? Mój kod konsument: var options = new K

13Ciepło

3Odpowiedz

Kafka - Nie można wysłać wiadomości do zdalnego serwera za pomocą Java

Próbuję utworzyć klaster Kafka, aby wysyłać wiadomości do pilota zdalnego sterowania. Skonfigurowałem wszystko zgodnie z opisem here. Uruchomiłem to na komputerze Linux red hat i działa dobrze przy uż

6Ciepło

1Odpowiedz

Błąd producenta Java Kafki

Zrobiłem producenta kafka java. , ale konsola podała błąd. serwer kafka jest na aws. a producent jest na moim macu. i jeszcze serwer kara jest osiągalny. Kiedy wysyłam wiadomość od producenta, serwer

28Ciepło

3Odpowiedz

zmiana okresu przechowywania kafka podczas wykonywania usługi

W przypadku Kafki 0.8.1.1, jak zmienić czas przechowywania dziennika w trakcie jego działania? documentation mówi nieruchomość jest , ale próbuje to zmienić za pomocą kafka-topics.sh zwraca ten błąd $

8Ciepło

3Odpowiedz

Usuwanie grupy konsumenckiej kafka w zookeeperze

Używam kafka_2.9.2-0.8.1.1 z zookeeperem 3.4.6. Czy istnieje narzędzie, które automatycznie usuwa grupę konsumentów z Zookeepera? Czy mogę po prostu usunąć wszystko z katalogu/consumer/[group_id] w zo

16Ciepło

1Odpowiedz

Czy możemy mieć silne możliwości routingu z Apache Kafka podobne do RabbitMq?

Próbujemy ocenić Kafkę i zastąpić Królik Mq w naszym oprogramowaniu. Znamy zalety Kafki pod względem RabbitMq w porównaniu z konsumpcją offline, ogromną trwałością, doskonałą wydajnością, małym opóźni

6Ciepło

2Odpowiedz

org.apache.spark.SparkException: Zadanie nie serializable

To jest przykład kodu robocze: JavaPairDStream<String, String> messages = KafkaUtils.createStream(javaStreamingContext, zkQuorum, group, topicMap); messages.print(); JavaDStream<String> lines = mess