adress comment

Author: poorbarcode

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetPositionImpl.java

@@ -35,9 +35,9 @@ public class AckSetPositionImpl implements Position, AckSetState {
     protected volatile long[] ackSet;
     @Getter
     @Setter
-    private int batchMessagesAckedCount;
+    private volatile int batchMessagesAckedCount;
     @Getter
-    private boolean positionRemovedFromCursor;
+    private volatile boolean positionRemovedFromCursor;
 
     public AckSetPositionImpl(long ledgerId, long entryId, long[] ackSet) {
         this.ledgerId = ledgerId;

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java

@@ -662,8 +662,8 @@ private void updatePendingAckMessagesAfterAcknowledged0(Consumer ackFrom, List<P
             // Reduce un-acknowledged messages.
             owner.addAndGetUnAckedMsgs(owner, -actualAcked);
             owner.updateBlockedConsumerOnUnackedMsgs(owner);
-            if (log.isInfoEnabled()) {
-                log.info("[{}][{}] {}-{}-{} {}-{}-{} acknowledged {} messages, un-ack-msg: {}, position: {}:{}"
+            if (log.isDebugEnabled()) {
+                log.debug("[{}][{}] {}-{}-{} {}-{}-{} acknowledged {} messages, un-ack-msg: {}, position: {}:{}"
                                 + " batch messages acked: {}, position {}:{} was deleted: {}",
                         topicName, subName, owner.cnx(), owner.consumerId(), owner.consumerName(),
                         ackFrom == null ? "null" : ackFrom.cnx(),