search

streamnative / rop

RocketMQ-on-Pulsar - A protocol handler that brings native RocketMQ protocol to Apache Pulsar
Apache License 2.0
98 stars 25 forks source link

Standalone ROP Shutdown #160

Open zengzhengrong opened 2 years ago

zengzhengrong commented 2 years ago

pulsar versiono 2.10.0

logs

pulsar_1          | 2022-05-24T07:52:30,228+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ProducerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-9] [standalone-18-9] Closed Producer
pulsar_1          | 2022-05-24T07:52:30,228+0000 [Rop-group-offset-reader] INFO  org.streamnative.pulsar.handlers.rocketmq.inner.consumer.metadata.GroupMetaManager - Start load group offset.
pulsar_1          | 2022-05-24T07:52:30,229+0000 [main] INFO  org.streamnative.pulsar.handlers.rocketmq.inner.consumer.metadata.GroupMetaManager - Start GroupMetaManager service successfully.
pulsar_1          | 2022-05-24T07:52:30,230+0000 [NettyEventExecutor] INFO  org.streamnative.pulsar.handlers.rocketmq.inner.NettyRemotingAbstract - NettyEventExecutor service started
pulsar_1          | 2022-05-24T07:52:30,239+0000 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service.
pulsar_1          | java.lang.NoSuchMethodError: 'org.apache.pulsar.zookeeper.ZooKeeperClientFactory org.apache.pulsar.broker.PulsarService.getZkClientFactory()'
pulsar_1          |     at org.streamnative.pulsar.handlers.rocketmq.inner.proxy.RopBrokerProxy.start(RopBrokerProxy.java:689) ~[?:?]
pulsar_1          |     at org.streamnative.pulsar.handlers.rocketmq.inner.RocketMQBrokerController.start(RocketMQBrokerController.java:578) ~[?:?]
pulsar_1          |     at org.streamnative.pulsar.handlers.rocketmq.RocketMQProtocolHandler.start(RocketMQProtocolHandler.java:123) ~[?:?]
pulsar_1          |     at org.apache.pulsar.broker.protocol.ProtocolHandlerWithClassLoader.start(ProtocolHandlerWithClassLoader.java:76) ~[org.apache.pulsar-pulsar-broker-2.10.0.jar:2.10.0]
pulsar_1          |     at org.apache.pulsar.broker.protocol.ProtocolHandlers.lambda$start$4(ProtocolHandlers.java:149) ~[org.apache.pulsar-pulsar-broker-2.10.0.jar:2.10.0]
pulsar_1          |     at java.lang.Iterable.forEach(Iterable.java:75) ~[?:?]
pulsar_1          |     at org.apache.pulsar.broker.protocol.ProtocolHandlers.start(ProtocolHandlers.java:149) ~[org.apache.pulsar-pulsar-broker-2.10.0.jar:2.10.0]
pulsar_1          |     at org.apache.pulsar.broker.PulsarService.start(PulsarService.java:780) ~[org.apache.pulsar-pulsar-broker-2.10.0.jar:2.10.0]
pulsar_1          |     at org.apache.pulsar.PulsarStandalone.start(PulsarStandalone.java:301) ~[org.apache.pulsar-pulsar-broker-2.10.0.jar:2.10.0]
pulsar_1          |     at org.apache.pulsar.PulsarStandaloneStarter.main(PulsarStandaloneStarter.java:139) [org.apache.pulsar-pulsar-broker-2.10.0.jar:2.10.0]
pulsar_1          | 2022-05-24T07:52:30,396+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-0][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 0
pulsar_1          | 2022-05-24T07:52:30,400+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-1][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 1
pulsar_1          | 2022-05-24T07:52:30,400+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-2][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 2
pulsar_1          | 2022-05-24T07:52:30,401+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-3][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 3
pulsar_1          | 2022-05-24T07:52:30,401+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-4][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 4
pulsar_1          | 2022-05-24T07:52:30,402+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-5][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 5
pulsar_1          | 2022-05-24T07:52:30,402+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-6][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 6
pulsar_1          | 2022-05-24T07:52:30,402+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-7][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 7
pulsar_1          | 2022-05-24T07:52:30,403+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-8][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 8
pulsar_1          | 2022-05-24T07:52:30,403+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-9][multiTopicsReader-2601b84b42] Subscribing to topic on cnx [id: 0x38ee9e61, L:/127.0.0.1:46522 - R:127.0.0.1/127.0.0.1:6650], consumerId 9
pulsar_1          | 2022-05-24T07:52:30,428+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-0] Created non-durable cursor read-position=6:0 mark-delete-position=6:-1
pulsar_1          | 2022-05-24T07:52:30,445+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-0][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 0
pulsar_1          | 2022-05-24T07:52:30,446+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-1] Created non-durable cursor read-position=9:0 mark-delete-position=9:-1
pulsar_1          | 2022-05-24T07:52:30,448+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-1][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 1
pulsar_1          | 2022-05-24T07:52:30,448+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-2] Created non-durable cursor read-position=12:0 mark-delete-position=12:-1
pulsar_1          | 2022-05-24T07:52:30,449+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-2][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 2
pulsar_1          | 2022-05-24T07:52:30,449+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-3] Created non-durable cursor read-position=14:0 mark-delete-position=14:-1
pulsar_1          | 2022-05-24T07:52:30,450+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-4] Created non-durable cursor read-position=8:0 mark-delete-position=8:-1
pulsar_1          | 2022-05-24T07:52:30,450+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-3][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 3
pulsar_1          | 2022-05-24T07:52:30,451+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-4][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 4
pulsar_1          | 2022-05-24T07:52:30,451+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-5] Created non-durable cursor read-position=10:0 mark-delete-position=10:-1
pulsar_1          | 2022-05-24T07:52:30,452+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-5][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 5
pulsar_1          | 2022-05-24T07:52:30,453+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-6] Created non-durable cursor read-position=13:0 mark-delete-position=13:-1
pulsar_1          | 2022-05-24T07:52:30,454+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-6][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 6
pulsar_1          | 2022-05-24T07:52:30,454+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-7] Created non-durable cursor read-position=15:0 mark-delete-position=15:-1
pulsar_1          | 2022-05-24T07:52:30,456+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-7][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 7
pulsar_1          | 2022-05-24T07:52:30,456+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-8] Created non-durable cursor read-position=7:0 mark-delete-position=7:-1
pulsar_1          | 2022-05-24T07:52:30,457+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-8][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 8
pulsar_1          | 2022-05-24T07:52:30,457+0000 [pulsar-io-29-3] INFO  org.apache.bookkeeper.mledger.impl.NonDurableCursorImpl - [rocketmq/offset/persistent/__consumer_offsets-partition-9] Created non-durable cursor read-position=11:0 mark-delete-position=11:-1
pulsar_1          | 2022-05-24T07:52:30,458+0000 [pulsar-io-29-2] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-9][multiTopicsReader-2601b84b42] Subscribed to topic on 127.0.0.1/127.0.0.1:6650 -- consumer: 9
pulsar_1          | 2022-05-24T07:52:30,508+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-6, name=multiTopicsReader-2601b84b42}, consumerId=6, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,512+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-6, name=multiTopicsReader-2601b84b42}, consumerId=6, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,512+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-6][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-6, ackPos=13:-1, readPos=76:0}]
pulsar_1          | 2022-05-24T07:52:30,513+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-6][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,514+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-6][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-6, ackPos=13:-1, readPos=76:0}]
pulsar_1          | 2022-05-24T07:52:30,514+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-6][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,517+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-2, name=multiTopicsReader-2601b84b42}, consumerId=2, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,518+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-2, name=multiTopicsReader-2601b84b42}, consumerId=2, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,518+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-2][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-2, ackPos=12:-1, readPos=92:0}]
pulsar_1          | 2022-05-24T07:52:30,518+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-2][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,519+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-2][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-2, ackPos=12:-1, readPos=92:0}]
pulsar_1          | 2022-05-24T07:52:30,519+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-2][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,554+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-8, name=multiTopicsReader-2601b84b42}, consumerId=8, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,554+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-8, name=multiTopicsReader-2601b84b42}, consumerId=8, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,555+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-8][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-8, ackPos=7:-1, readPos=167:0}]
pulsar_1          | 2022-05-24T07:52:30,555+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-8][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,555+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-8][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-8, ackPos=7:-1, readPos=182:0}]
pulsar_1          | 2022-05-24T07:52:30,555+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-8][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,557+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-0, name=multiTopicsReader-2601b84b42}, consumerId=0, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,557+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-0, name=multiTopicsReader-2601b84b42}, consumerId=0, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,557+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-0][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-0, ackPos=6:-1, readPos=150:0}]
pulsar_1          | 2022-05-24T07:52:30,557+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-0][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,558+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-0][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-0, ackPos=6:-1, readPos=150:0}]
pulsar_1          | 2022-05-24T07:52:30,558+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-0][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,559+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-4, name=multiTopicsReader-2601b84b42}, consumerId=4, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,560+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-4, name=multiTopicsReader-2601b84b42}, consumerId=4, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,560+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-4][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-4, ackPos=8:-1, readPos=183:0}]
pulsar_1          | 2022-05-24T07:52:30,560+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-4][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,561+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-4][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-4, ackPos=8:-1, readPos=183:0}]
pulsar_1          | 2022-05-24T07:52:30,561+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-4][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,574+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-5, name=multiTopicsReader-2601b84b42}, consumerId=5, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,575+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-5, name=multiTopicsReader-2601b84b42}, consumerId=5, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,575+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-5][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-5, ackPos=10:-1, readPos=201:0}]
pulsar_1          | 2022-05-24T07:52:30,575+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-5][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,575+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-5][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-5, ackPos=10:-1, readPos=201:0}]
pulsar_1          | 2022-05-24T07:52:30,575+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-5][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,577+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-1, name=multiTopicsReader-2601b84b42}, consumerId=1, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,577+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-1, name=multiTopicsReader-2601b84b42}, consumerId=1, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,577+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-1][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-1, ackPos=9:-1, readPos=217:0}]
pulsar_1          | 2022-05-24T07:52:30,577+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-1][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,577+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-1][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-1, ackPos=9:-1, readPos=217:0}]
pulsar_1          | 2022-05-24T07:52:30,577+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-1][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,578+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-9, name=multiTopicsReader-2601b84b42}, consumerId=9, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,578+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-9, name=multiTopicsReader-2601b84b42}, consumerId=9, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,578+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-9][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-9, ackPos=11:-1, readPos=219:0}]
pulsar_1          | 2022-05-24T07:52:30,578+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-9][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,579+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-9][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-9, ackPos=11:-1, readPos=219:0}]
pulsar_1          | 2022-05-24T07:52:30,579+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-9][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,593+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-7, name=multiTopicsReader-2601b84b42}, consumerId=7, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,594+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-7, name=multiTopicsReader-2601b84b42}, consumerId=7, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,594+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-7][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-7, ackPos=15:-1, readPos=287:0}]
pulsar_1          | 2022-05-24T07:52:30,594+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-7][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,594+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-7][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-7, ackPos=15:-1, readPos=287:0}]
pulsar_1          | 2022-05-24T07:52:30,594+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-7][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:30,596+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.Consumer - Disconnecting consumer: Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-3, name=multiTopicsReader-2601b84b42}, consumerId=3, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,596+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://rocketmq/offset/__consumer_offsets-partition-3, name=multiTopicsReader-2601b84b42}, consumerId=3, consumerName=4d14e, address=/127.0.0.1:46522}
pulsar_1          | 2022-05-24T07:52:30,596+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-3][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-3, ackPos=14:-1, readPos=270:0}]
pulsar_1          | 2022-05-24T07:52:30,596+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-3][multiTopicsReader-2601b84b42] Successfully closed dispatcher for reader
pulsar_1          | 2022-05-24T07:52:30,596+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-3][multiTopicsReader-2601b84b42] Successfully closed subscription [NonDurableCursorImpl{ledger=rocketmq/offset/persistent/__consumer_offsets-partition-3, ackPos=14:-1, readPos=270:0}]
pulsar_1          | 2022-05-24T07:52:30,596+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://rocketmq/offset/__consumer_offsets-partition-3][multiTopicsReader-2601b84b42] Successfully disconnected and closed subscription
pulsar_1          | 2022-05-24T07:52:31,477+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-0] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-9] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-8] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-7] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-6] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-5] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-4] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-3] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,478+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-2] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,479+0000 [Thread-0] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [persistent://rocketmq/offset/__consumer_offsets-partition-1] [multiTopicsReader-2601b84b42] Closed Consumer (not connected)
pulsar_1          | 2022-05-24T07:52:31,628+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.GracefulExecutorServicesTerminationHandler - Starting termination handler for 4 executors.
pulsar_1          | 2022-05-24T07:52:31,629+0000 [Thread-0] INFO  org.apache.pulsar.broker.service.GracefulExecutorServicesTerminationHandler - Shutdown completed.

grep ERROR

docker-compose logs -f | grep ERROR
pulsar_1          | 2022-05-24T08:08:55,859+0000 [main] ERROR org.apache.bookkeeper.bookie.Journal - Problems reading from data/standalone/bookkeeper0/current/lastMark (this is okay if it is the first time starting this bookie
pulsar_1          | 2022-05-24T08:08:58,096+0000 [client-scheduler-OrderedScheduler-6-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
pulsar_1          | 2022-05-24T08:08:59,163+0000 [client-scheduler-OrderedScheduler-25-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
pulsar_1          | 2022-05-24T08:09:07,390+0000 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service.
pulsar_1          | 2022-05-24T08:09:20,521+0000 [client-scheduler-OrderedScheduler-8-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
pulsar_1          | 2022-05-24T08:09:27,697+0000 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service.
pulsar_1          | 2022-05-24T08:09:40,263+0000 [client-scheduler-OrderedScheduler-10-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
pulsar_1          | 2022-05-24T08:09:47,554+0000 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service.
pulsar_1          | 2022-05-24T08:10:00,495+0000 [client-scheduler-OrderedScheduler-26-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
pulsar_1          | 2022-05-24T08:10:07,726+0000 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service.
pulsar_1          | 2022-05-24T08:10:20,706+0000 [client-scheduler-OrderedScheduler-4-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
pulsar_1          | 2022-05-24T08:10:27,936+0000 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service.
pulsar_1          | 2022-05-24T08:10:40,966+0000 [client-scheduler-OrderedScheduler-10-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {}
pulsar_1          | 2022-05-24T08:10:48,250+0000 [main] ERROR org.apache.pulsar.PulsarStandaloneStarter - Failed to start pulsar service.

standalone.sh rocketmq config

messagingProtocols=rocketmq
protocolHandlerDirectory=./protocols
loadManagerClassName=org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl
rocketmqListeners=rocketmq://192.168.2.168:9876
advertisedListeners=INTERNAL:pulsar://127.0.0.1:6650,INTERNAL:pulsar+ssl://127.0.0.1:6651,INTERNAL_ROP:pulsar://127.0.0.1:9876,INTERNAL_ROP:pulsar+ssl://127.0.0.1:9896
rocketmqListenerPortMap=9876:INTERNAL_ROP
brokerEntryMetadataInterceptors=org.apache.pulsar.common.intercept.AppendIndexMetadataInterceptor
brokerDeleteInactiveTopicsEnabled=false

rop version: pulsar-protocol-handler-rocketmq-0.2.0 rocketmq version 4.8 

701bc9ee452c   foxiswho/rocketmq:4.8.0                    "sh mqbroker -c /etc…"   5 days ago   Up 5 days   0.0.0.0:10909->10909/tcp, 9876/tcp, 10912/tcp, 0.0.0.0:10911->10911/tcp   rmqbroker
e04bdd592495   apacherocketmq/rocketmq-dashboard:latest   "sh -c 'java $JAVA_O…"   5 days ago   Up 5 days   0.0.0.0:8180->8080/tcp                                                    rmqdashboard
c22e083be74d   foxiswho/rocketmq:4.8.0                    "sh mqnamesrv"           5 days ago   Up 5 days   10909/tcp, 0.0.0.0:9876->9876/tcp, 10911-10912/tcp                        rmqnamesrv

compose.yaml

version: '3.3'

services:
  pulsar:
    image: "apachepulsar/pulsar:2.10.0"
    command: bin/pulsar standalone
    restart: always
    ports:
      - "6650:6650"
      - "8080:8080"
    volumes:
    #   - ./pulsar-cfg/data:/pulsar/data
      - ./pulsar-cfg/conf:/pulsar/conf
      - ./pulsar-cfg/protocols:/pulsar/protocols:rw

  pulsar-manager:
    image: "apachepulsar/pulsar-manager:v0.2.0"
    restart: always
    ports:
      - "9527:9527"
      - "7750:7750"
    depends_on:
      - pulsar
    links:
      - pulsar
    environment:
      - SPRING_CONFIGURATION_FILE=/pulsar-manager/pulsar-manager/application.properties
cherrot commented 1 year ago

Seems like this project is dead :(