[pulsar-broker] Cleanup already deleted namespace topics
* [pulsar-broker] Cleanup already deleted namespace topics
* add error-codes
* Revert "add error-codes"
This reverts commit
* Revert "[pulsar-broker] Cleanup already deleted namespace topics"
This reverts commit
* send success if producer is already closed
* send success if consumer is already closed
@@ -1358,9 +1358,8 @@ public class ServerCnx extends PulsarHandler {
CompletableFuture<Producer> producerFuture = producers.get(producerId);
if (producerFuture == null) {
- log.warn("[{}] Producer {} was not registered on the connection", remoteAddress, producerId);
- ctx.writeAndFlush(Commands.newError(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;
}
@@ -1401,8 +1400,8 @@ public class ServerCnx extends PulsarHandler {
CompletableFuture<Consumer> consumerFuture = consumers.get(consumerId);
if (consumerFuture == null) {
- log.warn("[{}] Consumer was not registered on the connection: {}", consumerId, remoteAddress);
- ctx.writeAndFlush(Commands.newError(requestId, ServerError.MetadataError, "Consumer not found"));
+ log.info("[{}] Consumer was not registered on the connection: {}", consumerId, remoteAddress);
+ ctx.writeAndFlush(Commands.newSuccess(requestId));
return;
}
