volfco commented on issue #5274: geo replicated subscribers URL: https://github.com/apache/pulsar/issues/5274#issuecomment-547626912 @merlimat These logs tel me that replication has been enabled: ``` 4:55:14.350 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://development/ns1/test] Starting replicator to remote: aus 14:55:14.350 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [development/ns1/persistent/test] Cursor pulsar.repl.aus recovered to position 13:-1 14:55:14.350 [bookkeeper-ml-workers-OrderedExecutor-3-0] WARN org.apache.bookkeeper.client.BookieWatcherImpl - New ensemble: [iad-pulsar1.local:3181] is not adhering to Placement Policy. quarantinedBookies: [] 14:55:14.352 [pulsar-ordered-OrderedExecutor-2-0-EventThread] ERROR org.apache.bookkeeper.proto.checksum.CRC32CDigestManager - Sse42Crc32C is not supported, will use a slower CRC32C implementation. 14:55:14.352 [pulsar-ordered-OrderedExecutor-2-0-EventThread] INFO org.apache.bookkeeper.client.LedgerCreateOp - Ensemble: [iad-pulsar1.local:3181] for ledger: 14 14:55:14.355 [BookKeeperClientWorker-OrderedExecutor-2-0] INFO org.apache.bookkeeper.mledger.impl.MetaStoreImplZookeeper - [development/ns1/persistent/test] [pulsar.repl.aus] Updating cursor info ledgerId=14 mark-delete=13:-1 14:55:14.356 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [development/ns1/persistent/test] Updated cursor pulsar.repl.aus with ledger id 14 md-position=13:-1 rd-position=13:0 14:55:14.356 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - [development/ns1/persistent/test] Opened new cursor: ManagedCursorImpl{ledger=development/ns1/persistent/test, name=pulsar.repl.aus, ackPos=13:-1, readPos=13:0} 14:55:14.357 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.pulsar.broker.service.AbstractReplicator - [persistent://development/ns1/test][iad -> aus] Starting replicator 14:55:14.358 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.pulsar.broker.service.BrokerService - Created topic persistent://development/ns1/test - dedup is disabled 14:55:14.359 [ForkJoinPool.commonPool-worker-2] INFO org.apache.pulsar.broker.service.ServerCnx - [/10.1.2.105:58767]-3 persistent://development/ns1/test configured with schema false 14:55:14.360 [ForkJoinPool.commonPool-worker-2] INFO org.apache.pulsar.broker.service.AbstractReplicator - [persistent://development/ns1/test][iad -> aus] Replicator already being started. Replicator state: Starting 14:55:14.360 [ForkJoinPool.commonPool-worker-2] INFO org.apache.pulsar.broker.service.ServerCnx - [/10.1.2.105:58767] Created new producer: Producer{topic=PersistentTopic{topic=persistent://development/ns1/test}, client=/10.1.2.105:58767, producerName=pulsar.repl.aus, producerId=3} 14:55:14.397 [pulsar-io-22-5] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x3b7aa4e9, L:/10.170.53.77:41078 - R: /10.1.2.105:6650]] Connected to server 14:55:14.518 [pulsar-io-22-8] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xfbfc6995, L:/10.170.53.77:41080 - R:aus-pulsar1.local/10.1.2.105:6650]] Connected to server 14:55:14.603 [pulsar-io-22-8] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://development/ns1/test] [pulsar.repl.iad] Creating producer on cnx [id: 0xd965768e, L:/10.170.53.77:40868 - R:aus-pulsar1.local/10.1.2.105:6650] 14:55:14.661 [pulsar-io-22-3] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://development/ns1/test] [pulsar.repl.iad] Created producer on cnx [id: 0xd965768e, L:/10.170.53.77:40868 - R:aus-pulsar1.local/10.1.2.105:6650] 14:55:14.661 [pulsar-io-22-3] INFO org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [development/ns1/persistent/test-pulsar.repl.aus] Rewind from 13:0 to 13:0 14:55:14.661 [pulsar-io-22-3] INFO org.apache.pulsar.broker.service.persistent.PersistentReplicator - [persistent://development/ns1/test][iad -> aus] Created replicator producer 14:55:14.881 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://development/ns1/test] Enabling replicated subscriptions controller 14:55:14.999 [bookkeeper-ml-workers-OrderedExecutor-3-0] INFO org.apache.pulsar.broker.service.persistent.ReplicatedSubscriptionsController - [PersistentTopic{topic=persistent://development/ns1/test}][consumer] Creating subscription at 13:13:0 after receiving update from replicated subcription ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
