diff --git a/pom.xml b/pom.xml
index 02e981da..a4e542c0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -130,13 +130,13 @@
     <junit.version>4.13.2</junit.version>
     <junitparams.version>1.1.1</junitparams.version>
     <logback.version>1.5.18</logback.version>
-    <logback.steno.version>2.1.2</logback.steno.version>
+    <logback.steno.version>2.2.0</logback.steno.version>
     <log4j.over.slf4j.version>2.0.17</log4j.over.slf4j.version>
     <metrics.client.version>0.13.0</metrics.client.version>
     <metrics.client.incubator.version>0.13.0</metrics.client.incubator.version>
     <metrics.jvm.extra.version>0.13.1</metrics.jvm.extra.version>
-    <metrics.http.extra.version>0.13.1</metrics.http.extra.version>
-    <metrics.aggregator.protocol.version>1.2.1</metrics.aggregator.protocol.version>
+    <metrics.http.extra.version>0.14.0</metrics.http.extra.version>
+    <metrics.aggregator.protocol.version>1.3.0</metrics.aggregator.protocol.version>
     <mockito.version>5.18.0</mockito.version>
     <netty.version>4.0.56.Final</netty.version>
     <netty.all.version>4.0.21.Final</netty.all.version>
@@ -144,7 +144,7 @@
     <oval.version>3.2.1</oval.version>
     <play.ws.version>3.0.7</play.ws.version>
     <postgresql.version>42.7.6</postgresql.version>
-    <protobuf.version>3.25.5</protobuf.version>
+    <protobuf.version>4.31.1</protobuf.version>
     <reflections.version>0.11.7</reflections.version>
     <scala.version>2.13</scala.version>
     <scala.library.version>2.13.16</scala.library.version>
diff --git a/src/main/java/com/arpnetworking/clusteraggregator/client/AggClientConnection.java b/src/main/java/com/arpnetworking/clusteraggregator/client/AggClientConnection.java
index 685ed3e9..a102d6a6 100644
--- a/src/main/java/com/arpnetworking/clusteraggregator/client/AggClientConnection.java
+++ b/src/main/java/com/arpnetworking/clusteraggregator/client/AggClientConnection.java
@@ -28,7 +28,7 @@
 import com.arpnetworking.tsdcore.statistics.Statistic;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
-import com.google.protobuf.GeneratedMessageV3;
+import com.google.protobuf.GeneratedMessage;
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import org.apache.pekko.actor.AbstractActor;
 import org.apache.pekko.actor.ActorRef;
