fayce66 edited a comment on issue #9317:
URL: https://github.com/apache/pulsar/issues/9317#issuecomment-768861343
OK, I rerun the pulsar-admin topics compact commands and effectively I can
see some __compaction messages in the log now, and I restarted my client and it
looks like it is working now. I did that 2 times yesterday and it did not work,
that is strange. FYI, I stop and restart the pulsar-daemon every morning. Are
the configurations saved or do I have to re-run the topics commands all the
time I restart the broker??
Here is my log, I think the compaction is working now, but I'm gonna keep on
testing some more to make sure it's OK now:
```
16:14:05.400 [pulsar-web-68-12] INFO
org.apache.pulsar.broker.admin.impl.PersistentTopicsBase - [null] Trigger
compaction on topic persistent://marianas/alphatrader/wing-calibration
16:14:05.421 [ForkJoinPool.commonPool-worker-29] INFO
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar
consumer status recorder with config: {
"topicNames" : [ "persistent://marianas/alphatrader/wing-calibration" ],
"topicsPattern" : null,
"subscriptionName" : "__compaction",
"subscriptionType" : "Exclusive",
"subscriptionMode" : "Durable",
"receiverQueueSize" : 1000,
"acknowledgementsGroupTimeMicros" : 100000,
"negativeAckRedeliveryDelayMicros" : 60000000,
"maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
"consumerName" : null,
"ackTimeoutMillis" : 0,
"tickDurationMillis" : 1000,
"priorityLevel" : 0,
"maxPendingChuckedMessage" : 10,
"autoAckOldestChunkedMessageOnQueueFull" : false,
"expireTimeOfIncompleteChunkedMessageMillis" : 60000,
"cryptoFailureAction" : "FAIL",
"properties" : { },
"readCompacted" : true,
"subscriptionInitialPosition" : "Latest",
"patternAutoDiscoveryPeriod" : 60,
"regexSubscriptionMode" : "PersistentOnly",
"deadLetterPolicy" : null,
"retryEnable" : false,
"autoUpdatePartitions" : true,
"autoUpdatePartitionsIntervalSeconds" : 60,
"replicateSubscriptionState" : false,
"resetIncludeHead" : false,
"keySharedPolicy" : null,
"batchIndexAckEnabled" : false
}
16:14:05.425 [ForkJoinPool.commonPool-worker-29] INFO
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config:
{
"serviceUrl" : "pulsar://localhost:6650",
"authPluginClassName" :
"org.apache.pulsar.client.impl.auth.AuthenticationDisabled",
"operationTimeoutMs" : 30000,
"statsIntervalSeconds" : 60,
"numIoThreads" : 1,
"numListenerThreads" : 1,
"connectionsPerBroker" : 1,
"useTcpNoDelay" : true,
"useTls" : false,
"tlsTrustCertsFilePath" : null,
"tlsAllowInsecureConnection" : false,
"tlsHostnameVerificationEnable" : false,
"concurrentLookupRequest" : 5000,
"maxLookupRequest" : 50000,
"maxLookupRedirects" : 20,
"maxNumberOfRejectedRequestPerConnection" : 50,
"keepAliveIntervalSeconds" : 30,
"connectionTimeoutMs" : 10000,
"requestTimeoutMs" : 60000,
"initialBackoffIntervalNanos" : 100000000,
"maxBackoffIntervalNanos" : 60000000000,
"listenerName" : null,
"useKeyStoreTls" : false,
"sslProvider" : null,
"tlsTrustStoreType" : "JKS",
"tlsTrustStorePath" : null,
"tlsTrustStorePassword" : null,
"tlsCiphers" : [ ],
"tlsProtocols" : [ ],
"proxyServiceUrl" : null,
"proxyProtocol" : null,
"enableTransaction" : false
}
16:14:05.432 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x977756f3,
L:/127.0.0.1:42032 - R:localhost/127.0.0.1:6650]] Connected to server
16:14:05.432 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.ServerCnx - New connection from
/127.0.0.1:42032
16:14:05.436 [ForkJoinPool.commonPool-worker-29] INFO
org.eclipse.jetty.server.RequestLog - 127.0.0.1 - - [28/Jan/2021:16:14:05
+0900] "PUT
/admin/v2/persistent/marianas/alphatrader/wing-calibration/compaction HTTP/1.1"
204 0 "-" "Pulsar-Java-v2.7.0" 38
16:14:05.437 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Subscribing
to topic on cnx [id: 0x977756f3, L:/127.0.0.1:42032 -
R:localhost/127.0.0.1:6650], consumerId 0
16:14:05.437 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032] Subscribing on
topic persistent://marianas/alphatrader/wing-calibration / __compaction
16:14:05.437 [pulsar-io-50-41] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration-__compaction] Rewind from
13911:132 to 13911:132
16:14:05.437 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://marianas/alphatrader/wing-calibration] There are no replicated
subscriptions on the topic
16:14:05.437 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Created new
subscription for 0
16:14:05.437 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032] Created
subscription on topic persistent://marianas/alphatrader/wing-calibration /
__compaction
16:14:05.438 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Subscribed
to topic on localhost/127.0.0.1:6650 -- consumer: 0
16:14:05.442 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Seek
subscription to message id -1:-1:-1
16:14:05.443 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.Consumer - Disconnecting consumer:
Consumer{subscription=CompactorSubscription{topic=persistent://marianas/alphatrader/wing-calibration,
name=__compaction}, consumerId=0, consumerName=99cae, address=/127.0.0.1:42032}
16:14:05.443 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=CompactorSubscription{topic=persistent://marianas/alphatrader/wing-calibration,
name=__compaction}, consumerId=0, consumerName=99cae, address=/127.0.0.1:42032}
16:14:05.444 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentSubscription -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Successfully
disconnected consumers from subscription, proceeding with cursor reset
16:14:05.444 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ClientCnx - [localhost/127.0.0.1:6650] Broker
notification of Closed consumer: 0
16:14:05.444 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConnectionHandler -
[persistent://marianas/alphatrader/wing-calibration] [__compaction] Closed
connection [id: 0x977756f3, L:/127.0.0.1:42032 - R:localhost/127.0.0.1:6650] --
Will try again in 0.1 s
16:14:05.446 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration] Initiate reset position to
12028:-1 on cursor __compaction
16:14:05.448 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl -
[marianas/alphatrader/persistent/wing-calibration] Creating ledger, metadata:
{component=[109, 97, 110, 97, 103, 101, 100, 45, 108, 101, 100, 103, 101, 114],
pulsar/managed-ledger=[109, 97, 114, 105, 97, 110, 97, 115, 47, 97, 108, 112,
104, 97, 116, 114, 97, 100, 101, 114, 47, 112, 101, 114, 115, 105, 115, 116,
101, 110, 116, 47, 119, 105, 110, 103, 45, 99, 97, 108, 105, 98, 114, 97, 116,
105, 111, 110], pulsar/cursor=[95, 95, 99, 111, 109, 112, 97, 99, 116, 105,
111, 110], application=[112, 117, 108, 115, 97, 114]} - metadata ops timeout :
60 seconds
16:14:05.465 [main-EventThread] INFO
org.apache.bookkeeper.client.LedgerCreateOp - Ensemble: [127.0.0.1:3181] for
ledger: 19142
16:14:05.475 [BookKeeperClientWorker-OrderedExecutor-14-0] INFO
org.apache.bookkeeper.mledger.impl.MetaStoreImpl -
[marianas/alphatrader/persistent/wing-calibration] [__compaction] Updating
cursor info ledgerId=19142 mark-delete=13911:131
16:14:05.481 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration] Updated cursor __compaction
with ledger id 19142 md-position=13911:131 rd-position=13911:132
16:14:05.484 [BookKeeperClientWorker-OrderedExecutor-14-0] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration] reset position to 12028:-1
before current read position 13911:132 on cursor __compaction
16:14:05.487 [BookKeeperClientWorker-OrderedExecutor-14-0] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032]
[persistent://marianas/alphatrader/wing-calibration][__compaction] Reset
subscription to message id -1:-1
16:14:05.487 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Successfully
reset subscription to message id -1:-1:-1
16:14:05.546 [pulsar-timer-104-1] INFO
org.apache.pulsar.client.impl.ConnectionHandler -
[persistent://marianas/alphatrader/wing-calibration] [__compaction]
Reconnecting after timeout
16:14:05.548 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Subscribing
to topic on cnx [id: 0x977756f3, L:/127.0.0.1:42032 -
R:localhost/127.0.0.1:6650], consumerId 0
16:14:05.548 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032] Subscribing on
topic persistent://marianas/alphatrader/wing-calibration / __compaction
16:14:05.548 [pulsar-io-50-41] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration-__compaction] Rewind from
12028:-1 to 12028:0
16:14:05.549 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://marianas/alphatrader/wing-calibration] There are no replicated
subscriptions on the topic
16:14:05.549 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Created new
subscription for 0
16:14:05.549 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032] Created
subscription on topic persistent://marianas/alphatrader/wing-calibration /
__compaction
16:14:05.549 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Subscribed
to topic on localhost/127.0.0.1:6650 -- consumer: 0
16:14:05.590 [pulsar-external-listener-102-1] WARN
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration] [__compaction] Could not
get connection while getLastMessageId -- Will try again in 100 ms
16:14:05.592 [pulsar-external-listener-102-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Get topic
last message Id
16:14:05.614 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Successfully
getLastMessageId 18970:696
16:14:05.614 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Get topic
last message Id
16:14:05.618 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Successfully
getLastMessageId 18970:696
16:14:05.618 [pulsar-client-io-101-1] INFO
org.apache.pulsar.compaction.TwoPhaseCompactor - Commencing phase one of
compaction for persistent://marianas/alphatrader/wing-calibration, reading to
18970:696:-1
16:14:06.037 [io-write-scheduler-OrderedScheduler-0-0] INFO
org.apache.bookkeeper.statelib.impl.kv.RocksdbKVStore - Checkpoint local state
store 000000000000000000/000000000000000000/000000000000000000 at revision -1
16:14:06.037 [io-checkpoint-scheduler-OrderedScheduler-0-0] INFO
org.apache.bookkeeper.statelib.impl.rocksdb.checkpoint.RocksdbCheckpointTask -
Create a local checkpoint of state store
000000000000000000/000000000000000000/000000000000000000 at
/home/faycal/Tools/apache-pulsar-2.7.0/data/standalone/bookkeeper/ranges/data/ranges/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85
16:14:06.175 [main-EventThread] INFO
org.apache.bookkeeper.client.LedgerCreateOp - Ensemble: [127.0.0.1:3181] for
ledger: 19143
16:14:06.176 [main-EventThread] INFO
org.apache.pulsar.compaction.TwoPhaseCompactor - Commencing phase two of
compaction for persistent://marianas/alphatrader/wing-calibration, from
13911:130:-1:-1 to 18970:696:-1:-1, compacting 2 keys to ledger 19143
16:14:06.178 [main-EventThread] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Seek
subscription to message id 13911:130:-1:-1
16:14:06.179 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.Consumer - Disconnecting consumer:
Consumer{subscription=CompactorSubscription{topic=persistent://marianas/alphatrader/wing-calibration,
name=__compaction}, consumerId=0, consumerName=99cae, address=/127.0.0.1:42032}
16:14:06.179 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=CompactorSubscription{topic=persistent://marianas/alphatrader/wing-calibration,
name=__compaction}, consumerId=0, consumerName=99cae, address=/127.0.0.1:42032}
16:14:06.179 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentSubscription -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Successfully
disconnected consumers from subscription, proceeding with cursor reset
16:14:06.179 [bookkeeper-ml-workers-OrderedExecutor-0-0] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration] Initiate reset position to
13911:130 on cursor __compaction
16:14:06.179 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ClientCnx - [localhost/127.0.0.1:6650] Broker
notification of Closed consumer: 0
16:14:06.179 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConnectionHandler -
[persistent://marianas/alphatrader/wing-calibration] [__compaction] Closed
connection [id: 0x977756f3, L:/127.0.0.1:42032 - R:localhost/127.0.0.1:6650] --
Will try again in 0.1 s
16:14:06.181 [BookKeeperClientWorker-OrderedExecutor-14-0] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration] reset position to 13911:130
before current read position 18970:697 on cursor __compaction
16:14:06.181 [BookKeeperClientWorker-OrderedExecutor-14-0] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032]
[persistent://marianas/alphatrader/wing-calibration][__compaction] Reset
subscription to message id 13911:130
16:14:06.181 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Successfully
reset subscription to message id 13911:130:-1:-1
16:14:06.222 [main-EventThread] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator for
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved version from -1 to 0.
16:14:06.226 [main-EventThread] INFO
org.apache.distributedlog.BKLogWriteHandler - Initiating Recovery For
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017:<default>
: []
16:14:06.227 [io-checkpoint-scheduler-OrderedScheduler-0-0] INFO
org.apache.distributedlog.BKLogWriteHandler - Initiating Recovery For
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017:<default>
: []
16:14:06.231 [DLM-/stream/storage-OrderedScheduler-0-0] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved to phase ALLOCATING : version = 0.
16:14:06.245 [DLM-/stream/storage-OrderedScheduler-3-0-EventThread] INFO
org.apache.bookkeeper.client.LedgerCreateOp - Ensemble: [127.0.0.1:3181] for
ledger: 19144
16:14:06.261 [main-EventThread] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator for
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved version from 0 to 1.
16:14:06.261 [main-EventThread] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved to phase ALLOCATED : version = 1.
16:14:06.261 [main-EventThread] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved to phase HANDING_OVER : version = 1.
16:14:06.261 [main-EventThread] INFO
org.apache.distributedlog.BKLogWriteHandler - No max ledger sequence number
found while creating log segment 1 for
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017:<default>.
16:14:06.269 [main-EventThread] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved to phase HANDED_OVER : version = 1.
16:14:06.269 [main-EventThread] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator for
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved version from 1 to 2.
16:14:06.269 [main-EventThread] INFO
org.apache.distributedlog.bk.SimpleLedgerAllocator - Ledger allocator
/stream/storage/000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017/<default>/allocation
moved to phase ALLOCATING : version = 2.
16:14:06.269 [main-EventThread] INFO
org.apache.distributedlog.logsegment.PerStreamLogSegmentCache -
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017
added log segment (inprogress_000000000000000001 : [LogSegmentId:19144,
firstTxId:202, lastTxId:-999, version:VERSION_V5_SEQUENCE_ID, completionTime:0,
recordCount:0, regionId:0, status:0, logSegmentSequenceNumber:1,
lastEntryId:-1, lastSlotId:-1, inprogress:true,
minActiveDLSN:DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0},
startSequenceId:-1]) to cache.
16:14:06.277 [main-EventThread] INFO
org.apache.distributedlog.BKLogWriteHandler - Deleting log segments older than
1611558846272 for
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017:<default>
: []
16:14:06.278 [DLM-/stream/storage-OrderedScheduler-13-0] INFO
org.apache.distributedlog.BKLogSegmentWriter - Flushing before closing log
segment
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017:<default>:inprogress_000000000000000001
16:14:06.280 [pulsar-timer-104-1] INFO
org.apache.pulsar.client.impl.ConnectionHandler -
[persistent://marianas/alphatrader/wing-calibration] [__compaction]
Reconnecting after timeout
16:14:06.280 [BookKeeperClientWorker-OrderedExecutor-0-0] INFO
org.apache.distributedlog.BKLogSegmentWriter - Closing BKPerStreamLogWriter
(abort=false) for
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017:<default>:inprogress_000000000000000001
: lastDLSN = DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}
outstandingTransmits = 1 writesPendingTransmit = 0
16:14:06.280 [BookKeeperClientWorker-OrderedExecutor-0-0] INFO
org.apache.distributedlog.BKLogSegmentWriter - Stream
000000000000000000/000000000000000000/000000000000000000/checkpoints/90356abe-2479-421d-a67b-fcd874fdcd85/MANIFEST-000017:<default>:inprogress_000000000000000001
aborted 0 writes
16:14:06.281 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Subscribing
to topic on cnx [id: 0x977756f3, L:/127.0.0.1:42032 -
R:localhost/127.0.0.1:6650], consumerId 0
16:14:06.282 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032] Subscribing on
topic persistent://marianas/alphatrader/wing-calibration / __compaction
16:14:06.282 [pulsar-io-50-41] INFO
org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[marianas/alphatrader/persistent/wing-calibration-__compaction] Rewind from
13911:130 to 13911:130
16:14:06.282 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://marianas/alphatrader/wing-calibration] There are no replicated
subscriptions on the topic
16:14:06.282 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.persistent.PersistentTopic -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Created new
subscription for 0
16:14:06.282 [pulsar-io-50-41] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:42032] Created
subscription on topic persistent://marianas/alphatrader/wing-calibration /
__compaction
16:14:06.282 [pulsar-client-io-101-1] INFO
org.apache.pulsar.client.impl.ConsumerImpl -
[persistent://marianas/alphatrader/wing-calibration][__compaction] Subscribed
to topic on localhost/127.0.0.1:6650 -- consumer: 0
```
----------------------------------------------------------------
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:
[email protected]
