fixes rotuer invoke

example/sampleapp/main.go

@@ -1,10 +1,9 @@
-//go:build ignore
-
 package main
 
 import (
 	"context"
 	"fmt"
+
 	"github.com/gojekfarm/ziggurat/v2"
 	"github.com/gojekfarm/ziggurat/v2/kafka"
 	"github.com/gojekfarm/ziggurat/v2/logger"
@@ -17,19 +16,23 @@ func main() {
 	l := logger.NewLogger(logger.LevelInfo)
 
 	kcg := kafka.ConsumerGroup{
-		Logger: logger.NewLogger(logger.LevelInfo),
+		Logger: l,
 		GroupConfig: kafka.ConsumerConfig{
 			BootstrapServers: "g-gojek-id-mainstream.golabs.io:6668",
-			GroupID:          "foo.id",
+			GroupID:          "bar.id",
 			ConsumerCount:    1,
+			AutoOffsetReset:  "earliest",
 			Topics:           []string{"^.*-booking-log"},
 		},
 	}
 
-	if runErr := zig.Run(ctx, ziggurat.HandlerFunc(func(ctx context.Context, event *ziggurat.Event) {
+	router := ziggurat.NewRouter()
+	router.HandlerFunc("bar.id/.*", func(ctx context.Context, event *ziggurat.Event) {
 		fmt.Println("path:", event.RoutingPath)
-	}), &kcg); runErr != nil {
-		l.Error("error running consumers", runErr)
+	})
+
+	if runErr := zig.Run(ctx, router, &kcg); runErr != nil {
+		l.Error("error running streams", runErr)
 	}
 
 }

router.go

@@ -94,7 +94,7 @@ func (r *Router) Handle(ctx context.Context, event *Event) {
 	path := event.RoutingPath
 	h, _ := r.match(path)
 	if h != nil {
-		return
+		h.Handle(ctx, event)
 	}
 	return
 }

router_test.go

@@ -54,6 +54,14 @@ func Test_match(t *testing.T) {
 				{pattern: "foo.id/foo/"},
 			},
 		},
+		{
+			name:  "should not match similar consumer group names",
+			want:  "bar.id/.*",
+			paths: []string{"bar.id/GO_BIRD_COMBO-booking-log/11"},
+			input: []routerEntry{
+				{pattern: "bar.id/.*"},
+			},
+		},
 	}
 
 	esToMap := func(es []routerEntry) map[string]routerEntry {