GitHub user volfco added a comment to the discussion: geo replicated subscribers
@merlimat These logs tell 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
```
GitHub link:
https://github.com/apache/pulsar/discussions/18983#discussioncomment-4447452
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
