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 sugestia na ten temat będzie naprawdę pomocna.Kafka w systemie rozproszonym
Odpowiedz
Zasadniczo trzeba wykonać follwing
1) Ustaw Kafka na wszystkich komputerach
2) Skonfiguruj właściwości config/server1.properties
plik, aby określić unikalną id
dla każdej maszyny. Możesz to zrobić, ustawiając właściwości broker.id
w pliku konfiguracyjnym. na przykład broker.id=1
, broker.id=2
. Dla każdego brokera ten identyfikator powinien być unikalny. W ten sposób każdy węzeł jest identyfikowany w klastrze kafka.
3) Uruchom kafka we wszystkich węzłach.
Możesz odnieść Step 6: Setting up a multi broker cluster z oficjalnej strony szybkiego uruchamiania.
także here jest ładny artykuł warto zajrzeć
Dodawanie do poprzedniej odpowiedzi przez user2720864
Załóżmy, że jest potrzebny układ Kafka z poniższej konfiguracji.
7 Kafka węzłów
3 właścicieli zoo
celu osiągnięcia tej instalacji 7 przypadków Kafka w 7 serwera/vm (wystąpienia), a w każdym z tych przypadków ustawić inny pośrednika-ID ten pozwoli Zookeeperowi zidentyfikować różne węzły kafka do prowadzenia księgowości, konserwacji. broker.id = X (/config/server.properties)
Aby uruchomić zookeepers, możesz użyć 3 z poprzednich instancji kafka lub użyć nowych serwerów do uruchomienia zookeepers. Po ustaleniu serwerów, na których działają zookeepery, zmień plik /config/server.properties, aby określić zookeepers.
zookeeper.connect = hostname1: port1, hostname2: port2
W rozproszonym środowisku dobrze jest mieć 3 hodowców zoo. Podczas gdy istnieje tylko jeden zookeeper, który działa jako prawdziwy mistrz, pozostałe 2 zookeepery działają jako fail-over. Kiedy master zawiedzie, jeden z dwóch ZK przejmie rolę mistrza.
Znalazłem ten link za bardzo przydatne, pomógł mi wyjaśnić wiele rzeczy na temat architektury kafka.
This to dobre odniesienie dla wszystkich konfiguracji plików właściwości w kafejce.
Mam nadzieję, że to pomoże!
Dzięki za sugestie postaram się udzielić wyczerpującej odpowiedzi. – smadhava
- 1. Jak obliczyć rozkład (Histogram) dużej ilości danych w systemie rozproszonym?
- 2. Które dodatki powinny być używane w systemie rozproszonym? Jak je skonfigurować?
- 3. Dowiedz się więcej o przetwarzaniu rozproszonym
- 4. Generator liczb losowych o prawdopodobieństwie rozproszonym
- 5. wyświetlanie czasu w zegarze z wykresem rozproszonym xy w r
- 6. Kafka Serializacja obiektu
- 7. java.lang.NoClassDefFoundError: Kafka/common/TopicAndPartition
- 8. Kafka CommitFailedException wyjątek konsument
- 9. Spark Streaming Kafka stream
- 10. Kafka rzuca java.nio.channels.ClosedChannelException
- 11. Integracja Camel Kafka
- 12. Algorytm Rebalancing Konsumentów Kafka
- 13. Pełne wykorzystanie wszystkich rdzeni w trybie pseudo-rozproszonym Hadoop
- 14. Usuwanie grupy konsumenckiej kafka w zookeeperze
- 15. Jak utworzyć Kafka ZKStringSerializer w Javie?
- 16. Jak wdrożyć Kafka Consumer w Scala
- 17. Różnica między Redis a kafka
- 18. Jak ładuje się saldo kafka?
- 19. Czy Kafka ma konsumenta wsadowego?
- 20. flume vs kafka vs inni
- 21. ActiveMQ vs Apollo vs Kafka
- 22. Confluent Platform vs Apache kafka
- 23. jak korzystać z kafka acls?
- 24. Błąd rejestru Kafka: Nie udało się zapisać rekordu Noop w sklepie kafka
- 25. Kafka: Jak włączyć rejestrowanie klienta?
- 26. Dlaczego "dołączenia" zmniejszają skalowalność w wielkoskalowym systemie rozproszonej bazy danych?
- 27. Apache Kafka Grupa konsumentów i prosty konsument
- 28. Wiele wylewek Storm-Kafka, jak podzielić ładunek?
- 29. Kafka Producent NetworkException i Timeout wyjątkami
- 30. Spring Kafka asynchroniczne wysyłanie bloków blokowych
Czy myślisz o [coś w tym stylu] (http://kafka.apache.org/documentation.html#distributionimpl)? –
Chcę, aby producent działał w innym systemie, brokerów na wielu systemach i konsumenta w innym systemie, aby go skonsumować. –
działający producent/konsument w samodzielnej maszynie nie przyniesie Ci wiele korzyści. Należy dążyć do rozpowszechniania aplikacji w klastrze, aby zrównoważyć obciążenie i zwiększyć przepustowość. Na przykład W przypadku producentów, podczas pracy w trybie asynchronicznym, poziom równoległości zależy od liczby brokerów obecnych w klastrze. – user2720864