apache-zookeeper

    1熱度

    1回答

    我使用zookeeper與策展人2.12.0。 我正在通過調用getChildren(我不知道完整的節點路徑)來成功觀察新節點,觀察者再次向觀察者提交調用getChildren的任務。 現在我想看節點刪除,只有刪除。我給觀察者打電話checkExists。但是,如果由於某種原因節點不存在,它實際上將成爲節點創建的守護者,這在我的情況下永遠不會發生。所以我會留下越來越多的「顛簸」觀察者,這將浪費我想

    0熱度

    1回答

    我想我的Ubuntu機器上安裝飼養員和動物園管理員,服務器,這些都是我做的步驟: - 添加的關鍵 捲曲-s http://archive.cloudera.com/cdh5/ubuntu/trusty/amd64/cdh/archive.key | sudo易於鍵添加 - 我加linesto我/etc/apt/sources.list.d/cloudera.key 的deb [ARCH = AMD

    0熱度

    1回答

    我有一個基於用戶輸入創建文件的API。我需要通過一個集羣來分發這個文件,這樣一個文件只能在1個節點上。我可以使用zookeeper來實現這一點,以及如何? 用戶可能想要刪除該文件。這意味着當被問到時,zookeeper需要從節點中刪除文件。 我已經讀過zookeeper wiki,但很難理解如何/何時使用它。

    0熱度

    1回答

    我想了解zookeeper的日誌格式,以便我可以爲此寫一個正則表達式,但是我找不到任何文章中究竟出現了什麼日誌 下面是來自zookeeper的日誌行。有人可以幫助我在[]之間進行登錄嗎?它是包名/類名嗎?什麼0.0.0.0代表? 2017年8月8日08:13:25635 - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServe

    0熱度

    1回答

    通常kafka-configs.sh用於使用該命令 > bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=alice-secret],SCRAM-SHA-512=[password=alice-secret]' --entity-

    0熱度

    2回答

    我正在使用融合平臺,動物園管理員處於活動狀態查找狀態。但是當我嘗試用合流開始卡夫卡時,它顯示動物園管理員已關閉。 $ sudo service zookeeper status Redirecting to /bin/systemctl status zookeeper.service ● zookeeper.service - Zookeeper Loaded: loaded (/

    1熱度

    3回答

    這是我的Java HBase的CREATETABLE以下程序: - public class createtable { public static void main(String[] args) throws IOException { Configuration conf = HBaseConfiguration.create(); con

    0熱度

    1回答

    我目前正在嘗試使用configuration provided as an example在Marathon上部署Eremetic(版本0.28.0)。我實際上已經能夠部署它一次,但突然間,在嘗試重新部署它之後,框架保持不活動狀態。 通過檢查日誌,我注意到一個不斷的嘗試連接到某些服務,顯然由於某些身份驗證問題從未成功。 2017/08/14 12:30:45 Connected to [REDAC

    1熱度

    1回答

    我有一個kafka連接插件,部署在一個kafka集羣中(獨立模式下,僅用於測試,其想法是分發)。此kafka連接插件使用管理員連接到羣集的zookeper,並從中獲取一些信息以決定如何處理這些消息。 的代碼是這樣的: protected CuratorFramework getCurator(final String zkConnection) { final CuratorFramew

    2熱度

    1回答

    內人跡罕至,一旦我需要在(使用Minikube)本地Kubernetes實例運行卡夫卡,並有向Minikube VM外部客戶端應用程序(發佈者和訂閱)訪問所產生的卡夫卡服務。 我的一切行動和Minikube運行,但我想,我已經做了配置錯誤,因爲我不能從外部訪問卡夫卡。我已經閱讀過類似的問題,並嘗試瞭解決方案,但是他們都沒有爲我解決這個問題。 我已經發布了我的YAML配置文件https://gith