fix consume filter tests.

Author: YoEight

src/main/java/io/kurrent/dbclient/v2/ConsumeFilter.java

@@ -172,7 +172,7 @@ public static ConsumeFilter fromStream(String stream) {
      * @throws IllegalArgumentException If the prefixes are invalid.
      */
     public static ConsumeFilter fromPrefixes(ConsumeFilterScope scope, String... prefixes) {
-        if (prefixes.length == 0)
+        if (prefixes == null || prefixes.length == 0)
             throw new IllegalArgumentException("Prefixes cannot be empty.");
 
         StringBuilder patternBuilder = new StringBuilder("^(");
@@ -188,7 +188,7 @@ public static ConsumeFilter fromPrefixes(ConsumeFilterScope scope, String... pre
             patternBuilder.append(Pattern.quote(prefix));
             first = false;
         }
-        patternBuilder.append(")");
+        patternBuilder.append(").*");
 
         String pattern = patternBuilder.toString();
         return new ConsumeFilter(