diff --git a/src/main/java/io/nats/client/JetStreamSubscription.java b/src/main/java/io/nats/client/JetStreamSubscription.java
index c1ea1a866..f4aae8c02 100644
--- a/src/main/java/io/nats/client/JetStreamSubscription.java
+++ b/src/main/java/io/nats/client/JetStreamSubscription.java
@@ -26,6 +26,12 @@
  */
 public interface JetStreamSubscription extends Subscription {
 
+    /**
+     * Gets the consumer name that was used to create the subscription.
+     * @return the consumer name
+     */
+    String getConsumerName();
+
     /**
      * Initiate pull with the specified batch size.
      * ! Pull subscriptions only. Push subscription will throw IllegalStateException
diff --git a/src/main/java/io/nats/client/impl/ErrorListenerLoggerImpl.java b/src/main/java/io/nats/client/impl/ErrorListenerLoggerImpl.java
index 66558a1a9..3e5a9a46d 100644
--- a/src/main/java/io/nats/client/impl/ErrorListenerLoggerImpl.java
+++ b/src/main/java/io/nats/client/impl/ErrorListenerLoggerImpl.java
@@ -36,6 +36,10 @@ private String supplyMessage(String label, Connection conn, Consumer consumer, S
         }
         if (sub != null) {
             sb.append(", Subscription: ").append(sub.hashCode());
+            if (sub instanceof JetStreamSubscription) {
+                JetStreamSubscription jssub = (JetStreamSubscription)sub;
+                sb.append(", Consumer Name: ").append(jssub.getConsumerName());
+            }
         }
         for (int x = 0; x < pairs.length; x++) {
             sb.append(", ").append(pairs[x]).append(pairs[++x]);
diff --git a/src/main/java/io/nats/client/impl/NatsJetStreamSubscription.java b/src/main/java/io/nats/client/impl/NatsJetStreamSubscription.java
index b1b45835f..edaefcaa2 100644
--- a/src/main/java/io/nats/client/impl/NatsJetStreamSubscription.java
+++ b/src/main/java/io/nats/client/impl/NatsJetStreamSubscription.java
@@ -57,7 +57,8 @@ void setConsumerName(String consumerName) {
         this.consumerName = consumerName;
     }
 
-    String getConsumerName() {
+    @Override
+    public String getConsumerName() {
         return consumerName;
     }