@@ -153,7 +153,7 @@ private void processMessages() {
         while (messageOptional.isPresent()) {
             final AggregationMessage message = messageOptional.get();
             current = current.drop(message.getLength());
-            final GeneratedMessageV3 gm = message.getMessage();
+            final GeneratedMessage gm = message.getMessage();
             if (gm instanceof Messages.HostIdentification) {
                 final Messages.HostIdentification hostIdent = (Messages.HostIdentification) gm;
                 _hostName = Optional.ofNullable(hostIdent.getHostName());
diff --git a/src/main/java/com/arpnetworking/clusteraggregator/client/HttpSourceActor.java b/src/main/java/com/arpnetworking/clusteraggregator/client/HttpSourceActor.java
index 552d5dda..088eff0d 100644
--- a/src/main/java/com/arpnetworking/clusteraggregator/client/HttpSourceActor.java
+++ b/src/main/java/com/arpnetworking/clusteraggregator/client/HttpSourceActor.java
@@ -36,7 +36,7 @@
 import com.google.common.util.concurrent.AtomicDouble;
 import com.google.inject.Inject;
 import com.google.inject.name.Named;
-import com.google.protobuf.GeneratedMessageV3;
+import com.google.protobuf.GeneratedMessage;
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import org.apache.http.HttpHeaders;
 import org.apache.pekko.Done;
@@ -145,8 +145,8 @@ private void handleAggregation(
 
         final AggregationMode aggregationMode = aggregationRequest.getAggregationMode();
         for (final AggregationMessage aggregationMessage : aggregationRequest.getAggregationMessages()) {
-            final GeneratedMessageV3 generatedMessageV3 = aggregationMessage.getMessage();
-            if (generatedMessageV3 instanceof Messages.StatisticSetRecord) {
+            final GeneratedMessage generatedMessage = aggregationMessage.getMessage();
+            if (generatedMessage instanceof Messages.StatisticSetRecord) {
                 final Messages.StatisticSetRecord statisticSetRecord =
                         (Messages.StatisticSetRecord) aggregationMessage.getMessage();
 
diff --git a/src/main/java/com/arpnetworking/tsdcore/model/AggregationMessage.java b/src/main/java/com/arpnetworking/tsdcore/model/AggregationMessage.java
index 8943bc0f..e3f9cdd1 100644
--- a/src/main/java/com/arpnetworking/tsdcore/model/AggregationMessage.java
+++ b/src/main/java/com/arpnetworking/tsdcore/model/AggregationMessage.java
@@ -16,7 +16,7 @@
 package com.arpnetworking.tsdcore.model;
 
 import com.arpnetworking.metrics.aggregation.protocol.Messages;
-import com.google.protobuf.GeneratedMessageV3;
+import com.google.protobuf.GeneratedMessage;
 import com.google.protobuf.InvalidProtocolBufferException;
 import org.apache.commons.codec.binary.Hex;
 import org.apache.pekko.util.ByteIterator;
@@ -42,7 +42,7 @@ public final class AggregationMessage {
      * @param message The message.
      * @return New {@link AggregationMessage} instance.
      */
-    public static AggregationMessage create(final GeneratedMessageV3 message) {
+    public static AggregationMessage create(final GeneratedMessage message) {
         return new AggregationMessage(message);
     }
 
@@ -139,7 +139,7 @@ public ByteString serialize() {
         return AggregationMessage.serialize(_message);
     }
 
-    private static ByteString serialize(final GeneratedMessageV3 message) {
+    private static ByteString serialize(final GeneratedMessage message) {
         final ByteStringBuilder b = ByteString.createBuilder();
         if (message instanceof Messages.HostIdentification) {
             b.putByte((byte) 0x01);
@@ -166,7 +166,7 @@ private static ByteString serialize(final GeneratedMessageV3 message) {
         return sizePrefix.result().concat(b.result());
     }
 
-    public GeneratedMessageV3 getMessage() {
+    public GeneratedMessage getMessage() {
         return _message;
     }
 
@@ -174,16 +174,16 @@ public int getLength() {
         return _length;
     }
 
-    private AggregationMessage(final GeneratedMessageV3 message) {
+    private AggregationMessage(final GeneratedMessage message) {
         this(message, serialize(message).length());
     }
 
-    private AggregationMessage(final GeneratedMessageV3 message, final int length) {
+    private AggregationMessage(final GeneratedMessage message, final int length) {
         _length = length;
         _message = message;
     }
 
-    private final GeneratedMessageV3 _message;
+    private final GeneratedMessage _message;
     private final int _length;
 
     private static final int BYTE_SIZE_IN_BYTES = 1;
diff --git a/src/test/java/com/arpnetworking/tsdcore/model/AggregationMessageTest.java b/src/test/java/com/arpnetworking/tsdcore/model/AggregationMessageTest.java
index 90d60ebd..d0f0bffb 100644
--- a/src/test/java/com/arpnetworking/tsdcore/model/AggregationMessageTest.java
+++ b/src/test/java/com/arpnetworking/tsdcore/model/AggregationMessageTest.java
@@ -16,7 +16,7 @@
 package com.arpnetworking.tsdcore.model;
 
 import com.arpnetworking.metrics.aggregation.protocol.Messages;
-import com.google.protobuf.GeneratedMessageV3;
+import com.google.protobuf.GeneratedMessage;
 import org.apache.pekko.util.ByteString;
 import org.apache.pekko.util.ByteStringBuilder;
 import org.junit.Assert;
@@ -34,7 +34,7 @@ public class AggregationMessageTest {
 
     @Test
     public void testHostIdentification() {
-        final GeneratedMessageV3 protobufMessage = Messages.HostIdentification.getDefaultInstance();
+        final GeneratedMessage protobufMessage = Messages.HostIdentification.getDefaultInstance();
         final AggregationMessage message = AggregationMessage.create(protobufMessage);
         Assert.assertNotNull(message);
         Assert.assertSame(protobufMessage, message.getMessage());
@@ -65,7 +65,7 @@ public void testHostIdentification() {
 
     @Test(expected = IllegalArgumentException.class)
     public void testSerializedUnsupportedMessage() {
-        final GeneratedMessageV3 message = Messages.SparseHistogramEntry.newBuilder()
+        final GeneratedMessage message = Messages.SparseHistogramEntry.newBuilder()
                 .build();
         AggregationMessage.create(message).serialize();
     }