apache-zookeeper

0熱度

2回答

要啓動KAFKA，我們需要啓動動物園管理員。但在cloudera VM中，我認爲有zookeeper實例已在運行。那麼誰能告訴我如何通過VM終端檢查默認實例是否是runnig？此外，如果我們啓動一個zookeeper服務，我們可以看到記錄器屏幕，但如何檢查它的cloudera虛擬機。謝謝你，比什努

0熱度

1回答

Zookeeper爲什麼使手錶一次觸發？

動物園管理員的手錶是一次性觸發器;如果我收到一個觀看事件，並且想要知道未來的變化，我必須設置另一塊手錶。有一些缺點： 1）這使我的代碼複雜 2）是獲得該事件併發送一個新的請求得到一塊手錶之間的等待時間，一些變化可能會錯過！爲什麼Zookeeper會使手錶一次觸發？

0熱度

1回答

卡夫卡鏡像是否需要不同的動物園管理員合奏？

我知道卡夫卡鏡像正在跨不同的數據中心複製數據。我在這裏有一些問題 - 1）這些不同的數據中心是否需要不同的動物園管理員合奏？ 2）如果我們想要跨數據中心的2個機架複製數據，這些卡夫卡鏡像概念可以成爲一個不錯的選擇嗎？感謝

0熱度

1回答

Zookeeper設置2機架故障轉移處理

我想了解zookeeper設置的影響和設計，因爲卡夫卡依賴zookeeper進行操作。 Zookeeper指定2F + 1的節點設置爲可靠的容錯。考慮如果我有2個機架，並且我在機架A和機架B上設置了4個節點（總共9個動物園管理員節點）並且機架B關閉（5個動物園管理員節點關閉）。在那種情況下需要2F + 1，它需要11個動物園管理員節點，因爲我只有9個節點。因此，動物園管理員在機架故障的情況下更高的

0熱度

1回答

卡祖笛重啓飼養員，手錶拋出異常

我的配置：飼養員：3.4.10 操作系統：Ubuntu的16.04 蟒蛇：2.7 卡祖笛：2.3.1 我在IPython中運行的代碼：當我重新啓動飼養員，與bin/zkServer.sh restart，外殼顯示爲下面的異常：如果我刪除手錶和一個聽衆更換，收聽效果很好。我不知道爲什麼，我讀了google和github/kazoo的信息，但是我沒有發現如何解決問題的解釋。 PS：有人說，因爲

1熱度

1回答

無法停止kafka服務器和動物園管理員

我有kafka經紀人正在運行，我想停止kafka和zookeeper以進行一些修改並重新啓動所有操作（將log.retention.hours帶到4）。但是，命令：Kafka-server-stop似乎不起作用！卡夫卡服務器停止我有這樣的： PIDS=$(ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{prin

0熱度

1回答

指定網絡ip docker

我正在使用docker部署一個zookeeper合奏，並且遇到了一個問題，我認爲這是由於代理泊塢窗用於localhost的問題。編輯：問題是，當我關閉連接，他們留在TIME_WAIT 我想爲我的集裝箱IP例如改變爲其他的私有地址空間的東西192.168.0.0子網，看看是否解決了這個問題。任何指導，將不勝感激這裏是我目前的碼頭工人，compose.yml的一部分： version: '2'

1熱度

1回答

使用異步API在Zookeeper中創建節點

在尋找zookeeper時，接受的答案表示不允許併發寫入。 Explaining Apache ZooKeeper 現在我的問題是Zookeeper具有線性寫入，這不會阻止我使用異步API創建節點並在回調中採取響應？雖然內部可能不允許同時寫入，或者我錯過了什麼？

1熱度

1回答

無法啓動zookeeper服務器

我在做安裝zookeeper，同時設置zookeeper服務器，我得到低於出。服務器沒有啓動。 .10\bin>call "C:\Program Files\Java\jre1.8.0_111"\bin\java "-Dzookeeper.log.dir=C:\zookeeper-3.4.10\b :43,637 [myid:] - INFO [main:[email protected]] -

1熱度

2回答

卡夫卡經紀人對領導層變更的消息丟失情況

我想了解卡夫卡消息丟失的以下行爲。簡而言之，當一個經紀人很早就死去，隨後在一些消息處理之後，所有其他經紀人都會死亡。如果首先死亡的經紀人開始上市，那麼他們出現後就不會趕上其他經紀人。相反，所有其他經紀人都會報告錯誤並重置抵消額以匹配第一個經紀人。預期這種行爲，以及確保零消息丟失的更改/設置是什麼？卡夫卡版本：2.11-0.10.2.0 重現步驟開始1個飼養員實例和3個卡夫卡經紀人創建一個話題