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
index 048a38753c..d2aaa069db 100644
--- 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
@@ -177,7 +177,7 @@ protected static ByteBuf responseToByteBuf(AbstractResponse response, KafkaHeade
         }
     }
 
-    protected Boolean channelReady() {
+    protected boolean channelReady() {
         return hasAuthenticated();
     }
 
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionCoordinator.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionCoordinator.java
index 7630703e9f..9ae81853ae 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionCoordinator.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionCoordinator.java
@@ -555,7 +555,7 @@ private void endTransaction(String transactionalId,
                                 Long producerId,
                                 Short producerEpoch,
                                 TransactionResult txnMarkerResult,
-                                Boolean isFromClient,
+                                boolean isFromClient,
                                 Consumer<Errors> callback) {
         AtomicBoolean isEpochFence = new AtomicBoolean(false);
         if (transactionalId == null || transactionalId.isEmpty()) {
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionMetadata.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionMetadata.java
index f2a61fd608..c00ad61b38 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionMetadata.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionMetadata.java
@@ -387,7 +387,7 @@ private static class BumpEpochResult {
     public TxnTransitMetadata prepareProducerIdRotation(Long newProducerId,
                                   Integer newTxnTimeoutMs,
                                   Long updateTimestamp,
-                                  Boolean recordLastEpoch) {
+                                  boolean recordLastEpoch) {
         if (hasPendingTransaction()) {
             throw new IllegalStateException("Cannot rotate producer ids while a transaction is still pending");
         }
@@ -489,7 +489,7 @@ public void addPartitions(Set<TopicPartition> partitions) {
         topicPartitions.addAll(partitions);
     }
 
-    public Boolean pendingTransitionInProgress() {
+    public boolean pendingTransitionInProgress() {
         return this.pendingState.isPresent();
     }
 
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/stats/PrometheusTextFormatUtil.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/stats/PrometheusTextFormatUtil.java
index a751b3802a..81ca2489ff 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/stats/PrometheusTextFormatUtil.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/stats/PrometheusTextFormatUtil.java
@@ -90,9 +90,9 @@ public static void writeOpStat(SimpleTextOutputStream w, String name, DataSketch
     }
 
     private static void writeQuantile(SimpleTextOutputStream w, DataSketchesOpStatsLogger opStat, String name,
-                                      Boolean success, double quantile) {
+                                      boolean success, double quantile) {
         w.write(name)
-                .write("{success=\"").write(success.toString())
+                .write("{success=\"").write(success)
                 .write("\",quantile=\"").write(Double.toString(quantile));
         if (!opStat.getLabels().isEmpty()) {
             w.write("\", ");
@@ -105,8 +105,8 @@ private static void writeQuantile(SimpleTextOutputStream w, DataSketchesOpStatsL
     }
 
     private static void writeCount(SimpleTextOutputStream w, DataSketchesOpStatsLogger opStat, String name,
-                                   Boolean success) {
-        w.write(name).write("_count{success=\"").write(success.toString());
+                                   boolean success) {
+        w.write(name).write("_count{success=\"").write(success);
         if (!opStat.getLabels().isEmpty()) {
             w.write("\", ");
             writeLabelsNoBraces(w, opStat.getLabels());
@@ -118,8 +118,8 @@ private static void writeCount(SimpleTextOutputStream w, DataSketchesOpStatsLogg
     }
 
     private static void writeSum(SimpleTextOutputStream w, DataSketchesOpStatsLogger opStat, String name,
-                                 Boolean success) {
-        w.write(name).write("_sum{success=\"").write(success.toString());
+                                 boolean success) {
+        w.write(name).write("_sum{success=\"").write(success);
         if (!opStat.getLabels().isEmpty()) {
             w.write("\", ");
             writeLabelsNoBraces(w, opStat.getLabels());