Update kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaCommandDecoder.java

eolivelli · BewareMyPower · web-flow · commit 8de0f495f4f1 · 2022-12-27T09:06:15.000+01:00
Co-authored-by: Yunze Xu &lt;xyzinfernity@163.com&gt;
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaCommandDecoder.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaCommandDecoder.java
@@ -649,10 +649,10 @@ public void bufferReleased() {
         }
 
         public void close() {
-           if (!released.compareAndSet(false, true)) {
-               return;
-           }
-           ReferenceCountUtil.safeRelease(this.buffer);
+             if (!released.compareAndSet(false, true)) {
+                return;
+            }
+            ReferenceCountUtil.safeRelease(this.buffer);
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -649,10 +649,10 @@ public void bufferReleased() {`
`649`	`649`	`}`
`650`	`650`
`651`	`651`	`public void close() {`
`652`		`- if (!released.compareAndSet(false, true)) {`
`653`		`- return;`
`654`		`- }`
`655`		`- ReferenceCountUtil.safeRelease(this.buffer);`
	`652`	`+ if (!released.compareAndSet(false, true)) {`
	`653`	`+ return;`
	`654`	`+ }`
	`655`	`+ ReferenceCountUtil.safeRelease(this.buffer);`
`656`	`656`	`}`
`657`	`657`	`}`
`658`	`658`