You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ti...@apache.org on 2023/01/12 03:56:48 UTC
[pulsar] branch master updated: [fix] Some typos in Cmd classes (#19190)
This is an automated email from the ASF dual-hosted git repository.
tison pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 89b1ff10107 [fix] Some typos in Cmd classes (#19190)
89b1ff10107 is described below
commit 89b1ff1010706b647cf11a564ae2a3a5916bc715
Author: lixinyang <84...@users.noreply.github.com>
AuthorDate: Thu Jan 12 11:56:40 2023 +0800
[fix] Some typos in Cmd classes (#19190)
Co-authored-by: nicklixinyang <ni...@didiglobal.com>
---
.../main/java/org/apache/pulsar/admin/cli/CmdPackages.java | 2 +-
.../main/java/org/apache/pulsar/admin/cli/CmdTopics.java | 2 +-
.../java/org/apache/pulsar/common/protocol/Commands.java | 14 +++++++-------
3 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java
index ba9e67a5b41..24214a89c57 100644
--- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java
+++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPackages.java
@@ -100,7 +100,7 @@ class CmdPackages extends CmdBase {
@Parameter(names = "--contact", description = "contact information of a package")
private String contact;
- @DynamicParameter(names = {"--properties", "-P"}, description = "external infromations of a package")
+ @DynamicParameter(names = {"--properties", "-P"}, description = "external information of a package")
private Map<String, String> properties = new HashMap<>();
@Parameter(names = "--path", description = "file path of the package", required = true)
diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
index 116252cca6d..874eb038e9d 100644
--- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
+++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
@@ -1169,7 +1169,7 @@ public class CmdTopics extends CmdBase {
Map<Integer, MessageId> messageIds = getTopics().terminatePartitionedTopic(persistentTopic);
for (Map.Entry<Integer, MessageId> entry: messageIds.entrySet()) {
String topicName = persistentTopic + "-partition-" + entry.getKey();
- System.out.println("Topic " + topicName + " succesfully terminated at " + entry.getValue());
+ System.out.println("Topic " + topicName + " successfully terminated at " + entry.getValue());
}
}
}
diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
index 4d4d64f7fe9..081dfe4275b 100644
--- a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
+++ b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
@@ -499,25 +499,25 @@ public class Commands {
DEFAULT_CONSUMER_EPOCH), metadataAndPayload);
}
- public static ByteBufPair newSend(long producerId, long sequenceId, int numMessaegs, ChecksumType checksumType,
+ public static ByteBufPair newSend(long producerId, long sequenceId, int numMessages, ChecksumType checksumType,
long ledgerId, long entryId, MessageMetadata messageMetadata, ByteBuf payload) {
- return newSend(producerId, sequenceId, -1 /* highestSequenceId */, numMessaegs,
+ return newSend(producerId, sequenceId, -1 /* highestSequenceId */, numMessages,
messageMetadata.hasTxnidLeastBits() ? messageMetadata.getTxnidLeastBits() : -1,
messageMetadata.hasTxnidMostBits() ? messageMetadata.getTxnidMostBits() : -1,
checksumType, ledgerId, entryId, messageMetadata, payload);
}
- public static ByteBufPair newSend(long producerId, long sequenceId, int numMessaegs, ChecksumType checksumType,
+ public static ByteBufPair newSend(long producerId, long sequenceId, int numMessages, ChecksumType checksumType,
MessageMetadata messageMetadata, ByteBuf payload) {
- return newSend(producerId, sequenceId, -1 /* highestSequenceId */, numMessaegs,
+ return newSend(producerId, sequenceId, -1 /* highestSequenceId */, numMessages,
messageMetadata.hasTxnidLeastBits() ? messageMetadata.getTxnidLeastBits() : -1,
messageMetadata.hasTxnidMostBits() ? messageMetadata.getTxnidMostBits() : -1,
checksumType, -1, -1, messageMetadata, payload);
}
- public static ByteBufPair newSend(long producerId, long lowestSequenceId, long highestSequenceId, int numMessaegs,
+ public static ByteBufPair newSend(long producerId, long lowestSequenceId, long highestSequenceId, int numMessages,
ChecksumType checksumType, MessageMetadata messageMetadata, ByteBuf payload) {
- return newSend(producerId, lowestSequenceId, highestSequenceId, numMessaegs,
+ return newSend(producerId, lowestSequenceId, highestSequenceId, numMessages,
messageMetadata.hasTxnidLeastBits() ? messageMetadata.getTxnidLeastBits() : -1,
messageMetadata.hasTxnidMostBits() ? messageMetadata.getTxnidMostBits() : -1,
checksumType, -1, -1, messageMetadata, payload);
@@ -1993,7 +1993,7 @@ public class Commands {
case ExclusiveWithFencing:
return ProducerAccessMode.ExclusiveWithFencing;
default:
- throw new IllegalArgumentException("Unknonw access mode: " + accessMode);
+ throw new IllegalArgumentException("Unknown access mode: " + accessMode);
}
}