[pulsar] branch branch-2.7 updated: [pulsar-broker] Cleanup already deleted namespace topics. (#12583)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.7 by this push:
     new 6e4c9d2  [pulsar-broker] Cleanup already deleted namespace topics. 
(#12583)
6e4c9d2 is described below

commit 6e4c9d2bc5903950deeadc02db12eb0f8db94657
Author: Jiwei Guo <techno...@apache.org>
AuthorDate: Sat Nov 20 00:06:44 2021 +0800

    [pulsar-broker] Cleanup already deleted namespace topics. (#12583)
---
 .../main/java/org/apache/pulsar/broker/service/ServerCnx.java    | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
index 22e2d28..697d4e5 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -1419,9 +1419,8 @@ public class ServerCnx extends PulsarHandler implements 
TransportCnx {
 
         CompletableFuture<Producer> producerFuture = producers.get(producerId);
         if (producerFuture == null) {
-            log.warn("[{}] Producer was not registered on the connection. 
producerId={}", remoteAddress, producerId);
-            commandSender.sendErrorResponse(requestId, 
ServerError.UnknownError,
-                    "Producer was not registered on the connection");
+            log.info("[{}] Producer {} was not registered on the connection", 
remoteAddress, producerId);
+            ctx.writeAndFlush(Commands.newSuccess(requestId));
             return;
         }
 
@@ -1466,8 +1465,8 @@ public class ServerCnx extends PulsarHandler implements 
TransportCnx {
 
         CompletableFuture<Consumer> consumerFuture = consumers.get(consumerId);
         if (consumerFuture == null) {
-            log.warn("[{}] Consumer was not registered on the connection: 
consumerId={}", remoteAddress, consumerId);
-            commandSender.sendErrorResponse(requestId, 
ServerError.MetadataError, "Consumer not found");
+            log.info("[{}] Consumer was not registered on the connection: {}", 
consumerId, remoteAddress);
+            ctx.writeAndFlush(Commands.newSuccess(requestId));
             return;
         }