apache-kafka
Kafka QuickStart, advertised.host.name daje Kafkę.pospolite.LeaderNotAvailableException
Jestem w stanie uzyskać prostą Kafkę z jednym węzłem (kafka_2.11-0.8.2.1) działającą lokalnie na jednej maszynie linuksowej, ... rs(AdminUtils.scala:70)
Zakładam, że oznacza to, że brokera nie można znaleźć z jakiegoś powodu? Nie wiem, co to znaczy...
Jak działa Zrównoważenie konsumentów w Kafka?
Gdy nowy konsument/brorker jest dodawany lub wyłączany, Kafka uruchamia operację równoważenia. Czy zmiana równowagi Kafki jest operacją blokującą? Czy konsumenci Kafki są blokowani podczas trwającej operacji przywracania równowagi?
Java, Jak uzyskać ilość wiadomości w temacie w apache kafka
Używam Apache kafka do przesyłania wiadomości. Zaimplementowałem producenta i konsumenta w Javie. Jak możemy uzyskać liczbę wiadomości w temacie?
Czy klucz jest wymagany w ramach wysyłania wiadomości w Kafce
KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(),Serial ... łać z delete.retention.ms , Czy muszę wysłać klucz jako część wiadomości? Czy dobrze jest zrobić klucz jako część wiadomości
Dlaczego konsumenci Kafki łączą się z zookeeperem, a producenci otrzymują metadane od brokerów?
Dlaczego konsumenci łączą się z zookeeperem, aby odzyskać lokalizacje partycji? A producenci Kafki muszą połączyć się z jedny ... st jakaś funkcja, którą mi brakuje? Trudno mi wymyślić powód, dla którego zookeeper jest naprawdę potrzebny w klastrze Kafki.
kafka get partition count for a topic
Jak mogę uzyskać Ilość partycji dla dowolnego tematu Kafki z kodu. Sprawdziłem wiele linków, ale żaden nie działa.
Kilka:
... of-a-topic
Które wyglądają jak podobne dyskusje.
Są też podobne linki NA SO, które nie mają na to działającego rozwiązania.
Amazon zarządzane strumieniowanie dla Kafka - funkcje i wydajność MSK
Oceniam AWS Managed Service Kafka (MSK) i Wiem, że obecnie jest w trybie podglądu, stąd może nie mieć wszystkich funkcji lub ... benchmark wydajności w porównaniu z vanilla kafka? A jaka jest maksymalna liczba brokerów, które mogą być lauched w klastrze?
Jak uzyskać dostęp do interfejsu JMX w dockerze z zewnątrz?
Próbuję zdalnie monitorować JVM w dockerze. Konfiguracja wygląda tak:
Maszyna 1: uruchamia JVM (w moim przypadku działa k ... 0.1.203 netmask 0xffffff00 broadcast 10.0.1.255
nd6 options=1<PERFORMNUD>
media: autoselect
status: active
Kafka Consumer Rebalancing Algorithm
Czy ktoś może mi powiedzieć, czym jest algorytm równoważenia dla konsumentów Kafki? Chciałbym zrozumieć, jak liczenie partycji i wątki konsumenckie wpływają na to.
Dziękuję,
Jak kodować / dekodować wiadomości Kafka za pomocą Avro binary encoder?
Próbuję użyć Avro do odczytywania/pisania wiadomości do Kafki. Ma ktoś może przykład użycia kodera binarnego Avro do kodowani ... e rozwiązanie dla JSON w odniesieniu do przestrzeni. Avro właśnie wspomniano, ponieważ może być bardziej kompaktowy niż JSON.
Kiedy klient Apache Kafka wyrzuca wyjątek "Batch Expired"?
Używając Apache Kafka Java client (0.9), Próbuję wysłać długą serię rekordów do brokera używając Kafka Producer class.
Asyn ... ucać wyjątki (TimeoutException), z Komunikatem "batch expired".
Jakie okoliczności powodują, że wyjątek ten jest wyrzucony?
Kafka, SNS czy coś innego?
Przepraszam, jeśli to pytanie dla początkujących. Ale staram się zrozumieć, czego powinienem użyć. Z tego co rozumiem Kafka j ... rwszą myślą było użycie SNS i SQS. Ale niż widziałem wiele osób używających Kafki na AWS. Jakie są zalety jednego nad drugim?
Jak zminimalizować opóźnienia związane z kafka messaging framework?
Scenariusz: mam mały temat (~150msgs/sec) dla którego chcielibyśmy mieć
niskie Opóźnienie propagacji od producenta do konsume ... zwykle najdroższą operacją.
Więc, uważam, że nie ma sposobu, aby zejść do znaku 150ms - 250ms. (bez aktualizacji sprzętu) .
Kafka: Get broker host from ZooKeeper
Ze szczególnych powodów muszę używać zarówno - ConsumerGroup (Alias konsument wysokiego szczebla) jak i SimpleConsumer (Alias ... ieć:
jeśli jest to właściwa droga, Jak prawidłowo odczytać te węzły?
jeśli całe podejście jest złe, co jest właściwe ?
Jak zmienić repliki tematu kafka?
Po jednym temacie stworzonym przez producenta lub Administratora, jak zmienić numer replik tego tematu?(zwiększ lub zmniejsz liczbę replik.)
Kafka-jak zatwierdzić offset po każdej wiadomości za pomocą wysokiego poziomu konsumenta?
Korzystam z usług wysokiej klasy konsumenta Kafki. Ponieważ używam Kafki jako "kolejki transakcji" dla mojej aplikacji, muszę ... em może być lokalne śledzenie offsetów? Czy ta alternatywna metoda jest zalecana? Jeśli tak, to jak byś się do tego zbliżył?
Kafka Msg VS REST Calls
Obecnie w świecie mikroserwisów widzę wiele projektów w moim miejscu pracy, które wykorzystują wiadomości kafka, gdy można os ... je jako wiadomość do tematu kafka, aby zostały zużyte przez usługę inwentaryzacji
Którą drogę byś wybrał i jaka jest ocena
Jak wyeksponować usługę bez głowy dla StatefulSet zewnętrznie w Kubernetes
Dzięki temu, że nie ma problemu, nie ma problemu.
Do wykrywania usług w klastrze używane są StatefulSet i usługa bez głowy. ... b jeden możliwy) sposób na to? Czy możliwe jest wystawienie serwis zewnętrzny za kafka-x.broker.kafka.svc.cluster.local:9092?
Kafka: Consumer API vs Streams API
Ostatnio zacząłem uczyć się Kafki i kończę z tym pytaniem.
Jaka jest różnica między konsumentem a strumieniem? Dla mnie, je ... iej?
I did Google na to, ale nie dostał żadnych dobrych odpowiedzi na to. Przepraszam, jeśli to pytanie jest zbyt trywialne.
Jak napisać plik do producenta Kafka
Próbuję załadować prosty plik tekstowy zamiast standardowego wejścia w Kafce.
Po pobraniu Kafki wykonałem następujące kroki: ... towy do producenta, który może być widoczny bezpośrednio przez Konsumenta. Każda pomoc będzie naprawdę mile widziana. Dzięki!