diff --git a/src/main/java/io/ipfs/api/IPFS.java b/src/main/java/io/ipfs/api/IPFS.java
index 7704fad..b6285c8 100755
--- a/src/main/java/io/ipfs/api/IPFS.java
+++ b/src/main/java/io/ipfs/api/IPFS.java
@@ -232,7 +232,7 @@ public Object peers() throws IOException {
         }
 
         public Object peers(String topic) throws IOException {
-            return retrieveAndParse("pubsub/peers?topic="+topic);
+            return retrieveAndParse("pubsub/peers?arg="+topic);
         }
 
         /**