Known importers: 120 (displaying 139 packages, including internal and invalid packages)
- github.com/Alibay/go-kit/kafka
- github.com/LeeZXin/zsf/logger
- github.com/NSObjects/ima/internal/pump/pumps
- github.com/RHEnVision/provisioning-backend/internal/kafka
- github.com/RonkyTang/go-queue/kq
- github.com/TykTechnologies/tyk-pump/pumps
- github.com/adambabik/kafka_exporter/internal/segment
- github.com/arjun-1/kafkagosaur/src/kafkagosaur
- github.com/arquivei/goduck/impl/implstream/kafkasegmentio
- github.com/arsfox/xk6-kafka
- github.com/artie-labs/transfer/processes/consumer
- 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/blackhorseya/monorepo-go/pkg/transports/kafkax
- github.com/bryce4651/pkg/kfk
- github.com/chaos-mesh/chaosd/pkg/server/chaosd
- github.com/chenjie199234/config/config
- github.com/chenquan/go-queue/kafka
- github.com/chenzhiwei/kafka/utils/config
- github.com/creepzed/url-shortener-service/app/shortener/infrastructure/queue/kafka/common
- github.com/dairongpeng/leona/internal/gstash/gstashs
- github.com/daylikon/xk6-kafka
- github.com/devexps/go-micro/broker/kafka/v2
- github.com/dmachard/go-dnscollector/loggers
- github.com/dotunj/pvent/producer
- github.com/ego-component/ekafka
- github.com/falcosecurity/falcosidekick/outputs
- 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/frain-dev/convoy/internal/pkg/pubsub/kafka
- github.com/go-bamboo/pkg/client/kafka
- github.com/go-juno/kit/message-queue/kafka
- github.com/golly-go/plugins/kafka
- github.com/gowins/dionysus/kafka
- github.com/gozelus/gokafka
- github.com/gw123/gutils/kafka
- github.com/halilylm/logruskafka
- github.com/housepower/clickhouse_sinker/input
- github.com/hurx/coverser/util/kafka
- github.com/ihatiko/kafka-client
- 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/lf-edge/ekuiper/extensions/kafka
- 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/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/mostafa/xk6-kafka
- github.com/musobarlab/kafka-cli
- github.com/ngyugive/goat_kit/pkg/event/kafka
- github.com/nsobjects/ima/internal/pump/pumps
- github.com/ometcenter/keeper/kafka
- github.com/onecombine/onecombine-msg-validator/src/utils
- 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/pingcap/tiflow/pkg/sink/kafka/v2
- github.com/qa-tools-family/iam/internal/pump/pumps
- github.com/rfancn/hdget-sdk/lib/mq/provider/kafkago
- github.com/rudderlabs/rudder-go-kit/kafkaclient
- github.com/rumis/storage/skafka
- github.com/segmentio/topicctl/pkg/admin
- 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/stdyum/api-auth/internal/config
- github.com/superproj/onex/pkg/options
- github.com/tanqiuqiang/go-queue/kq
- 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/viru-tech/clickhouse_sinker/input
- 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/xiongdi9456/go-queue/kq
- github.com/zeromicro/go-queue/kq
- gitlab.com/bensivo/kcli/internal/client
- gitlab.com/incubus8/go/kafka
- gitlab.ws/zeromicro/go-queue/kq
- go.dfds.cloud/aad-aws-sync/internal/kafkautil