Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[fix][broker] Fix String wrong format #21829

Merged
merged 1 commit into from
Jan 2, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -824,7 +824,7 @@ public void readEntryComplete(Entry entry, Object ctx) {

@Override
public String toString() {
return String.format("Cursor [{}] get Nth entry", ManagedCursorImpl.this);
return String.format("Cursor [%s] get Nth entry", ManagedCursorImpl.this);
}
}, null);

Expand Down Expand Up @@ -1544,7 +1544,7 @@ public synchronized void readEntryFailed(ManagedLedgerException mle, Object ctx)

@Override
public String toString() {
return String.format("Cursor [{}] async replay entries", ManagedCursorImpl.this);
return String.format("Cursor [%s] async replay entries", ManagedCursorImpl.this);
}
};

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1265,7 +1265,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) {

@Override
public String toString() {
return String.format("ML [{}] get earliest message publish time of pos",
return String.format("ML [%s] get earliest message publish time of pos",
ManagedLedgerImpl.this.name);
}
}, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2740,7 +2740,7 @@ public void readEntryComplete(Entry entry, Object ctx) {

@Override
public String toString() {
return String.format("Topic [{}] get entry batch size",
return String.format("Topic [%s] get entry batch size",
PersistentTopicsBase.this.topicName);
}
}, null);
Expand Down Expand Up @@ -2844,7 +2844,7 @@ public void readEntryComplete(Entry entry, Object ctx) {

@Override
public String toString() {
return String.format("Topic [{}] internal get message by id",
return String.format("Topic [%s] internal get message by id",
PersistentTopicsBase.this.topicName);
}
}, null);
Expand Down Expand Up @@ -3016,7 +3016,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) {

@Override
public String toString() {
return String.format("Topic [{}] internal examine message async",
return String.format("Topic [%s] internal examine message async",
PersistentTopicsBase.this.topicName);
}
}, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2227,7 +2227,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) {

@Override
public String toString() {
return String.format("ServerCnx [{}] get largest batch index when possible",
return String.format("ServerCnx [%s] get largest batch index when possible",
ServerCnx.this.ctx.channel());
}
}, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -533,7 +533,7 @@ public void readEntryComplete(Entry entry, Object ctx) {

@Override
public String toString() {
return String.format("Replication [{}] peek Nth message",
return String.format("Replication [%s] peek Nth message",
PersistentReplicator.this.producer.getProducerName());
}
}, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -887,7 +887,7 @@ public void readEntryComplete(Entry entry, Object ctx) {

@Override
public String toString() {
return String.format("Subscription [{}-{}] async replay entries", PersistentSubscription.this.topicName,
return String.format("Subscription [%s-%s] async replay entries", PersistentSubscription.this.topicName,
PersistentSubscription.this.subName);
}
}, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -330,7 +330,7 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) {

@Override
public String toString() {
return String.format("Transaction buffer [{}] recover from snapshot",
return String.format("Transaction buffer [%s] recover from snapshot",
SnapshotSegmentAbortedTxnProcessorImpl.this.topic.getName());
}
}, null);
Expand Down
Loading