Known importers: 189 (displaying 216 packages, including internal and invalid packages)
- bitbucket.org/bsdrpst/gopkg/q/kafka
- bitbucket.org/credmais/kafka/pkg/mensageria/segmentio-kafka
- bitbucket.org/rctiplus/vegapunk/event/kafka
- github.com/2pgcn/gameim/internal/logic/data
- github.com/508284405/leetcode2/kafka
- github.com/Alibay/go-kit/kafka
- github.com/AmanKumar2696/sidekick/outputs
- github.com/GRMrGecko/freeipa-health-metrics
- github.com/ISSHEB/Core/kafka
- github.com/Junjiayy/hamal/pkg/core/readers
- github.com/LeeZXin/zsf/logger
- 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/RonkyTang/go-queue/kq
- github.com/Rosas99/smsx/pkg/options
- github.com/RumbiaID/pkg-library/app/pkg/broker/kafkaservice
- github.com/TykTechnologies/tyk-pump/pumps
- github.com/adambabik/kafka_exporter/internal/segment
- github.com/allenshri/go-queue/kq
- github.com/arjun-1/kafkagosaur/src/kafkagosaur
- github.com/arquivei/goduck/impl/implstream/kafkasegmentio
- github.com/arsfox/xk6-kafka
- github.com/ashwinyue/monster/pkg/options
- github.com/backendlitit/go-common-copy/kafka_listener
- github.com/bangunindo/trap2json/forwarder
- github.com/batchcorp/kng
- github.com/bhorovyi/xk6-kafka
- github.com/bigzhuk/kafka-adapter
- github.com/bryce4651/pkg/kfk
- github.com/cetnfurkan/core/mq
- github.com/chaos-mesh/chaosd/pkg/server/chaosd
- github.com/chengfield/go-queue/kq
- github.com/chenjie199234/config/config
- github.com/chenquan/go-queue/kafka
- github.com/chenzhiwei/kafka/utils/config
- github.com/cjfinnell/kafgo/internal
- github.com/creepzed/url-shortener-service/app/shortener/infrastructure/queue/kafka/common
- github.com/dairongpeng/leona/internal/gstash/gstashs
- github.com/databendcloud/bend-ingest-kafka
- github.com/daylikon/xk6-kafka
- github.com/deepshore/xk6-kafka
- github.com/dev-ansh-r/dcalpwan-server/internal/integration/kafka
- github.com/devexps/go-micro/broker/kafka/v2
- github.com/dgdts/UniversalServer/pkg/kafka
- github.com/diki-haryadi/govega/event/kafka
- github.com/dmachard/go-dnscollector/workers
- github.com/dotunj/pvent/producer
- github.com/drio/go-lambda-kafka/handler/producer
- github.com/ego-component/ekafka
- github.com/falcosecurity/falcosidekick/outputs
- github.com/fancar/tmp_xm/internal/kafka
- github.com/fcristovao/await
- github.com/ferras777/xk6-kafka
- github.com/festum/gopkg/kafka
- github.com/figueyes/shortener-app/app/shortener/infrastructure/queue/kafka/config
- github.com/foundation-go/foundation/kafka
- github.com/getsentry/vroom/cmd/vroom
- github.com/gfa-inc/gfa/common/mq/kafkax
- github.com/go-bamboo/pkg/queue/kafka
- github.com/go-gotop/kit/broker/kafka
- github.com/golly-go/plugins/kafka
- github.com/gowins/dionysus/kafka
- github.com/gozelus/gokafka
- github.com/gw123/gutils/kafka
- github.com/haixi01wen/kratos-transport/broker/kafka
- github.com/halilylm/logruskafka
- github.com/heshaofeng1991/core/middlewares/kafka
- github.com/housepower/clickhouse_sinker/input
- github.com/hurricane1988/harbor-webhook/pkg/sources/kafka
- github.com/hurx/coverser/util/kafka
- github.com/ichbingautam/real-time-log-ingestion-and-anomaly-detection-system/internal/messaging
- github.com/integration-system/isp-event-lib/kafka
- github.com/ir0njaw/falcosidekick/outputs
- github.com/justinmoonca/go-queue/kq
- 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/kevinyjn/gocom/mq/kafka
- github.com/khulnasoft/fanal/outputs
- github.com/kochabonline/kit/store/kafka
- github.com/kubearmor/sidekick/outputs
- github.com/lhdhtrc/kafka-go/pkg
- github.com/libpub/golib/mq/kafka
- github.com/lidaboo/go-queue/kq
- github.com/lidofinance/dc4bc/storage/kafka_storage
- github.com/linkingthing/clxone-utils/alarm
- github.com/loggie-io/loggie/pkg/sink/kafka
- github.com/lukwil/project-tools/Kafka-Rest-Bridge
- github.com/luyasr/gaia/stores/kafka
- github.com/lwinmgmg/outbox/service
- github.com/m3co/kafko
- github.com/marmotedu/iam/internal/pump/pumps
- github.com/megaease/easeprobe/probe/client/kafka
- github.com/mft-labs/amf_kafka
- github.com/milktea736/cassandra-sink-connector/kafkaconsumer
- github.com/mix-plus/go-queue/kq
- github.com/mosajjal/dnsmonster/internal/output
- github.com/mostafa/xk6-kafka
- github.com/musobarlab/kafka-cli
- github.com/nguyenta1993/service-kit/kafka
- github.com/ngyugive/goat_kit/pkg/event/kafka
- github.com/nioliu/commons/log
- github.com/nsobjects/ima/internal/pump/pumps
- github.com/oddbit-project/blueprint/provider/kafka
- github.com/ometcenter/keeper/kafka
- github.com/onexstack/onexstack/pkg/options
- github.com/onno-vos-dev/await
- github.com/pankaj-kumar34/event-stream/internal/dialer
- github.com/pecigonzalo/kafka-canary/internal/client
- github.com/phenixrizen/topicctl/pkg/admin
- github.com/philips-software/gautocloud-connectors/hsdp
- github.com/prb112/fhir-kafka-go
- github.com/qa-tools-family/iam/internal/pump/pumps
- github.com/raczu/kube2kafka/pkg/exporter
- github.com/rfancn/hdget-sdk/lib/mq/provider/kafkago
- github.com/rosas99/monster/pkg/options
- github.com/rsi2m/xk6-kafka-fixed
- github.com/rudderlabs/rudder-go-kit/kafkaclient
- github.com/rumis/storage/skafka
- github.com/segmentio/topicctl/pkg/admin
- github.com/senyu-up/toolbox/tool/mq/aws_kafka
- github.com/serviceexchange/server/services/streammanager/kafka/client
- github.com/seymac/xk6-kafka
- github.com/shaozi17/go-queue/kq
- github.com/shipperizer/kilo-franz/sasl
- github.com/skeleton1231/go-iam-ecommerce-microservice/internal/pump/pumps
- github.com/sko00o/kafka/producer/kafkago
- github.com/snail-plus/gopkg/options
- github.com/stdyum/api-auth/internal/config
- github.com/stellar/stellar-disbursement-platform-backend/internal/events
- github.com/sturn/go-queue/kq
- github.com/superproj/onex/pkg/options
- github.com/tanqiuqiang/go-queue/kq
- github.com/tarmalonchik/kafkawrapper
- github.com/telkomdev/tob/services/kafka
- github.com/tianet/ditto/pkg/adapters/producer
- github.com/tx7do/kratos-transport/broker/kafka
- github.com/ubntc/go/kstore/provider/kafkago
- github.com/uncorde/uncorde/internal/integration/kafka
- github.com/visforest/windy/kq
- github.com/wanglixianyii/go-kratos/user-job/pkg/broker/kafka
- github.com/wangzhen94/iam/internal/pump/pumps
- github.com/wfusion/easeprobe/probe/client/kafka
- github.com/ws6/klib
- github.com/xiaocok/go-tools/pkg/kafka
- github.com/xiongdi9456/go-queue/kq
- github.com/zeromicro/go-queue/kq
- gitlab.com/bensivo/kcli/internal/client
- gitlab.com/falaleev-go/kafkamux
- gitlab.com/incubus8/go/kafka
- gitlab.ws/zeromicro/go-queue/kq