Known importers: 94 (displaying 120 packages, including internal and invalid packages)
- gitee.com/jerryduren/architecture/go-with-domain/demo5gc/libs/platform/dms
- github.com/DIMO-Network/vehicle-signal-decoding/internal/infrastructure/kafka
- github.com/Improwised/golang-api/pkg/watermill
- github.com/KejawenLab/bima/v4/messengers/brokers
- github.com/Planxnx/message-processing-api/alarm-service/internal/router
- github.com/Planxnx/message-processing-api/alarm-service/pkg/connection
- github.com/Planxnx/message-processing-api/alarm-service/pkg/connection/kafka
- github.com/Planxnx/message-processing-api/external-caller-service/cmd
- github.com/Planxnx/message-processing-api/external-caller-service/internal/api/messagequeue
- github.com/Planxnx/message-processing-api/external-caller-service/internal/message
- github.com/Planxnx/message-processing-api/external-caller-service/pkg/kafka
- github.com/Planxnx/message-processing-api/gateway-service/api/messagequeue
- github.com/Planxnx/message-processing-api/gateway-service/api/restful/message
- github.com/Planxnx/message-processing-api/gateway-service/internal/message
- github.com/Planxnx/message-processing-api/gateway-service/pkg/kafka
- github.com/Planxnx/message-processing-api/scheduler-service/cmd
- github.com/Planxnx/message-processing-api/scheduler-service/internal/api/messagequeue
- github.com/Planxnx/message-processing-api/scheduler-service/internal/message
- github.com/Planxnx/message-processing-api/scheduler-service/pkg/connection
- github.com/Planxnx/message-processing-api/scheduler-service/pkg/connection/kafka
- github.com/Planxnx/message-processing-api/scheduler-service/pkg/cron
- github.com/ThreeDotsLabs/watermill-benchmark/pkg
- github.com/Unheilbar/test_kafka
- github.com/agalue/onms-sink-syslog
- github.com/alexcuse/edgex-watermill/v2/kafka
- github.com/apoldev/trackchecker/internal/app/track/delivery/watermill-kafka
- github.com/as-rabbit/go-connect/event_driven/events/water-mill
- github.com/bimalabs/framework/v4/messengers/brokers
- github.com/ckbball/smurfin-email
- github.com/depocket/support/queue/kafka
- github.com/evertontomalok/distributed-system-go/internal/infra/kafka
- github.com/f1monkey/f1monkey/internal/kafka
- github.com/formancehq/go-libs/v2/sharedpublish/sharedpublishkafka
- github.com/fwidjaya20/symphonic/event
- github.com/gearpoint/filepoint/pkg/watermill
- github.com/go-baselib/postgresql-cdc/internal/publisher
- github.com/ijidan/jsocial/internal/pkg/pubsub
- github.com/kachvame/gayway/cmd/gayway
- github.com/kasper023/shop/transport
- github.com/kitanoyoru/kitaDriveBot/apps/service/internal/api/kafka/v0
- github.com/muktiarafi/ticketing-common
- github.com/nekizz/final-project/backend/booking/booking
- github.com/nekizz/final-project/backend/booking/cmd
- github.com/nekizz/final-project/backend/booking/util
- github.com/nekizz/final-project/backend/orchestrator/cmd
- github.com/nekizz/final-project/backend/orchestrator/orchestrator
- github.com/nekizz/final-project/backend/payment/cmd
- github.com/nekizz/final-project/backend/payment/payment
- github.com/nekizz/final-project/backend/room/cmd
- github.com/nekizz/final-project/backend/room/room
- github.com/ormanli/rest-kafka-bridge-example
- github.com/program-world-labs/DDDGo/pkg/message
- github.com/purposeinplay/go-commons/pubsub/kafka
- github.com/rakamoviz/kincirair/cmd/cqrskafka
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_domain
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_domain_partitioned_processor
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_domain_partitioned_publisher
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_eventdenormalizer
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_eventdenormalizer_partitioned
- github.com/rakamoviz/kincirair/cmd/kafkapublisher
- github.com/rakamoviz/kincirair/cmd/kafkasubscriber
- github.com/ramadani/starboost
- github.com/rizalgowandy/gdk/pkg/queue/watermillx/pubsub
- github.com/ryanyogan/watermill-basics
- github.com/sanservices/kit/kafkalistener
- github.com/tommynurwantoro/kafkid/internal/adapter/kafka
- github.com/ttagiyeva/superstream/internal/watermill
- github.com/weezqyd/ringier/internal/adapters/msb
- github.com/ygaros/event-driven-example