Known importers: 895 (displaying 985 packages, including internal and invalid packages)
- git.halomobi.net/common/halolib/kafka
- git.kuainiujinke.com/bc-backend/nb/broker
- gitee.com/KaiErDeLe/higo/pkg/databus/kafka
- gitee.com/Madou-Shinni/go-fastmq/kafka
- gitee.com/alexleix/pkgs/mq
- gitee.com/coyte/commons/libs/mq
- gitee.com/emmm_admin/xgameCommon/akNet
- gitee.com/fashionpalace/base/kafka/consumer
- gitee.com/laotie999/guardian/app/sys_service
- gitee.com/leaf-rain-gitee/goim/internal/job
- gitee.com/leicc/go-core
- gitee.com/phper95/pkg/mq
- gitee.com/zym950511/test/async
- github.com/18905603704/openbilibili/go-common/app/admin/main/apm/service
- github.com/18905603704/openbilibili/go-common/app/infra/databus/tcp
- github.com/18905603704/openbilibili/go-common/app/infra/notify/notify
- github.com/18905603704/openbilibili/go-common/app/interface/openplatform/monitor-end/service
- github.com/18905603704/openbilibili/go-common/app/job/main/app-wall/service/offer
- github.com/1uvu/bilibili-go-common-master/app/admin/main/apm/service
- github.com/1uvu/bilibili-go-common-master/app/infra/databus/tcp
- github.com/1uvu/bilibili-go-common-master/app/infra/notify/notify
- github.com/1uvu/bilibili-go-common-master/app/interface/openplatform/monitor-end/service
- github.com/1uvu/bilibili-go-common-master/app/job/main/app-wall/service/offer
- github.com/2329408386/sarama-cluster/cmd/sarama-cluster-cli
- github.com/33cn/externaldb/mq/kafka
- github.com/AlexStocks/goext/log/kafka
- github.com/Andrew-M-C/tencent-tars-demo/GoKafkaConsumer
- github.com/Apstra/telegraf/plugins/inputs/kafka_consumer
- github.com/Bsm/sarama-cluster/cmd/sarama-cluster-cli
- github.com/CHneger/sarama-cluster/cmd/sarama-cluster-cli
- github.com/CiscoM31/sarama-cluster/cmd/sarama-cluster-cli
- github.com/Click2Cloud/multi-cloud/datamover/pkg/kafka
- github.com/EAHITechnology/raptor/emq
- github.com/FanThreeSixty/kafkactl/commands
- github.com/GreatSir/realclouds_go/middleware
- github.com/InVisionApp/benthos/lib/input/reader
- github.com/JeffreyDing11223/kago
- github.com/Kistler-Group/eh-kafka
- github.com/KylinHe/aliensboot-core/mq/kafka
- github.com/LOOIS-IO/relay-lib/kafka
- github.com/Laisky/go-kafka
- github.com/Loopring/relay-lib/kafka
- github.com/MateusCastello/kafka-topic-cloner/kafka
- github.com/Microsoft/presidio/pkg/stream/kafka
- github.com/Nordstrom/kandi
- github.com/ONSdigital/dp-dd-csv-filter
- github.com/PAWSOME-INDONESIA/paw_kit/messaging/kafka-sarama
- github.com/ParticleMedia/join-log-dumper/server
- github.com/Pluto-tv/furan/lib/kafka
- github.com/ScaleFT/sarama-cluster/cmd/sarama-cluster-cli
- github.com/SheepGardener/alpaca-mq
- github.com/Terry-Mao/goim/internal/job
- github.com/UESTC-KEEP/keep/cloud/pkg/common/kafka
- github.com/ZR233/golog
- github.com/acger/consumer-svc
- github.com/agave/ah-microservices/services/users/events
- github.com/aidan-/benthos/lib/input/reader
- github.com/airdb/go-demo/kafka
- github.com/alexshtin/cadence/tools/cli
- github.com/alexstocks/goext/log/kafka
- github.com/alkorin/sarama-cluster/cmd/sarama-cluster-cli
- github.com/allan-2stars/bstation/app/admin/main/apm/service
- github.com/allan-2stars/bstation/app/infra/databus/tcp
- github.com/allan-2stars/bstation/app/infra/notify/notify
- github.com/allan-2stars/bstation/app/interface/openplatform/monitor-end/service
- github.com/allan-2stars/bstation/app/job/main/app-wall/service/offer
- github.com/alrs/furan/lib/kafka
- github.com/altairsix/pkg/eventsourcex/kafka
- github.com/andrew-m-c/tencent-tars-demo/GoKafkaConsumer
- github.com/anovateam/benthos/lib/input/reader
- github.com/appuri/sarama-cluster/cmd/sarama-cluster-cli
- github.com/apstra/telegraf/plugins/inputs/kafka_consumer
- github.com/ar3s3ru/benthos/lib/input/reader
- github.com/aravindvs/sarama-cluster/cmd/sarama-cluster-cli
- github.com/arcology-network/main/modules/p2p/conn/receiver
- github.com/arkady-emelyanov/kafkabeat/beater
- github.com/arlxn/bilibili-master-backup/app/admin/main/apm/service
- github.com/arlxn/bilibili-master-backup/app/infra/databus/tcp
- github.com/arlxn/bilibili-master-backup/app/infra/notify/notify
- github.com/arlxn/bilibili-master-backup/app/interface/openplatform/monitor-end/service
- github.com/arlxn/bilibili-master-backup/app/job/main/app-wall/service/offer
- github.com/asiragusa/benthos/lib/input/reader
- github.com/babex-group/babex-kafka
- github.com/bigomby/k2http
- github.com/bingtianyiyan/youki_gotools/kafkaexternal/consumer
- github.com/blaskovicz/heroku-kafka-demo-go
- github.com/blastbao/goim/internal/job
- github.com/blastbao/openbilibili-go-common-1/app/admin/main/apm/service
- github.com/blastbao/openbilibili-go-common-1/app/infra/databus/tcp
- github.com/blastbao/openbilibili-go-common-1/app/infra/notify/notify
- github.com/blastbao/openbilibili-go-common-1/app/interface/openplatform/monitor-end/service
- github.com/blastbao/openbilibili-go-common-1/app/job/main/app-wall/service/offer
- github.com/boyand/sarama-cluster/_examples
- github.com/boyisire/golang_codes/core/base
- github.com/bsm/Sarama-cluster/cmd/sarama-cluster-cli
- github.com/bxsmart/bxcore/kafka
- github.com/cafra/utils/mq/kafka
- github.com/calvindjy/iteago/process/kafka
- github.com/camlabs/gomq-kafka
- github.com/certifaction/benthos/lib/input/reader
- github.com/cha87de/sarama-cluster/cmd/sarama-cluster-cli
- github.com/changwh/go-common/app/admin/main/apm/service
- github.com/changwh/go-common/app/infra/databus/tcp
- github.com/changwh/go-common/app/infra/notify/notify
- github.com/changwh/go-common/app/interface/openplatform/monitor-end/service
- github.com/changwh/go-common/app/job/main/app-wall/service/offer
- github.com/checkr/openmock
- github.com/chengtengfei/mongoshake-rubick/src/mongoshake/tunnel/kafka
- github.com/chenjinya/dilidili-go-common/app/admin/main/apm/service
- github.com/chenjinya/dilidili-go-common/app/infra/databus/tcp
- github.com/chenjinya/dilidili-go-common/app/infra/notify/notify
- github.com/chenjinya/dilidili-go-common/app/interface/openplatform/monitor-end/service
- github.com/chenjinya/dilidili-go-common/app/job/main/app-wall/service/offer
- github.com/chentao/telegraf/plugins/inputs/kafka_consumer
- github.com/chneger/sarama-cluster/cmd/sarama-cluster-cli
- github.com/chrisho/mosquito/alikafka
- github.com/ciscom31/sarama-cluster/cmd/sarama-cluster-cli
- github.com/civet148/gotools/mq/kafka
- github.com/clementkng/cloud-sdr/cloud/sdr/sdr-data-ingest/example-go-clients
- github.com/click2cloud/multi-cloud/datamover/pkg/kafka
- github.com/clouderwork/sarama-cluster/cmd/sarama-cluster-cli
- github.com/cludden/benthos/lib/input/reader
- github.com/cnfinder/sarama-cluster/cmd/sarama-cluster-cli
- github.com/codecruzer/sarama-cluster/cmd/sarama-cluster-cli
- github.com/cookingkode/book/reservation
- github.com/crast/sarama-cluster/_examples
- github.com/crud3306/go/02-Advance/05-MQ/01-Kafka/src
- github.com/cyriiilZ/horse/mq/kafka
- github.com/d33d33/sarama-cluster/cmd/sarama-cluster-cli
- github.com/dailyhunt/feed/kafka
- github.com/damithadayananda/golang-example/consumer
- github.com/datager/codes/gocodes/dg/utils/clients
- github.com/denislobanov/go-pubsub/kafka
- github.com/digbrand1977/tinymonitor/plugins/inputs/kafka_consumer
- github.com/dingzhenying/bilibili-opencode/app/admin/main/apm/service
- github.com/dingzhenying/bilibili-opencode/app/infra/databus/tcp
- github.com/dingzhenying/bilibili-opencode/app/infra/notify/notify
- github.com/dingzhenying/bilibili-opencode/app/interface/openplatform/monitor-end/service
- github.com/dingzhenying/bilibili-opencode/app/job/main/app-wall/service/offer
- github.com/dishesdog/b-go-common/app/admin/main/apm/service
- github.com/dishesdog/b-go-common/app/infra/databus/tcp
- github.com/dishesdog/b-go-common/app/infra/notify/notify
- github.com/dishesdog/b-go-common/app/interface/openplatform/monitor-end/service
- github.com/dishesdog/b-go-common/app/job/main/app-wall/service/offer
- github.com/dishine/libary/mq/kafka
- github.com/dmitryilyin/kafkabeat/beater
- github.com/dubin555/kafkascale/worker
- github.com/dylanpeng/goproject/src/mq/kafka/consumer
- github.com/eager7/go_study/2019/kafka
- github.com/edfungus/conduction/messenger
- github.com/ehsbaiu/backup-of-openbilibili-go-common/app/admin/main/apm/service
- github.com/ehsbaiu/backup-of-openbilibili-go-common/app/infra/databus/tcp
- github.com/ehsbaiu/backup-of-openbilibili-go-common/app/infra/notify/notify
- github.com/ehsbaiu/backup-of-openbilibili-go-common/app/interface/openplatform/monitor-end/service
- github.com/ehsbaiu/backup-of-openbilibili-go-common/app/job/main/app-wall/service/offer
- github.com/embrace-io/sarama-cluster/cmd/sarama-cluster-cli
- github.com/esser420/multistreamingserver/consumer/kafka
- github.com/featurebasedb/pdk/kafka
- github.com/findcoo/stream/kafka
- github.com/finogeeks/ligase/cmd/kafka-test
- github.com/fish-pro/ginbase
- github.com/frairon/goka-godays2019/01-sarama/sarama-cluster
- github.com/friddle/openbilibili-go-common/app/admin/main/apm/service
- github.com/friddle/openbilibili-go-common/app/infra/databus/tcp
- github.com/friddle/openbilibili-go-common/app/infra/notify/notify
- github.com/friddle/openbilibili-go-common/app/interface/openplatform/monitor-end/service
- github.com/friddle/openbilibili-go-common/app/job/main/app-wall/service/offer
- github.com/ftamas88/kafka-test/internal/consumer
- github.com/fucang/sarama-cluster/cmd/sarama-cluster-cli
- github.com/gabrielg/benthos/lib/input/reader
- github.com/gamedev-ai/bilibili_repo/app/admin/main/apm/service
- github.com/gamedev-ai/bilibili_repo/app/infra/databus/tcp
- github.com/gamedev-ai/bilibili_repo/app/infra/notify/notify
- github.com/gamedev-ai/bilibili_repo/app/interface/openplatform/monitor-end/service
- github.com/gamedev-ai/bilibili_repo/app/job/main/app-wall/service/offer
- github.com/gaopengfei123123/go_study/src/kafka_demo/sarama
- github.com/gaystudio/openbilibili/app/admin/main/apm/service
- github.com/gaystudio/openbilibili/app/infra/databus/tcp
- github.com/gaystudio/openbilibili/app/infra/notify/notify
- github.com/gaystudio/openbilibili/app/interface/openplatform/monitor-end/service
- github.com/gaystudio/openbilibili/app/job/main/app-wall/service/offer
- github.com/gdchenli/kafka_demo/pkg/kafka
- github.com/gdwgh/mu-li-xian-bei/app/admin/main/apm/service
- github.com/gdwgh/mu-li-xian-bei/app/infra/databus/tcp
- github.com/gdwgh/mu-li-xian-bei/app/infra/notify/notify
- github.com/gdwgh/mu-li-xian-bei/app/interface/openplatform/monitor-end/service
- github.com/gdwgh/mu-li-xian-bei/app/job/main/app-wall/service/offer
- github.com/genius52/bigdata/kafka_demo/main
- github.com/geniusrabbit/notificationcenter/kafka
- github.com/ggordan/go-pubsub/kafka
- github.com/go-gadgets/eventsourcing/distribution/kafka
- github.com/go-ocf/cqrs/eventbus/kafka
- github.com/goees/yago/coms/kafka
- github.com/gotcp/connector
- github.com/graphext/furan/lib/kafka
- github.com/gua-pian/alibaba-dts-go
- github.com/gucio321/mosquito/alikafka
- github.com/guiyunweb/openbilibili/app/admin/main/apm/service
- github.com/guiyunweb/openbilibili/app/infra/databus/tcp
- github.com/guiyunweb/openbilibili/app/infra/notify/notify
- github.com/guiyunweb/openbilibili/app/interface/openplatform/monitor-end/service
- github.com/guiyunweb/openbilibili/app/job/main/app-wall/service/offer
- github.com/h7kanna/cadence/tools/cli
- github.com/hadwinzhy/test/src/kafka
- github.com/hero1s/golib/mq/kafka
- github.com/heshaofeng1991/core/middlewares/kafka
- github.com/heyHui2018/best-practise/service/kafka
- github.com/heyhui2018/best-practise/service/kafka
- github.com/hodgekou/openbilibili/app/admin/main/apm/service
- github.com/hodgekou/openbilibili/app/infra/databus/tcp
- github.com/hodgekou/openbilibili/app/infra/notify/notify
- github.com/hodgekou/openbilibili/app/interface/openplatform/monitor-end/service
- github.com/hodgekou/openbilibili/app/job/main/app-wall/service/offer
- github.com/hsuan-jen/go-common/app/admin/main/apm/service
- github.com/hsuan-jen/go-common/app/infra/databus/tcp
- github.com/hsuan-jen/go-common/app/infra/notify/notify
- github.com/hsuan-jen/go-common/app/interface/openplatform/monitor-end/service
- github.com/hsuan-jen/go-common/app/job/main/app-wall/service/offer
- github.com/huchgit/golang_zk/kafka_consumer
- github.com/huibin-yu/sarama-cluster/cmd/sarama-cluster-cli
- github.com/hulklab/yago/coms/kafka
- github.com/iTheWindRises/bilibili-source/app/admin/main/apm/service
- github.com/iTheWindRises/bilibili-source/app/infra/databus/tcp
- github.com/iTheWindRises/bilibili-source/app/infra/notify/notify
- github.com/iTheWindRises/bilibili-source/app/interface/openplatform/monitor-end/service
- github.com/iTheWindRises/bilibili-source/app/job/main/app-wall/service/offer
- github.com/iamfaith/go_common/Desktop/go-common-master/app/admin/main/apm/service
- github.com/iamfaith/go_common/Desktop/go-common-master/app/infra/databus/tcp
- github.com/iamfaith/go_common/Desktop/go-common-master/app/infra/notify/notify
- github.com/iamfaith/go_common/Desktop/go-common-master/app/interface/openplatform/monitor-end/service
- github.com/iamfaith/go_common/Desktop/go-common-master/app/job/main/app-wall/service/offer
- github.com/ihsanul14/go-confluent-kafka
- github.com/iluminae/benthos/lib/input/reader
- github.com/imjerrychan/gostudy/bilibili_fork-master/app/admin/main/apm/service
- github.com/imjerrychan/gostudy/bilibili_fork-master/app/infra/databus/tcp
- github.com/imjerrychan/gostudy/bilibili_fork-master/app/infra/notify/notify
- github.com/imjerrychan/gostudy/bilibili_fork-master/app/interface/openplatform/monitor-end/service
- github.com/imjerrychan/gostudy/bilibili_fork-master/app/job/main/app-wall/service/offer
- github.com/imkuqin-zw/final_consistency/plugins/kafka/consumer
- github.com/infantbee/skills/golang/kafka
- github.com/inloco/kafka-elasticsearch-injector/src/kafka
- github.com/invisionapp/benthos/lib/input/reader
- github.com/inwecrypto/gomq-kafka
- github.com/iooikaak/frame/mq/kafka
- github.com/itea-tgl/itea-go/process/kafka
- github.com/ithewindrises/bilibili-source/app/admin/main/apm/service
- github.com/ithewindrises/bilibili-source/app/infra/databus/tcp
- github.com/ithewindrises/bilibili-source/app/infra/notify/notify
- github.com/ithewindrises/bilibili-source/app/interface/openplatform/monitor-end/service
- github.com/ithewindrises/bilibili-source/app/job/main/app-wall/service/offer
- github.com/itumbrella/clicli-go-backend/app/admin/main/apm/service
- github.com/itumbrella/clicli-go-backend/app/infra/databus/tcp
- github.com/itumbrella/clicli-go-backend/app/infra/notify/notify
- github.com/itumbrella/clicli-go-backend/app/interface/openplatform/monitor-end/service
- github.com/itumbrella/clicli-go-backend/app/job/main/app-wall/service/offer
- github.com/ivost/go/test-kafka-avro
- github.com/jackjie2016/pkg/mq
- github.com/jaffee/pdk/kafka
- github.com/jdcloud-bds/bds/common/kafka
- github.com/jeffreyDing11223/kago
- github.com/jeffreyding11223/kago
- github.com/jiaoshenmene/bilibili-backup/app/admin/main/apm/service
- github.com/jiaoshenmene/bilibili-backup/app/infra/databus/tcp
- github.com/jiaoshenmene/bilibili-backup/app/infra/notify/notify
- github.com/jiaoshenmene/bilibili-backup/app/interface/openplatform/monitor-end/service
- github.com/jiaoshenmene/bilibili-backup/app/job/main/app-wall/service/offer
- github.com/jinglov/gomisc/kafka
- github.com/jingyanlei/go-test/src/kafka
- github.com/johng-cn/sarama-cluster/cmd/sarama-cluster-cli
- github.com/johngcn/sarama-cluster/cmd/sarama-cluster-cli
- github.com/justcallmewilliam/b_source_code/app/admin/main/apm/service
- github.com/justcallmewilliam/b_source_code/app/infra/databus/tcp
- github.com/justcallmewilliam/b_source_code/app/infra/notify/notify
- github.com/justcallmewilliam/b_source_code/app/interface/openplatform/monitor-end/service
- github.com/justcallmewilliam/b_source_code/app/job/main/app-wall/service/offer
- github.com/kailashyogeshwar85/slim-orderbook/cmd/slim-orderbook
- github.com/kbtxwer/openbilibili-go/app/admin/main/apm/service
- github.com/kbtxwer/openbilibili-go/app/infra/databus/tcp
- github.com/kbtxwer/openbilibili-go/app/infra/notify/notify
- github.com/kbtxwer/openbilibili-go/app/interface/openplatform/monitor-end/service
- github.com/kbtxwer/openbilibili-go/app/job/main/app-wall/service/offer
- github.com/kevinfan0/bilibili-go/app/admin/main/apm/service
- github.com/kevinfan0/bilibili-go/app/infra/databus/tcp
- github.com/kevinfan0/bilibili-go/app/infra/notify/notify
- github.com/kevinfan0/bilibili-go/app/interface/openplatform/monitor-end/service
- github.com/kevinfan0/bilibili-go/app/job/main/app-wall/service/offer
- github.com/kiereneinar/envelop/infra/kafka
- github.com/king2200/bilibli_golang/src/go-common/app/admin/main/apm/service
- github.com/king2200/bilibli_golang/src/go-common/app/infra/databus/tcp
- github.com/king2200/bilibli_golang/src/go-common/app/infra/notify/notify
- github.com/king2200/bilibli_golang/src/go-common/app/interface/openplatform/monitor-end/service
- github.com/king2200/bilibli_golang/src/go-common/app/job/main/app-wall/service/offer
- github.com/kistler-group/eh-kafka
- github.com/kms9/publicyc/pkg/client/okafka
- github.com/kong36088/danmu
- github.com/kumakichi/sarama-cluster/cmd/sarama-cluster-cli
- github.com/laincheung/bilibili-go-codego/app/admin/main/apm/service
- github.com/laincheung/bilibili-go-codego/app/infra/databus/tcp
- github.com/laincheung/bilibili-go-codego/app/infra/notify/notify
- github.com/laincheung/bilibili-go-codego/app/interface/openplatform/monitor-end/service
- github.com/laincheung/bilibili-go-codego/app/job/main/app-wall/service/offer
- github.com/lanfang/mysql-river/queue
- github.com/lanxingmo/sarama-cluster/cmd/sarama-cluster-cli
- github.com/lateefj/shylock/kafka
- github.com/lazyun/goland/kafkaTools/src/kafkaTools
- github.com/lcl1992421/bilibili/app/admin/main/apm/service
- github.com/lcl1992421/bilibili/app/infra/databus/tcp
- github.com/lcl1992421/bilibili/app/infra/notify/notify
- github.com/lcl1992421/bilibili/app/interface/openplatform/monitor-end/service
- github.com/lcl1992421/bilibili/app/job/main/app-wall/service/offer
- github.com/leboncoin/sarama-cluster/cmd/sarama-cluster-cli
- github.com/leicc520/go-core
- github.com/leizhu/incidents_consume
- github.com/ligang7138/go_rest/storage/kafka
- github.com/linux-doc/openbilibili-go-common/app/admin/main/apm/service
- github.com/linux-doc/openbilibili-go-common/app/infra/databus/tcp
- github.com/linux-doc/openbilibili-go-common/app/infra/notify/notify
- github.com/linux-doc/openbilibili-go-common/app/interface/openplatform/monitor-end/service
- github.com/linux-doc/openbilibili-go-common/app/job/main/app-wall/service/offer
- github.com/lioroger/subscribe_example/goimpl
- github.com/liqichen6688/pedestrain_distance/producersetting
- github.com/liteck/kafka
- github.com/liu-xuewen/openBilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/admin/main/apm/service
- github.com/liu-xuewen/openBilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/infra/databus/tcp
- github.com/liu-xuewen/openBilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/infra/notify/notify
- github.com/liu-xuewen/openBilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/interface/openplatform/monitor-end/service
- github.com/liu-xuewen/openBilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/job/main/app-wall/service/offer
- github.com/liu-xuewen/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/admin/main/apm/service
- github.com/liu-xuewen/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/infra/databus/tcp
- github.com/liu-xuewen/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/infra/notify/notify
- github.com/liu-xuewen/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/interface/openplatform/monitor-end/service
- github.com/liu-xuewen/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/job/main/app-wall/service/offer
- github.com/liudaved/go-lean-bilibili/app/admin/main/apm/service
- github.com/liudaved/go-lean-bilibili/app/infra/databus/tcp
- github.com/liudaved/go-lean-bilibili/app/infra/notify/notify
- github.com/liudaved/go-lean-bilibili/app/interface/openplatform/monitor-end/service
- github.com/liudaved/go-lean-bilibili/app/job/main/app-wall/service/offer
- github.com/ljjgs/pkg/mq
- github.com/lluckyboi/redrock_homework/mq_kafka/consumer
- github.com/loois-io/relay-lib/kafka
- github.com/loopfz/sarama-cluster/cmd/sarama-cluster-cli
- github.com/loopring/relay-lib/kafka
- github.com/lotreal/pdk/kafka
- github.com/louislaugier/crypto-exchange/engine
- github.com/lovego/kafka
- github.com/lpxxn/mygotest/kafkademo/demo3
- github.com/ls-2018/bilibilicode/app/admin/main/apm/service
- github.com/ls-2018/bilibilicode/app/infra/databus/tcp
- github.com/ls-2018/bilibilicode/app/infra/notify/notify
- github.com/ls-2018/bilibilicode/app/interface/openplatform/monitor-end/service
- github.com/ls-2018/bilibilicode/app/job/main/app-wall/service/offer
- github.com/ltick/tick-framework/module/queue
- github.com/lubit/klient
- github.com/luolr/bilibili_backup/app/admin/main/apm/service
- github.com/luolr/bilibili_backup/app/infra/databus/tcp
- github.com/luolr/bilibili_backup/app/infra/notify/notify
- github.com/luolr/bilibili_backup/app/interface/openplatform/monitor-end/service
- github.com/luolr/bilibili_backup/app/job/main/app-wall/service/offer
- github.com/lxt1045/kits/kafka
- github.com/lzhz2012/netsim/kafkaCliWrapper
- github.com/mactynow/commonutil/messaging/kafka-sarama
- github.com/marekgalovic/kafka-mysql
- github.com/mark-libn/istio-micro/internal/kafka
- github.com/marsmay/golib/kafka
- github.com/mateuscastello/kafka-topic-cloner/kafka
- github.com/mathpl/kafka_httpcat
- github.com/matrixvirus/bilibili_20190421/app/admin/main/apm/service
- github.com/matrixvirus/bilibili_20190421/app/infra/databus/tcp
- github.com/matrixvirus/bilibili_20190421/app/infra/notify/notify
- github.com/matrixvirus/bilibili_20190421/app/interface/openplatform/monitor-end/service
- github.com/matrixvirus/bilibili_20190421/app/job/main/app-wall/service/offer
- github.com/maxchen299/my-code/app/admin/main/apm/service
- github.com/may215/gollum/consumer
- github.com/mengbaby/go-common/app/admin/main/apm/service
- github.com/mengbaby/go-common/app/infra/databus/tcp
- github.com/mengbaby/go-common/app/infra/notify/notify
- github.com/mengbaby/go-common/app/interface/openplatform/monitor-end/service
- github.com/mengbaby/go-common/app/job/main/app-wall/service/offer
- github.com/mfamador/benthos/lib/input/reader
- github.com/mgencur/eventing/pkg/buses/kafka/dispatcher
- github.com/microsoft/presidio/pkg/stream/kafka
- github.com/miweiweigithub/begin-gobili/app/admin/main/apm/service
- github.com/miweiweigithub/begin-gobili/app/infra/databus/tcp
- github.com/miweiweigithub/begin-gobili/app/infra/notify/notify
- github.com/miweiweigithub/begin-gobili/app/interface/openplatform/monitor-end/service
- github.com/miweiweigithub/begin-gobili/app/job/main/app-wall/service/offer
- github.com/momo247/go-common/app/admin/main/apm/service
- github.com/momo247/go-common/app/infra/databus/tcp
- github.com/momo247/go-common/app/infra/notify/notify
- github.com/momo247/go-common/app/interface/openplatform/monitor-end/service
- github.com/momo247/go-common/app/job/main/app-wall/service/offer
- github.com/monojitbarua/go-avro-kafka/avro
- github.com/monzo/sarama-cluster/cmd/sarama-cluster-cli
- github.com/morganfly/bilibili/app/admin/main/apm/service
- github.com/morganfly/bilibili/app/infra/databus/tcp
- github.com/morganfly/bilibili/app/infra/notify/notify
- github.com/morganfly/bilibili/app/interface/openplatform/monitor-end/service
- github.com/morganfly/bilibili/app/job/main/app-wall/service/offer
- github.com/mormulms/agent-centric-monitoring/generic-agent/telegraf/plugins/inputs/kafka_consumer
- github.com/moul/kafka-gateway/service
- github.com/mouminoux/kafkacli
- github.com/mous77/go/mq
- github.com/mrlyc/sarama-demo/sarama
- github.com/msample/sarama-cluster/cmd/sarama-cluster-cli
- github.com/mujiansu/openbilibili-common/app/admin/main/apm/service
- github.com/mujiansu/openbilibili-common/app/infra/databus/tcp
- github.com/mujiansu/openbilibili-common/app/infra/notify/notify
- github.com/mujiansu/openbilibili-common/app/interface/openplatform/monitor-end/service
- github.com/mujiansu/openbilibili-common/app/job/main/app-wall/service/offer
- github.com/murderxchip/aliyun-dts-dispatcher/dts/consumers
- github.com/mwain/benthos/lib/input/reader
- github.com/nanfengpo/goim/internal/job
- github.com/nanpingli/qqqg/internal/job
- github.com/nds15763/feed/producer/service/kafka
- github.com/neil-liang/sarama-cluster/cmd/sarama-cluster-cli
- github.com/niteshjain/mconsumer
- github.com/niwho/utils
- github.com/nj-leegern/goprophet/mq/kafka
- github.com/nordstrom/kandi
- github.com/nwest1/benthos/lib/input/reader
- github.com/obalunenko/kafka-dump/dumper
- github.com/oemdaro/mqtt-microservices/data-service/kafka
- github.com/oleg-balunenko/kafka-dump/dumper
- github.com/ollystephens/benthos/lib/input/reader
- github.com/onsdigital/dp-dd-csv-filter
- github.com/open-horizon/examples/cloud/sdr/data-ingest/example-go-clients
- github.com/openfaas-incubator/kafka-connector
- github.com/openmock/openmock
- github.com/opensds/multi-cloud/datamover/pkg/kafka
- github.com/oyjjpp/blog/service/queue
- github.com/philipjung164/pubg-go-healthchecks
- github.com/phillweston/openbilibili/app/admin/main/apm/service
- github.com/phillweston/openbilibili/app/infra/databus/tcp
- github.com/phillweston/openbilibili/app/infra/notify/notify
- github.com/phillweston/openbilibili/app/interface/openplatform/monitor-end/service
- github.com/phillweston/openbilibili/app/job/main/app-wall/service/offer
- github.com/phper95/pkg/mq
- github.com/pilosa/pdk/kafka
- github.com/plgd-dev/cqrs/eventbus/kafka
- github.com/pluto-tv/furan/lib/kafka
- github.com/pmtabe1/sarama-cluster/cmd/sarama-cluster-cli
- github.com/pradeepp28/eh-kafka
- github.com/projectriff-archive/function-sidecar/cmd
- github.com/pvcy/presidio/pkg/stream/kafka
- github.com/q1angch0u/bilibili/go-common/app/admin/main/apm/service
- github.com/q1angch0u/bilibili/go-common/app/infra/databus/tcp
- github.com/q1angch0u/bilibili/go-common/app/infra/notify/notify
- github.com/q1angch0u/bilibili/go-common/app/interface/openplatform/monitor-end/service
- github.com/q1angch0u/bilibili/go-common/app/job/main/app-wall/service/offer
- github.com/qiangyongyang/sarama-cluster/cmd/sarama-cluster-cli
- github.com/qjpcpu/common/kafkautil
- github.com/qwqteam/bilibili-backup/app/admin/main/apm/service
- github.com/qwqteam/bilibili-backup/app/infra/databus/tcp
- github.com/qwqteam/bilibili-backup/app/infra/notify/notify
- github.com/qwqteam/bilibili-backup/app/interface/openplatform/monitor-end/service
- github.com/qwqteam/bilibili-backup/app/job/main/app-wall/service/offer
- github.com/rafalmnich/streams/kafka
- github.com/ravin-bhambhu07/test-cluster/cmd/sarama-cluster-cli
- github.com/ricardo-ch/kafka-topic-cloner/kafka
- github.com/ricardoarchive/kafka-topic-cloner/kafka
- github.com/rickb777/kafka-tool/api
- github.com/rwoj/go-trade
- github.com/s1377427321/stock_project/github.com/bsm/sarama-cluster/cmd/sarama-cluster-cli
- github.com/s290305915/sarama-cluster/cmd/sarama-cluster-cli
- github.com/saleswise/sarama-cluster/cmd/sarama-cluster-cli
- github.com/santhoshkumarbollena/golangkafka/Golang-Avro-SchemaRegistry/Consumer
- github.com/sbowman/sarama-cluster/_examples
- github.com/scaleft/sarama-cluster/cmd/sarama-cluster-cli
- github.com/shelton-hu/pi/kafka
- github.com/shootz-developer/gtool/mq
- github.com/siaoynli/pkg/mq
- github.com/sicecep/sarama-cluster/cmd/sarama-cluster-cli
- github.com/signalfx/sarama-cluster/cmd/sarama-cluster-cli
- github.com/simplexity-ckcclc/gochannel/match
- github.com/skyshang1/go.learning/kafka
- github.com/sl33nyc/venom/executors/kafka
- github.com/sld880311/influxdata/telegraf/plugins/inputs/kafka_consumer
- github.com/soukengo/gopkg/component/mq/kafka
- github.com/srcmesh/kubefaas/pkg/mqtrigger/messageQueue/kafka
- github.com/ssoor/open-bilibili/app/admin/main/apm/service
- github.com/ssoor/open-bilibili/app/infra/databus/tcp
- github.com/ssoor/open-bilibili/app/infra/notify/notify
- github.com/ssoor/open-bilibili/app/interface/openplatform/monitor-end/service
- github.com/ssoor/open-bilibili/app/job/main/app-wall/service/offer
- github.com/stationedabroad/sarama-cluster/cmd/sarama-cluster-cli
- github.com/stepsaway/msgqueue
- github.com/stockx/sarama-cluster/cmd/sarama-cluster-cli
- github.com/sudiyi/sdy/aliware/kafka
- github.com/sundy-li/go_commons/libs/mq
- github.com/sunlight2728/testgob/app/admin/main/apm/service
- github.com/sunlight2728/testgob/app/infra/databus/tcp
- github.com/sunlight2728/testgob/app/infra/notify/notify
- github.com/sunlight2728/testgob/app/interface/openplatform/monitor-end/service
- github.com/sunlight2728/testgob/app/job/main/app-wall/service/offer
- github.com/sunp13/kfktool
- github.com/suohailong/sarama-cluster/cmd/sarama-cluster-cli
- github.com/syncromatics/kafmesh/pkg/runner
- github.com/tal-tech/hera/kafkaconsumer
- github.com/tamber/sarama-cluster/cmd/sarama-cluster-cli
- github.com/tanlei007/bilibili-go-common-master/app/admin/main/apm/service
- github.com/tanlei007/bilibili-go-common-master/app/infra/databus/tcp
- github.com/tanlei007/bilibili-go-common-master/app/infra/notify/notify
- github.com/tanlei007/bilibili-go-common-master/app/interface/openplatform/monitor-end/service
- github.com/tanlei007/bilibili-go-common-master/app/job/main/app-wall/service/offer
- github.com/tanlinhua/bilibili-backup/app/admin/main/apm/service
- github.com/tanlinhua/bilibili-backup/app/infra/databus/tcp
- github.com/tanlinhua/bilibili-backup/app/infra/notify/notify
- github.com/tanlinhua/bilibili-backup/app/interface/openplatform/monitor-end/service
- github.com/tanlinhua/bilibili-backup/app/job/main/app-wall/service/offer
- github.com/thbkrkr/qli/client
- github.com/towiller/cmd-async/src/srv/services/bd_broker
- github.com/transfon/sarama-cluster/cmd/sarama-cluster-cli
- github.com/trilogy-group/aurea-insidesales-cip-go-common/kafka
- github.com/trivago/gollum/consumer
- github.com/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/admin/main/apm/service
- github.com/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/infra/databus/tcp
- github.com/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/infra/notify/notify
- github.com/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/interface/openplatform/monitor-end/service
- github.com/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/job/main/app-wall/service/offer
- github.com/twanies/sarama-cluster/_examples
- github.com/txchat/im-util/app-examples/echo/server
- github.com/uber-archive/cherami-server/services/outputhost
- github.com/uber/cherami-server/services/outputhost
- github.com/uedun/kafka-trigger/pkg/event-consumers/kafka
- github.com/vaksi/messaging/pkg/kafka
- github.com/vavrusa/sarama-cluster/cmd/sarama-cluster-cli
- github.com/ventifang/bilibili-source-code/app/admin/main/apm/service
- github.com/ventifang/bilibili-source-code/app/infra/databus/tcp
- github.com/ventifang/bilibili-source-code/app/infra/notify/notify
- github.com/ventifang/bilibili-source-code/app/interface/openplatform/monitor-end/service
- github.com/ventifang/bilibili-source-code/app/job/main/app-wall/service/offer
- github.com/veritone/go-messaging-lib/kafka
- github.com/vinayr/kafka-test
- github.com/vmware-archive/dispatch/lib/riff
- github.com/vmware/dispatch/lib/riff
- github.com/wangkechen/gotest
- github.com/wangyihit/libmt/util/kafka
- github.com/waterdogy/linkchange/src/consumer
- github.com/weichang-bianjie/kafka-sdk-go/kafka
- github.com/weitrue/Seckill/infrastructure/mq/kafka
- github.com/wenboyu00/go_pkg_depoly/mq
- github.com/windhooked/benthos/lib/input/reader
- github.com/wolf29f/venom/executors/kafka
- github.com/wonglyxng/gopractice/openbilibili-master/go-common/app/admin/main/apm/service
- github.com/wonglyxng/gopractice/openbilibili-master/go-common/app/infra/databus/tcp
- github.com/wonglyxng/gopractice/openbilibili-master/go-common/app/infra/notify/notify
- github.com/wonglyxng/gopractice/openbilibili-master/go-common/app/interface/openplatform/monitor-end/service
- github.com/wonglyxng/gopractice/openbilibili-master/go-common/app/job/main/app-wall/service/offer
- github.com/woodsaj/go-kafka-test
- github.com/wumingshi0531/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/admin/main/apm/service
- github.com/wumingshi0531/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/infra/databus/tcp
- github.com/wumingshi0531/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/infra/notify/notify
- github.com/wumingshi0531/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/interface/openplatform/monitor-end/service
- github.com/wumingshi0531/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/job/main/app-wall/service/offer
- github.com/wupeaking/sarama-cluster/cmd/sarama-cluster-cli
- github.com/wyonghui/biliwebsource/app/admin/main/apm/service
- github.com/wyonghui/biliwebsource/app/infra/databus/tcp
- github.com/wyonghui/biliwebsource/app/infra/notify/notify
- github.com/wyonghui/biliwebsource/app/interface/openplatform/monitor-end/service
- github.com/wyonghui/biliwebsource/app/job/main/app-wall/service/offer
- github.com/xbonlinenet/goup/frame/data
- github.com/xgxw/foundation-go/events
- github.com/xiang87871/bilibili/app/admin/main/apm/service
- github.com/xiang87871/bilibili/app/infra/databus/tcp
- github.com/xiang87871/bilibili/app/infra/notify/notify
- github.com/xiang87871/bilibili/app/interface/openplatform/monitor-end/service
- github.com/xiang87871/bilibili/app/job/main/app-wall/service/offer
- github.com/xiaomeng79/istio-micro/internal/kafka
- github.com/xiaoweihong/deepgo/test
- github.com/xlt-evil/the_way_to_go/kafka
- github.com/xwi88/kit4go/kafka
- github.com/xx132917/xhyl/src/conf
- github.com/xxxtai/Bilibili-Go-Backup/app/admin/main/apm/service
- github.com/xxxtai/Bilibili-Go-Backup/app/infra/databus/tcp
- github.com/xxxtai/Bilibili-Go-Backup/app/infra/notify/notify
- github.com/xxxtai/Bilibili-Go-Backup/app/interface/openplatform/monitor-end/service
- github.com/xxxtai/Bilibili-Go-Backup/app/job/main/app-wall/service/offer
- github.com/xy-gzf/gzf_server/lib/common/kafka
- github.com/yanuar-nc/migration-database-microservice/cmd/consumer
- github.com/yejingx/sarama-cluster/cmd/sarama-cluster-cli
- github.com/yixinshuwu/openbilibili-go-common-1/app/admin/main/apm/service
- github.com/yixinshuwu/openbilibili-go-common-1/app/infra/databus/tcp
- github.com/yixinshuwu/openbilibili-go-common-1/app/infra/notify/notify
- github.com/yixinshuwu/openbilibili-go-common-1/app/interface/openplatform/monitor-end/service
- github.com/yixinshuwu/openbilibili-go-common-1/app/job/main/app-wall/service/offer
- github.com/yngzij/openbilibili/app/admin/main/apm/service
- github.com/yngzij/openbilibili/app/infra/databus/tcp
- github.com/yngzij/openbilibili/app/infra/notify/notify
- github.com/yngzij/openbilibili/app/interface/openplatform/monitor-end/service
- github.com/yngzij/openbilibili/app/job/main/app-wall/service/offer
- github.com/youminxue/euler/internal/job
- github.com/ytf606/golibs/service/kafka
- github.com/yushuilong/livebarrage/comet
- github.com/z131031231/gohangout-input-kafka_sarama
- github.com/zboyco/go-test/kafka/consumer
- github.com/zhangxiaocong/crypto-exchange-engine
- github.com/zhuquanji/sarama-cluster/cmd/sarama-cluster-cli
- github.com/zhuzhuolong/excharge
- github.com/zihao-boy/zihao/common/kafka
- github.com/ziru/openmock
- github.com/zqkgo/goim-enhanced/internal/job
- github.com/zzttya/sarama-cluster/cmd/sarama-cluster-cli
- github.imxd.top/bsm/sarama-cluster/cmd/sarama-cluster-cli
- gitlab.com/mfahry/go-confluent-avro
- gitlab.lanhuapp.com/gopkgs/ikafka/sarama
- gitlab.laodianhuang.cn/oaago/component/kafka
- gopkg.in/go-gadgets/eventsourcing.v0/distribution/kafka
- gopkg.in/vmware/dispatch.v0/lib/riff
- gopkg.in/yshahin/telegraf.v1/plugins/inputs/kafka_consumer
- xgit.xiaoniangao.cn/xngo/lib/kafka-consumer/kafka