apache-zookeeper

0熱度

2回答

我'初學者卡夫卡 1 /我下載卡夫卡的1.0.0版本 2 /我在bith server.properties更改的數據目錄位置和屬性zookeeper.properties \設置\ server.properties \ CONFIG \ zookeeper.properties 3 /當我嘗試啓動動物園管理員和卡夫卡服務器我有一個錯誤「Files was unexpected」 D：\ ka

2熱度

2回答

卡夫卡緩存zkVersion不等於在動物園管理員經紀人不恢復

我有一個卡夫卡羣集與3個經紀人。我最近開始面臨問題，經紀人離開集羣，產品/消費者拋出領導者沒有可用的錯誤。事件在檢查日誌我看到下面的順序： //很多副本提取程序線程的啓動/停止 [2017-10-09 14:48:50,600] INFO [ReplicaFetcherManager on broker 6] Removed fetcher for partitions [2017-10-0

2熱度

2回答

策展人InterProcessMutex vs InterProcessSemaphoreMutex

InterProcessMutex與InterProcessSemaphoreMutex有什麼區別？ docs說InterProcessSemaphoreMutex是相同的InterProcessMutex除了它不是可重入。但我不知道什麼折返的意思。

0熱度

1回答

卡夫卡分區領導人選舉失敗後，不受控制的經紀人關機

我們有3卡夫卡經紀人和主題與40個分區和複製因子設置爲1.在一些分區失控的卡夫卡經紀人關閉後，我們看到，它是不可能選出新的領導者（請參閱下面的日誌）。最終我們無法讀到這個話題。請注意，如果可以在不改變複製因子大於1的情況下倖存這種類型的崩潰。我們希望我們的目標數據庫具有一致的狀態（基於kafka主題的事件創建），所以我們還將參數unclean.leader.election.enable設置爲

0熱度

1回答

如果我爲每個ZooKeeper集羣使用Curator框架的多個實例，會產生什麼後果？

在Apache館長網站，此 http://curator.apache.org/curator-framework/index.html 重要的說明：CuratorFramework實例是線程安全的。您應該在您的應用程序中爲每個ZooKeeper集羣共享一個CuratorFramework。但是，如何使用多個實例很糟糕？我會得到那種方式有什麼缺點？

0熱度

1回答

Apache Kafka：生產者-Consume API沒有在GCP上運行

我一直試圖在Kafka集羣上運行我的生產者和消費者api，但它不工作。 1）動物園管理員是在一個GCP VM實例運行 2）卡夫卡正在另一個GCP VM實例運行步驟如下：步驟1）使用運行動物園管理員以下命令： bin/zookeeper-server-start.sh config/zookeeper.properties 個Zookeeper.properties： #the direct

0熱度

2回答

Confluent模式註冊管理機構偏移管理

我們使用Confluent模式註冊機構作爲Avro模式回購。我所觀察到的是Zookeeper中沒有消費者偏移量管理。是否因爲Schema Registry的設計方式 - 不是在Zookeeper中存儲偏移量，而是在Kafka中存儲偏移量，還是在Kafka中壓縮日誌/主題的情況下是標準設計模式？

1熱度

1回答

不能從Python代碼

產生卡夫卡我有這個模塊運行（所有地方）：的ZooKeeper 卡夫卡服務器卡夫卡消費者 Python腳本在劇本有send()電話： producer = KafkaProducer(bootstrap_servers=['localhost:9092']) producer.send('test', 'entry1') 每15秒左右。卡夫卡服務器上的幾乎每一個send() 調用產生這些

0熱度

3回答

Apache Kafka + Apache Camel集成+ POC問題java.util.Hashtable.put上的java.lang.NullPointerException（Hashtable.java:459）

這是我的路由生成器。在這裏，我試圖從我的文件插入數據topic.Later，我通過我的主要方法，並使用駱駝上下文我運行它。我嘗試了幾個代碼，但沒有人幫助我。我正在開發Apache kafka的POC - 駱駝。 public class SimpleRouteBuilder extends RouteBuilder { @Override public void config

-1熱度

1回答

Solr雲：等待4000ms後未找到註冊的領導者

我已經創建了6個集合，每個集合有3個分片和2個副本（solr版本5.5.0）。幾天後我的設置工作正常。但幾天之後，我收到以下錯誤： Error while trying to recover. core=Collection1_shard3_replica2:org.apache.solr.common.SolrException: No registered leader was found a