pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] tuan6956 commented on issue #3490: Fail to reset-cursor on replicator subscription
Date Tue, 12 Feb 2019 11:30:32 GMT
tuan6956 commented on issue #3490: Fail to reset-cursor on replicator subscription 
URL: https://github.com/apache/pulsar/issues/3490#issuecomment-462724484
 
 
   clusters
   ```["region_1","region_2","region_3","region_4"]```
   Error occur when run in cluster region_1
   ```bin/pulsar-admin topics reset-cursor persistent://public/default/tx -s pulsar.repl.region_4
--time 24h```
   ```Reason: Subscription not found```
   internal stats for topic in region_1:
   ```
   bin/pulsar initialize-cluster-metadata \
     --cluster region_4 \
     --zookeeper localhost:2184 \
     --configuration-store localhost:2190 \
     --web-service-url http://localhost:8083 \
     --web-service-url-tls https://localhost:8446 \
     --broker-service-url pulsar://localhost:6656 \
     --broker-service-url-tls pulsar+ssl://localhost:6657
   
   
     {
     "entriesAddedCounter" : 1,
     "numberOfEntries" : 31,
     "totalSize" : 1616,
     "currentLedgerEntries" : 1,
     "currentLedgerSize" : 59,
     "lastLedgerCreatedTimestamp" : "2019-01-31T12:19:44.312+07:00",
     "waitingCursorsCount" : 7,
     "pendingAddEntriesCount" : 0,
     "lastConfirmedEntry" : "44:0",
     "state" : "LedgerOpened",
     "ledgers" : [ { ],
     "cursors" : {
       "consumer-test-1" : {
         "markDeletePosition" : "0:-1",
         "readPosition" : "0:0",
         "waitingReadOp" : false,
         "pendingReadOps" : 0,
         "messagesConsumedCounter" : -30,
         "cursorLedger" : 49,
         "cursorLedgerLastEntry" : 2,
         "individuallyDeletedMessages" : "[]",
         "lastLedgerSwitchTimestamp" : "2019-01-31T12:19:44.316+07:00",
         "state" : "Open",
         "numberOfEntriesSinceFirstNotAckedMessage" : 1,
         "totalNonContiguousDeletedMessagesRange" : 0,
         "properties" : { }
       },
       "consumer-test-2" : {
         "markDeletePosition" : "0:-1",
         "readPosition" : "0:0",
         "waitingReadOp" : false,
         "pendingReadOps" : 0,
         "messagesConsumedCounter" : -30,
         "cursorLedger" : 45,
         "cursorLedgerLastEntry" : 13,
         "individuallyDeletedMessages" : "[]",
         "lastLedgerSwitchTimestamp" : "2019-01-31T12:19:44.315+07:00",
         "state" : "Open",
         "numberOfEntriesSinceFirstNotAckedMessage" : 1,
         "totalNonContiguousDeletedMessagesRange" : 0,
         "properties" : { }
       },
       "pulsar.repl.region_2" : {
         "markDeletePosition" : "44:0",
         "readPosition" : "44:1",
         "waitingReadOp" : true,
         "pendingReadOps" : 0,
         "messagesConsumedCounter" : 1,
         "cursorLedger" : 46,
         "cursorLedgerLastEntry" : 1,
         "individuallyDeletedMessages" : "[]",
         "lastLedgerSwitchTimestamp" : "2019-01-31T12:19:44.317+07:00",
         "state" : "Open",
         "numberOfEntriesSinceFirstNotAckedMessage" : 1,
         "totalNonContiguousDeletedMessagesRange" : 0,
         "properties" : { }
       },
       "pulsar.repl.region_3" : {
         "markDeletePosition" : "44:0",
         "readPosition" : "44:1",
         "waitingReadOp" : true,
         "pendingReadOps" : 0,
         "messagesConsumedCounter" : 1,
         "cursorLedger" : 48,
         "cursorLedgerLastEntry" : 1,
         "individuallyDeletedMessages" : "[]",
         "lastLedgerSwitchTimestamp" : "2019-01-31T12:19:44.317+07:00",
         "state" : "Open",
         "numberOfEntriesSinceFirstNotAckedMessage" : 1,
         "totalNonContiguousDeletedMessagesRange" : 0,
         "properties" : { }
       },
       "pulsar.repl.region_4" : {
         "markDeletePosition" : "44:0",
         "readPosition" : "44:1",
         "waitingReadOp" : true,
         "pendingReadOps" : 0,
         "messagesConsumedCounter" : 1,
         "cursorLedger" : 47,
         "cursorLedgerLastEntry" : 1,
         "individuallyDeletedMessages" : "[]",
         "lastLedgerSwitchTimestamp" : "2019-01-31T12:19:44.317+07:00",
         "state" : "Open",
         "numberOfEntriesSinceFirstNotAckedMessage" : 1,
         "totalNonContiguousDeletedMessagesRange" : 0,
         "properties" : { }
       }
     }
   }
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message