Skip to content

Commit 9ef5d5a

Browse files
Meflhuangdx0726
authored andcommitted
Fix the params broken by PR apache#4400 (apache#7795)
### Motivation The PR apache#4400 introduced new params on the pulsar-client consume command but it broked some old ones. ### Modifications This PR fixes this problem to restore the good param behavior.
1 parent 7bcf355 commit 9ef5d5a

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

  • pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli

pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -205,16 +205,16 @@ private int consume(String topic) {
205205
builder.topic(topic);
206206
}
207207

208-
ConsumerBuilder<byte[]> consumerBuilder = client.newConsumer().topic(topic);
209208
if (this.maxPendingChuckedMessage > 0) {
210-
consumerBuilder.maxPendingChuckedMessage(this.maxPendingChuckedMessage);
209+
builder.maxPendingChuckedMessage(this.maxPendingChuckedMessage);
211210
}
212211
if (this.receiverQueueSize > 0) {
213-
consumerBuilder.maxPendingChuckedMessage(this.receiverQueueSize);
212+
builder.receiverQueueSize(this.receiverQueueSize);
214213
}
215-
Consumer<byte[]> consumer = consumerBuilder.subscriptionName(this.subscriptionName)
216-
.autoAckOldestChunkedMessageOnQueueFull(this.autoAckOldestChunkedMessageOnQueueFull)
217-
.subscriptionType(subscriptionType).subscribe();
214+
215+
builder.autoAckOldestChunkedMessageOnQueueFull(this.autoAckOldestChunkedMessageOnQueueFull);
216+
217+
Consumer<byte[]> consumer = builder.subscribe();
218218

219219
RateLimiter limiter = (this.consumeRate > 0) ? RateLimiter.create(this.consumeRate) : null;
220220
while (this.numMessagesToConsume == 0 || numMessagesConsumed < this.numMessagesToConsume) {

0 commit comments

Comments
 (0)