Known importers: 163 (displaying 191 packages, including internal and invalid packages)
- bitbucket.org/rctiplus/vegapunk/event/kafka
- git.gz.internal.jumaiyx.cn/pkg/kafka
- gitee.com/go-kade/mcube/ioc/config/kafka
- github.com/0xanonymeow/kafka-go/kafka
- github.com/2997215859/gomdsdk/consumer
- github.com/Alibay/go-kit/kafka
- github.com/AmanKumar2696/sidekick/outputs
- github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/infrastructure
- github.com/Cobalt0s/creme-brulee/pkg/tech/kmanager
- github.com/Egor123qwe/loggy/pkg/producer
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue
- github.com/LeeZXin/zsf/mq/kafkamq
- github.com/NSObjects/ima/internal/pump/pumps
- github.com/PingCAP-QE/ee-apps/cloudevents-server/pkg/kafka
- github.com/RHEnVision/provisioning-backend/internal/kafka
- github.com/RapidCodeLab/ZapLogger
- github.com/Rosas99/smsx/pkg/options
- github.com/RumbiaID/pkg-library/app/pkg/broker/kafkaservice
- github.com/Tencent/bk-bcs/bcs-services/bcs-data-manager/cmd
- github.com/Tuhis/edge-receiver/pkg/kafkawrapper
- github.com/TykTechnologies/tyk-pump/pumps
- github.com/abulo/ratel/kafka
- github.com/achillescres/pkg/kafka
- github.com/adityaeka26/go-pkg/kafka
- github.com/akazwz/gin-api/kafka/counter
- github.com/allenshri/go-queue/kq
- github.com/angel-one/amx-margin/utils/kafka
- github.com/arjun-1/kafkagosaur/src/kafkagosaur
- github.com/arsfox/xk6-kafka
- github.com/artie-labs/transfer/lib/kafkalib
- github.com/backendlitit/go-common-copy/kafka_listener
- github.com/bangunindo/trap2json/forwarder
- github.com/batchcorp/kng
- github.com/bhorovyi/xk6-kafka
- github.com/bryce4651/pkg/kfk
- github.com/chaos-mesh/chaosd/pkg/server/chaosd
- github.com/chenjie199234/config/config
- github.com/chenzhiwei/kafka/utils/config
- github.com/chili-ios/convoy-go/v2/example/kafka
- github.com/chrismoos/caddy-events-kafka
- github.com/chrusty/kafka-cli/internal/configuration
- github.com/common-go/kafka
- github.com/crwnl3ss/watchdoge/pkg/check
- github.com/cultureamp/ca-go/kafka/consumer
- github.com/dairongpeng/leona/internal/gstash/gstashs
- github.com/danmaxdanilov/zts.shared/pkg/messaging
- github.com/daylikon/xk6-kafka
- github.com/dev-ansh-r/dcalpwan-server/internal/integration/kafka
- github.com/devexps/go-micro/broker/kafka/v2
- github.com/devyk100/gengou-db/internal/kafka_internal
- github.com/diki-haryadi/govega/event/kafka
- github.com/dimonleksin/kurl/pkg/kfk
- github.com/dmachard/go-dnscollector/workers
- github.com/dotunj/pvent/producer
- github.com/ego-component/ekafka
- github.com/falcosecurity/falcosidekick/outputs
- github.com/fancar/tmp_xm/internal/kafka
- github.com/fcristovao/await
- github.com/ferditatlisu/kafka-search-consumer-go/pkg/client
- github.com/ferras777/xk6-kafka
- github.com/fleezesd/kafka-example/kafka-go-demo/SASL
- github.com/fmo/football-data
- github.com/foundation-go/foundation/kafka
- github.com/franciscosbf/free-market-common/pkg/clients/kafka
- github.com/gfa-inc/gfa/common/mq/kafkax
- github.com/go-gotop/kit/broker/kafka
- github.com/gustavobertoi/realtime/pkg/pubsub
- github.com/gw123/gutils/kafka
- github.com/halilylm/logruskafka
- github.com/highlight-run/highlight/backend/kafka-queue
- github.com/housepower/clickhouse_sinker/input
- github.com/hurricane1988/harbor-webhook/pkg/sources/kafka
- github.com/integration-system/isp-event-lib/kafka
- github.com/ir0njaw/falcosidekick/outputs
- github.com/jkkkls/logtail
- github.com/johnvicke/snuber/apps/graphql-api/pkg/kafka
- github.com/justinmoonca/go-queue/kq
- github.com/justtrackio/gosoline/pkg/kafka/connection
- github.com/kamicuu/chirpstack-application-server/internal/integration/kafka
- github.com/kedacore/keda/v2/pkg/scalers
- github.com/keepchen/go-sail/v3/lib/kafka
- github.com/knhn1004/hackathon-tiktok-shop-recommendation-engine/api-node/internal/services/kafka
- github.com/ksooo091/kafka-go
- github.com/ksysoev/kafka-cli/cmd
- github.com/kubearmor/sidekick/outputs
- github.com/loggie-io/loggie/pkg/sink/kafka
- github.com/mammenj/go-health/queues
- github.com/marmotedu/iam/internal/pump/pumps
- github.com/mft-labs/amf_kafka
- github.com/mostafa/xk6-kafka
- github.com/nambrosini/kcp/kafka
- github.com/nsobjects/ima/internal/pump/pumps
- github.com/oddbit-project/blueprint/provider/kafka
- github.com/ogibayashi/sample-app-golang/service/kafka
- github.com/onno-vos-dev/await
- github.com/pbudner/argosminer/sources
- github.com/pecigonzalo/kafka-canary/internal/client
- github.com/pellizzetti/fsfc-simulator/infra/kafka
- github.com/phenixrizen/topicctl/pkg/admin
- github.com/phthom/asset-tools-aiops-roks/src
- github.com/ponyjackal/eventual-consistency-blog/services
- github.com/qa-tools-family/iam/internal/pump/pumps
- github.com/raft-tech/df-kafka-go
- github.com/rosas99/monster/pkg/options
- github.com/rudderlabs/rudder-go-kit/kafkaclient
- github.com/segmentio/topicctl/pkg/admin
- github.com/senyu-up/toolbox/tool/mq/aws_kafka
- github.com/sergiusd/redbus/internal/pkg/kafka/credential
- github.com/serviceexchange/server/services/streammanager/kafka/client
- github.com/seymac/xk6-kafka
- github.com/shipperizer/kilo-franz/sasl
- github.com/sigmasee/sigmasee/shared/enterprise/messaging/kafka/kafka-go
- github.com/skeleton1231/go-iam-ecommerce-microservice/internal/pump/pumps
- github.com/sko00o/kafka/producer/kafkago
- github.com/snail-plus/gopkg/options
- github.com/sswastioyono18/vaccination-demo/cmd
- github.com/sturn/go-queue/kq
- github.com/superproj/onex/pkg/options
- github.com/supersstone/interviewcode/go-code/internal/mqs
- github.com/tianet/ditto/pkg/adapters/producer
- github.com/tx7do/kratos-transport/broker/kafka
- github.com/unkeyed/unkey/apps/api/pkg/kafka
- github.com/vedrankolka/donation-server/pkg/notifier/kafka
- github.com/viru-tech/clickhouse_sinker/input
- github.com/wangzhen94/iam/internal/pump/pumps
- github.com/wardab0104/eventstream-go-sdk/v3
- github.com/xh-dev-go/ip-publisher/IpDetect
- github.com/zackarysantana/velocity/internal/service/kafka
- github.com/zhangsq-ax/aws-msk-helper-go
- gitlab.com/bensivo/kcli/internal/client