diff --git a/connector-java/src/main/java/io/zeebe/hazelcast/connect/java/ZeebeHazelcast.java b/connector-java/src/main/java/io/zeebe/hazelcast/connect/java/ZeebeHazelcast.java
index b797098..effd41f 100644
--- a/connector-java/src/main/java/io/zeebe/hazelcast/connect/java/ZeebeHazelcast.java
+++ b/connector-java/src/main/java/io/zeebe/hazelcast/connect/java/ZeebeHazelcast.java
@@ -46,6 +46,8 @@ public class ZeebeHazelcast implements AutoCloseable {
     RECORD_MESSAGE_TYPES.add(Schema.DecisionRecord.class);
     RECORD_MESSAGE_TYPES.add(Schema.DecisionRequirementsRecord.class);
     RECORD_MESSAGE_TYPES.add(Schema.DecisionEvaluationRecord.class);
+    RECORD_MESSAGE_TYPES.add(Schema.SignalRecord.class);
+    RECORD_MESSAGE_TYPES.add(Schema.SignalSubscriptionRecord.class);
   }
 
   private final Ringbuffer<byte[]> ringbuffer;
@@ -368,6 +370,17 @@ public Builder addDecisionEvaluationListener(
       return this;
     }
 
+    public Builder addSignalListener(Consumer<Schema.SignalRecord> listener) {
+      addListener(Schema.SignalRecord.class, listener);
+      return this;
+    }
+
+    public Builder addSignalSubscriptionListener(
+        Consumer<Schema.SignalSubscriptionRecord> listener) {
+      addListener(Schema.SignalSubscriptionRecord.class, listener);
+      return this;
+    }
+
     private long getSequence(Ringbuffer<?> ringbuffer) {
 
       final var headSequence = ringbuffer.headSequence();
diff --git a/pom.xml b/pom.xml
index 56ee036..d303556 100644
--- a/pom.xml
+++ b/pom.xml
@@ -16,8 +16,8 @@
     </parent>
 
     <properties>
-        <version.zeebe>8.2.0-rc1</version.zeebe>
-        <version.exporter.protobuf>1.4.0-alpha1</version.exporter.protobuf>
+        <version.zeebe>8.2.0</version.zeebe>
+        <version.exporter.protobuf>1.4.0</version.exporter.protobuf>
         <version.hazelcast>5.2.3</version.hazelcast>
         <version.log4j>2.20.0</version.log4j>
         <version.zeebe.testcontainers>3.5.2</version.zeebe.testcontainers>