莊周夢蝶

你看，偏見是可以改變的。
:)

你不在淘寶了？

@changedi
嗯，上個月離職了

2012-05-10 15:46:21 [ pool-2-thread-1:15156 ] - [ ERROR ] 獲取ZKLoadRebalanceListener失敗
java.util.concurrent.ExecutionException: java.lang.NullPointerException
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper.getBrokerConnectionListener(ConsumerZooKeeper.java:100)
at com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper.commitOffsets(ConsumerZooKeeper.java:89)
at com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer$1.run(SimpleMessageConsumer.java:113)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:181)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:205)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.lang.NullPointerException
at com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper$1.call(ConsumerZooKeeper.java:169)
at com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper$1.call(ConsumerZooKeeper.java:165)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper.registerConsumer(ConsumerZooKeeper.java:183)
at com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer.completeSubscribe(SimpleMessageConsumer.java:212)
at com.duokoo.Remove.main(Remove.java:42)

@xnang

無背景，無程序，請問你讓我怎么幫你看？

安裝你說的步驟搭建了服務(wù)，所有的代碼都是example里面的，生產(chǎn)端可以正常寫入數(shù)據(jù)，返回類似Send message successfully,sent to -1-0 這樣的提示。消費端通過SyncConsumer這個類只能取出部分數(shù)據(jù)，比如寫入5條只能取到部分幾條使用AsyncConsumer.java
log4j在debug模式下出現(xiàn)了上面評論的那個異常錯誤

@xnang

從堆棧來看，明顯不是example的代碼，你自己寫的或者修改的吧。

從錯誤來看，應(yīng)該是因為消費者的zk配置問題，請看example代碼。

SyncConsumer不是只能取出部分數(shù)據(jù)，可能是因為你沒有遞增offset，或者服務(wù)端延遲force的問題。

能告訴下你的郵箱么？我們發(fā)郵件交流吧。謝謝！

@xnang
killme2008@gmail.com，可以的話gtalk

感謝博主的指導(dǎo)，調(diào)試通過了。博主真的不錯，很耐心。再次感謝

準備啟動服務(wù)器，配置為：MetaConfig [brokerId=0, dataPath=d:metamorphosisdatafile
, deletePolicy=delete,168, diamondZKDataId=metamorphosis.zkConfig, diamondZKGrou
p=DEFAULT_GROUP, getProcessThreadCount=80, hostName=null, maxSegmentSize=1073741
824, maxTransferSize=1048576, numPartitions=10, putProcessThreadCount=80, server
Port=8123, slaveGroup=meta-slave-group, slaveId=-1, statTopicSet=[mytopic], topi
cDeletePolicy=, topics=[mytopic], unflushInterval=10000, unflushThreshold=1000,
zkConfig=com.taobao.metamorphosis.utils.ZkUtils$ZKConfig@1630ab9]
Exception in thread "main" com.taobao.metamorphosis.server.exception.Metamorphos
isServerStartupException: Register broker to zk failed
at com.taobao.metamorphosis.server.assembly.MetaMorphosisBroker.start(Me
taMorphosisBroker.java:206)
at com.taobao.metamorphosis.EnhancedBroker.start(EnhancedBroker.java:46)

at com.taobao.metamorphosis.ServerStartup.main(ServerStartup.java:47)
Caused by: org.I0Itec.zkclient.exception.ZkNodeExistsException: org.apache.zooke
eper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists for /meta
/brokers/ids/0/master
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:55)

at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685)
at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
at org.I0Itec.zkclient.ZkClient.createEphemeral(ZkClient.java:328)
at com.taobao.metamorphosis.utils.ZkUtils.createEphemeralPath(ZkUtils.ja
va:82)
at com.taobao.metamorphosis.server.BrokerZooKeeper.registerBrokerInZk(Br
okerZooKeeper.java:188)
at com.taobao.metamorphosis.server.assembly.MetaMorphosisBroker.start(Me
taMorphosisBroker.java:201)
... 2 more
Caused by: org.apache.zookeeper.KeeperException$NodeExistsException: KeeperError
Code = NodeExists for /meta/brokers/ids/0/master
at org.apache.zookeeper.KeeperException.create(KeeperException.java:110)

at org.apache.zookeeper.KeeperException.create(KeeperException.java:42)
at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:637)
at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
... 7 more
菜鳥一個求指導(dǎo)，是不是哪里配置不對了