Go to main page
Known importers: 0 (displaying 11,098 packages, including internal and invalid packages)
- actshad.dev/goflow/transport
- bitbucket.org/hokego/marmota/pkg/mq
- bitbucket.org/moni-africa/golibkafka/systems/kafka
- bitbucket.org/mybudget-dev/krouter
- e.coding.net/nimrc/micro/go-plugins/broker/kafka
- e.coding.net/ricnsmart/go/service/kafka
- e.coding.net/xmissy/opensource/go-mysql-transfer/service/endpoint
- e.coding.net/yhyang/common-sdk/eventbus/dirver/kafka
- e.coding.net/yhyang/common-sdk/kafka-driver/consumer
- e.coding.net/yhyang/common-sdk/kafka-driver/handlers
- e.coding.net/yhyang/common-sdk/kafka-driver/producer
- e.coding.net/yhyang/common-sdk/kafka-driver/tests/consumer
- e.coding.net/yhyang/common-sdk/kafka-driver/tests/producer
- e.coding.net/yhyang/golib/eventbus/dirver/kafka
- e.coding.net/yhyang/golib/kafka-driver/consumer
- e.coding.net/yhyang/golib/kafka-driver/handlers
- e.coding.net/yhyang/golib/kafka-driver/producer
- e.coding.net/yhyang/golib/kafka-driver/tests/consumer
- e.coding.net/yhyang/golib/kafka-driver/tests/producer
- git.aasal.co/ehsan/utils/socket
- git.cs.kau.se/hamzchah/opencnc_kafka-exporter/logger/pkg/internal
- git.fg-tech.ru/listware/go-core/pkg/executor
- git.halomobi.net/common/halolib/kafka
- git.hawtech.cn/jager/hawox/queues/kafka
- git.iwrk.ru/epicbytes/code/backend/svc/mqtt-broker/plugins/bridge
- git.ixmxm.top/ixmxm/dkit/dkafka
- git.jxc1690.top/library/iris/_examples/tutorial/api-for-apache-kafka/src
- git.kescher.at/forestCloud/minio/pkg/event/target
- git.noahlan.cn/noahlan/ntool-biz/core/mq/kafka
- git.oschina.net/sblig/pholcus/common/kafka
- git.pinjamwinwin.com/aidc/framework/v2/kafka
- git.proto.group/protoobp/pobp-trace-go/contrib/Shopify/sarama
- git.renbj.cn/saas/golib/kafka
- git.wanpinghui.com/WPH/go_common/wph/mq/kafka
- gitea.com/ha666/sync-mysql/plugin/kafka
- gitea.xmrsdc.top/public/utilx/common/kafkahelper
- gitee.com/Cookie_XiaoD/easykafka
- gitee.com/Diegoh/go-study/go-logagent/kafka
- gitee.com/JMArch/go-plugins/broker/kafka
- gitee.com/KaiErDeLe/higo/pkg/databus/kafka
- gitee.com/alexleix/pkgs/mq
- gitee.com/chenhonghua/ginorigin/kafka
- gitee.com/common_go/producer/kafka
- gitee.com/coyte/commons/libs/mq
- gitee.com/cuijun/iris_v1111/_examples/tutorial/api-for-apache-kafka/src
- gitee.com/d_alchemia/da-go-kafka-client/kafka
- gitee.com/danlansky/go-library/repository/kafka
- gitee.com/davel-go/gozero-common/kafkax
- gitee.com/davel28/go-common/kafka
- gitee.com/edgells/go-commons/logger
- gitee.com/emmm_admin/xgameCommon/akNet
- gitee.com/fanfansong/gokafka/gokafka
- gitee.com/fuelou/broker
- gitee.com/go-vulcanus/vulcanus/data
- gitee.com/gomods/producer/kafka
- gitee.com/hnorm/kafka
- gitee.com/jerryduren/architecture/go-with-domain/demo5gc/libs/platform/dms
- gitee.com/kinwyb/appTools/common
- gitee.com/kudingc/zh_logs/library/kafka
- gitee.com/leicc/go-core
- gitee.com/lh-her-team/logger
- gitee.com/linewise/go-frame/db/kafka
- gitee.com/lisailiya/hello-world/hello-go/demo/learn-kafka
- gitee.com/lisailiya/hello-world/hello-go/pkg/kafka
- gitee.com/lisailiya/hello-world/hello-go/tool/db_sync
- gitee.com/lisailiya/hello-world/xiuxiulu/demo/learn-kafka
- gitee.com/lisailiya/hello-world/xiuxiulu/pkg/kafka
- gitee.com/lisailiya/hello-world/xiuxiulu/tool/db_sync
- gitee.com/liuxuezhan/go-plugins/broker/kafka
- gitee.com/middleware_demo/go_kafka
- gitee.com/monitor_dev/ucloud_kafka_exporter/kafka_exporter
- gitee.com/netscript/iris/_examples/tutorial/api-for-apache-kafka/src
- gitee.com/peyton1991/kuat/mq/kafka
- gitee.com/qihuanxk/my-kit/logs/kafka
- gitee.com/ruomin/util/lib/kafka
- gitee.com/sasukebo/go-micro/plugins/broker/kafka/v4
- gitee.com/so-love-will-split-right/go-library/gkldcache
- gitee.com/sonysoul/iris/_examples/tutorial/api-for-apache-kafka/src
- gitee.com/teamlint/iris/_examples/tutorial/api-for-apache-kafka/src
- gitee.com/telhello1/udpgo/kafka
- gitee.com/titan-kit/titan/backends/kafka
- gitee.com/tylergong/mycore
- gitee.com/w1229748769/iris/_examples/tutorial/api-for-apache-kafka/src
- gitee.com/yanwenqing/backend-lib/teckafka
- gitee.com/yysama/golang/frame/worker/xworker/kafka
- gitee.com/zawei/yggdrasil/pkg/lib/kafka
- gitee.com/zhangjungang/beats/filebeat/input/kafka
- gitee.com/zhangjungang/beats/libbeat/common/kafka
- gitee.com/zhangjungang/beats/libbeat/outputs/kafka
- gitee.com/zhangjungang/beats/metricbeat/module/kafka
- gitee.com/zhangjungang/beats/metricbeat/module/kafka/consumergroup
- gitee.com/zhangjungang/beats/metricbeat/module/kafka/partition
- gitee.com/zhenyangze/zlib/zlib
- gitee.com/zhuyuns/basic/kafka
- gitee.com/zr233/glog2
- gitee.com/zym950511/test/async
- github.com/0angelic0/dd-trace-go/contrib/Shopify/sarama
- github.com/0quz/gitlab-jira-cm/pkg/service
- github.com/0xa48rx394r83e9/kascade/microservice1/consumer
- github.com/0xa48rx394r83e9/kascade/microservice1/producer
- github.com/0xa48rx394r83e9/kascade/microservice2/consumer
- github.com/0xa48rx394r83e9/kascade/microservice2/producer
- github.com/0xa48rx394r83e9/kascade/microservice3/consumer
- github.com/0xa48rx394r83e9/kascade/microservice3/producer
- github.com/11SF/go-common/kafka
- github.com/18905603704/openbilibili/go-common/app/admin/main/apm/service
- github.com/18905603704/openbilibili/go-common/app/infra/canal/service/reader
- 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/18905603704/openbilibili/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/1998729/kafka-forward-elasticsearch/pkg/input
- github.com/1uvu/bilibili-go-common-master/app/admin/main/apm/service
- github.com/1uvu/bilibili-go-common-master/app/infra/canal/service/reader
- 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/1uvu/bilibili-go-common-master/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/23m/kafkaconnector
- github.com/26tanishabanik/otel-kafka-receiver/receiver/customkafkareceiver
- github.com/2phost/sarama-keycloak
- github.com/35233/barrage-kit/barrage-forwarder
- github.com/3lvia/edna-cloudevents-go
- github.com/767061485/pholcus/common/kafka
- github.com/7ing/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/99-66/compression-efficiency-in-kafka/kafka
- github.com/99-66/go-kafka-protobuf-consumer-example/kafka
- github.com/99-66/go-singletone-db-conn-example/repositories
- github.com/ALSAD-project/alsad-core/cmd/learners/drivers/kafka
- github.com/ARGOeu/argo-messaging/brokers
- github.com/AaronZheng815/golang4Beginner/kafka
- github.com/AccelByte/messagebus-go-sdk
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/bookingservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/eventservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/lib/helper/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/lib/msgqueue/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/bookingservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/eventservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/lib/helper/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/lib/msgqueue/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/bookingservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/eventservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/lib/helper/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/lib/msgqueue/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/bookingservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/eventservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/lib/helper/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/lib/msgqueue/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/bookingservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/eventservice
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/lib/helper/kafka
- github.com/AcornPublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/lib/msgqueue/kafka
- github.com/AiRISTAFlowInc/fs-contrib/activity/kafka
- github.com/AlexStocks/goext/log/kafka
- github.com/AliyunContainerService/kube-eventer/common/kafka
- github.com/AmadeusITGroup/Kubernetes-Kafka-Connect-Operator/pkg/custommetrics
- github.com/AntonJoha/onos-lib-go/pkg/logging
- github.com/ArdaXi/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/AssetMantle/modules/utilities/rest/queuing
- github.com/Augustu/go-plugins/broker/kafka
- github.com/Azure/Kore/pkg/scalers
- github.com/Azure/azure-event-hubs-for-kafka/quickstart/go-sarama-client/consumer
- github.com/Azure/azure-event-hubs-for-kafka/quickstart/go-sarama-client/producer
- github.com/Azure/azure-event-hubs-for-kafka/tutorials/oauth/go-sarama/consumer
- github.com/Azure/azure-event-hubs-for-kafka/tutorials/oauth/go-sarama/producer
- github.com/AzusaChino/ficus/pkg/kafka
- github.com/BLNeo/tool/kafka
- github.com/BaritoLog/go-boilerplate/saramatestkit
- github.com/BastilleNetworks/beats/libbeat/common/kafka
- github.com/BastilleNetworks/beats/libbeat/outputs/kafka
- github.com/BastilleNetworks/beats/metricbeat/module/kafka
- github.com/BastilleNetworks/beats/metricbeat/module/kafka/consumergroup
- github.com/BastilleNetworks/beats/metricbeat/module/kafka/partition
- github.com/Bitspark/slang/pkg/elem
- github.com/Brain-Gamer/cadvisor/storage/kafka
- github.com/C4o/Juggler/web
- github.com/CN-TU/go-flows/modules/exporters/kafka
- github.com/COTBU/notifier/service
- github.com/Chendemo12/functools/kafkac
- github.com/CiscoCloud/syslog-service
- github.com/CiscoDevNet/bigmuddy-network-telemetry-pipeline
- github.com/Cloudflare/goflow/transport
- github.com/Clymene-project/Clymene/cmd/ingester/app/consumer
- github.com/Clymene-project/Clymene/cmd/ingester/app/consumer/mocks
- github.com/Clymene-project/Clymene/pkg/kafka/auth
- github.com/Clymene-project/Clymene/pkg/kafka/consumer
- github.com/Clymene-project/Clymene/pkg/kafka/producer
- github.com/Clymene-project/Clymene/plugin/storage/kafka
- github.com/CocaineCong/gin-mall/repository/kafka
- github.com/CoderBenson/go_study/middleware/kafka
- github.com/ConnorDoyle/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/ContentSquare/Burrow
- github.com/ContextLogic/sarama/examples/http_server
- github.com/ContextLogic/sarama/examples/sasl_scram_client
- github.com/ContextLogic/sarama/mocks
- github.com/ContextLogic/sarama/tools/kafka-console-consumer
- github.com/ContextLogic/sarama/tools/kafka-console-partitionconsumer
- github.com/ContextLogic/sarama/tools/kafka-console-producer
- github.com/ContextLogic/sarama/tools/kafka-producer-performance
- github.com/ContinuumLLC/elastic-beats/filebeat/input/kafka
- github.com/ContinuumLLC/elastic-beats/libbeat/common/kafka
- github.com/ContinuumLLC/elastic-beats/libbeat/outputs/kafka
- github.com/ContinuumLLC/elastic-beats/metricbeat/module/kafka
- github.com/ContinuumLLC/elastic-beats/metricbeat/module/kafka/consumergroup
- github.com/ContinuumLLC/elastic-beats/metricbeat/module/kafka/partition
- github.com/CrowdStrike/go_kafka_client
- github.com/CrowdStrike/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/CrowdStrike/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/CrowdStrike/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/CrowdStrike/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/CrowdStrike/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/Cuebiq/go-kafka-avro
- github.com/CxZMoE/hmq/plugins/bridge
- github.com/DADDYLAB/go-plugins/broker/kafka
- github.com/DIMO-Network/vehicle-signal-decoding/internal/infrastructure/kafka
- github.com/DWHengr/aurora/pkg/misc/kafka
- github.com/DankersW/dobby/kafka
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/01_sarama_tail_demo/kafka_consumer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/01_sarama_tail_demo/kafka_consumer/consumer_group
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/01_sarama_tail_demo/kafka_producer/SyncProducer
- github.com/Danny5487401/go_package_example/18_log_collect/logAgent/kafka
- github.com/DataDog/data-streams-go/integrations/sarama
- github.com/Ddarli/gym/kafka
- github.com/DeAccountSystems/das_commonlib/mq/kafka
- github.com/DerSalvador/eventing-contrib/kafka/channel/pkg/controller/channel
- github.com/DerSalvador/eventing-contrib/kafka/channel/pkg/dispatcher
- github.com/DerSalvador/eventing-contrib/kafka/channel/pkg/reconciler/controller
- github.com/DerSalvador/eventing-contrib/kafka/channel/pkg/reconciler/controller/resources
- github.com/DerSalvador/eventing-contrib/kafka/source/pkg/adapter
- github.com/Dert091499/Utilities/messaging/kafka
- github.com/Dert12318/Utilities/messaging/kafka
- github.com/DimaGolomozy/goreplay
- github.com/Dizzrt/etstream/kafka
- github.com/DreamedOfMe/barrage-kit/barrage-forwarder
- github.com/DroiTaipei/zipkin-go-opentracing
- github.com/DukeAnn/gohangout-input-kafka_sarama
- github.com/EAHITechnology/raptor/emq
- github.com/EdgeCast/vflow/producer
- github.com/Eomaxl/EventDriven-Programming/worker
- github.com/ExpediaDotCom/haystack-idl/fakespans
- github.com/FalseColor/pusher
- github.com/FanThreeSixty/kafkactl/commands
- github.com/FiberApps/common-library/kafka
- github.com/Financial-Times/kafka/consumergroup
- github.com/Financial-Times/kafka/examples/consumergroup
- github.com/Financial-Times/kafka/tools/consoleconsumer
- github.com/Financial-Times/kafka/tools/consoleproducer
- github.com/Financial-Times/kafka/tools/stressproducer
- github.com/Financial-Times/kafka/tools/transferoffsets
- github.com/Financial-Times/kafka/tools/verifier
- github.com/Financial-Times/zipper-s3
- github.com/FourWD/middleware/kafka
- github.com/Genesis-Palace/go-scrapy/scrapy
- github.com/GitMine/pholcus/common/kafka
- github.com/Golangltd/pholcus/common/kafka
- github.com/Goldenbean/go-common
- github.com/Goserizz/mq-benchmarking/benchmark/mq
- github.com/Grade-Two/minio/pkg/event/target
- github.com/GreatSir/realclouds_go/middleware
- github.com/Guy1m0/Blockchain-I-O/cclib
- github.com/Hemiun/testcontainer
- github.com/HinekoTech/go-middleware/kafka
- github.com/HnH/choreographer/infrastructure
- github.com/IBM/CodeEngine/kafka
- github.com/Icedroid/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/IfanTsai/go-lib/client/kafka
- github.com/Imgur/go-plugins/broker/kafka
- github.com/Improwised/golang-api/pkg/watermill
- github.com/Jawshua/zipkin-go-opentracing
- github.com/JeffreyDing11223/kago
- github.com/Jie11211/tools/kafkatool
- github.com/JingchengLi/dannytools/mykafka
- github.com/JitendraKSahu/beats/v7/filebeat/input/kafka
- github.com/JitendraKSahu/beats/v7/libbeat/common/kafka
- github.com/JitendraKSahu/beats/v7/libbeat/outputs/kafka
- github.com/JitendraKSahu/beats/v7/libbeat/outputs/kafkarest
- github.com/JitendraKSahu/beats/v7/metricbeat/module/kafka
- github.com/JitendraKSahu/beats/v7/metricbeat/module/kafka/consumergroup
- github.com/JitendraKSahu/beats/v7/metricbeat/module/kafka/partition
- github.com/Johnathan-Chan/go-tools/kafka
- github.com/KA1251/CoreModule
- github.com/KEVISONG/go/pkg/kafka
- github.com/Kelfitas/proxify/pkg/logger/kafka
- github.com/Kistler-Group/eh-kafka
- github.com/KleeTaurus/volc-sdk-golang/example/dts/data-subscription-demo
- github.com/Kochanac/vobla/head/internal/kafka
- github.com/Kochava/firehose/cmd/internal/kafka
- github.com/KoddiDev/dd-trace-go/contrib/Shopify/sarama
- github.com/LOOIS-IO/relay-lib/kafka
- github.com/LaYa-op/laya-go-template/models/dao
- github.com/LabKiko/kiko-gokit/kafka
- github.com/LeakIX/l9plugins/tcp
- github.com/LinkerNetworks/linkerConnector/sender
- github.com/Loopring/relay-lib/kafka
- github.com/LuoHongLiang0921/kuaigo/pkg/core/mq/kafka
- github.com/Macheal/go-plugins/broker/kafka
- github.com/MatthewJSalerno/goflow/backends/kafka
- github.com/MickayG/kafkoi
- github.com/Microsoft/presidio/pkg/stream/kafka
- github.com/Mongey/kafka-console-consumer
- github.com/Mongey/terraform-provider-confluentcloud/ccloud
- github.com/MonteCarloClub/kchain-middleware/producer
- github.com/NYTimes/gizmo/pubsub/kafka
- github.com/NYtimes/gizmo/pubsub/kafka
- github.com/NikitaTsaralov/utils/connectors/logger
- github.com/Nordstrom/kandi
- github.com/NygmaC/streamming-video/stream-reader/internal/consumer
- github.com/ONSdigital/dp-kafka
- github.com/ONSdigital/dp-kafka/mock
- github.com/ONSdigital/dp-kafka/v2
- github.com/ONSdigital/dp-kafka/v2/mock
- github.com/ONSdigital/dp-kafka/v3
- github.com/ONSdigital/dp-kafka/v3/interfaces
- github.com/ONSdigital/dp-kafka/v3/kafkatest
- github.com/ONSdigital/dp-kafka/v3/mock
- github.com/ONSdigital/dp-kafka/v4
- github.com/ONSdigital/dp-kafka/v4/interfaces
- github.com/ONSdigital/dp-kafka/v4/kafkatest
- github.com/ONSdigital/dp-kafka/v4/mock
- github.com/ONSdigital/dp-observation-importer/initialise
- github.com/OOM-Killer/fakemetrics_ng/out
- github.com/OneMount/gonfluent
- github.com/Ovat1975/go-plugins/broker/kafka
- github.com/PAWSOME-INDONESIA/paw_kit/messaging/kafka-sarama
- github.com/PGITAb/go-plugins/broker/kafka
- github.com/PKUJohnson/solar/std/ec/kafka
- github.com/PacktPublishing/Advanced-Go-Programming-in-7-Days/Day-7/4-Message-Queues/easy-issues/application
- github.com/PacktPublishing/Advanced-Go-Programming-in-7-Days/Day-7/4-Message-Queues/easy-issues/cmd/user
- github.com/PacktPublishing/Advanced-Go-Programming-in-7-Days/Day-7/4-Message-Queues/easy-issues/web
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter04/src/bookingservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter04/src/eventservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter04/src/lib/helper/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter04/src/lib/msgqueue/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter05/src/bookingservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter05/src/eventservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter05/src/lib/helper/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter05/src/lib/msgqueue/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter06/src/bookingservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter06/src/eventservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter06/src/lib/helper/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter06/src/lib/msgqueue/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter09/src/bookingservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter09/src/eventservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter09/src/lib/helper/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter09/src/lib/msgqueue/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter10/src/bookingservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter10/src/eventservice
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter10/src/lib/helper/kafka
- github.com/PacktPublishing/Cloud-Native-programming-with-Golang/Chapter10/src/lib/msgqueue/kafka
- github.com/Palvaneh/sarama/examples/http_server
- github.com/Palvaneh/sarama/examples/sasl_scram_client
- github.com/Palvaneh/sarama/mocks
- github.com/Palvaneh/sarama/tools/kafka-console-consumer
- github.com/Palvaneh/sarama/tools/kafka-console-partitionconsumer
- github.com/Palvaneh/sarama/tools/kafka-console-producer
- github.com/Palvaneh/sarama/tools/kafka-producer-performance
- github.com/ParticleMedia/join-log-dumper/server
- github.com/Path-IM/Path-IM-Server-Demo/app/msg-push/cmd/rpc/internal/server
- github.com/Path-IM/Path-IM-Server-Demo/app/msg-transfer/cmd/history-cassandra/internal/server
- github.com/Path-IM/Path-IM-Server-Demo/app/msg-transfer/cmd/history-mongo/internal/server
- github.com/Path-IM/Path-IM-Server-Demo/app/msg-transfer/cmd/persistent/internal/server
- github.com/Path-IM/Path-IM-Server-Demo/common/xkafka
- github.com/Path-IM/Path-IM-Server/app/msg-gateway/cmd/wsrpc/internal/rpcserver
- github.com/Path-IM/Path-IM-Server/app/msg-transfer/cmd/history-cassandra/internal/server
- github.com/Path-IM/Path-IM-Server/app/msg-transfer/cmd/history-mongo/internal/server
- github.com/Path-IM/Path-IM-Server/app/msg-transfer/cmd/persistent/internal/server
- github.com/Path-IM/Path-IM-Server/common/xkafka
- github.com/Pirionfr/lookatch-agent/sinks
- github.com/Pluto-tv/furan/lib/kafka
- github.com/Pororochenzy/lego/sys/kafka
- github.com/PreritO/cAdvisor/storage/kafka
- github.com/ProtocolONE/go-plugins/broker/kafka
- github.com/Qianjiachen55/go-guide/kafka
- github.com/RTradeLtd/s3x/pkg/event/target
- github.com/Rabbit-OJ/Rabbit-OJ-Judger/mq
- github.com/RainJoe/go-plugins/broker/kafka
- github.com/RanchoCooper/go-by-demos/articles/consume-kafka-efficiently/producer
- github.com/RedHatInsights/ccx-notification-service/producer/kafka
- github.com/RedHatInsights/ccx-notification-writer
- github.com/RedHatInsights/insights-results-aggregator/broker
- github.com/RedHatInsights/insights-results-aggregator/consumer
- github.com/RedHatInsights/insights-results-aggregator/producer
- github.com/RedHatInsights/insights-results-aggregator/storage
- github.com/RedHatInsights/insights-results-aggregator/tests/helpers
- github.com/RedHatOfficial/GoCourse/lesson7/kafka
- github.com/Remember9/frame/worker/xworker/kafka
- github.com/RoySunnySean007/k6/stats/kafka
- github.com/RuiFG/streaming/streaming-connector/kafka-connector/source
- github.com/Runner-Go-Team/RunnerGo-collector-open/internal/pkg/server
- github.com/S7evinK/saramajetstream
- github.com/SafetyCulture/k6/stats/kafka
- github.com/SahilKang/terraform-provider-kafka/kafka
- github.com/Sandekala/cerpens-back/pkg/kafka
- github.com/SheepGardener/alpaca-mq
- github.com/SkyAPM/go2sky-plugins/kafkareporter
- github.com/Sonek-HoangBui/k6/stats/kafka
- github.com/SongOf/kafkapc
- github.com/Stackdriver/heapster/common/kafka
- github.com/StreamFinance-Protocol/stream-chain/protocol/indexer/msgsender
- github.com/Study-of-slag-weng/go-kafka-avro
- github.com/SubmergedTree/kafkaconnector
- github.com/T0kii/beats/v7/filebeat/input/kafka
- github.com/T0kii/beats/v7/libbeat/common/kafka
- github.com/T0kii/beats/v7/libbeat/outputs/kafka
- github.com/T0kii/beats/v7/metricbeat/module/kafka
- github.com/T0kii/beats/v7/metricbeat/module/kafka/consumergroup
- github.com/T0kii/beats/v7/metricbeat/module/kafka/partition
- github.com/TechnimalCoLtd/hmq/plugins/bridge
- github.com/TemurMannonov/medium_notification_service_with_kafka/pkg/messagebroker
- github.com/TencentBlueKing/beats/filebeat/input/kafka
- github.com/TencentBlueKing/beats/libbeat/common/kafka
- github.com/TencentBlueKing/beats/libbeat/outputs/kafka
- github.com/TencentBlueKing/beats/metricbeat/module/kafka
- github.com/TencentBlueKing/beats/metricbeat/module/kafka/consumergroup
- github.com/TencentBlueKing/beats/metricbeat/module/kafka/partition
- github.com/TencentBlueKing/bkmonitor-datalink/pkg/influxdb-proxy/backend/influxdb
- github.com/TencentBlueKing/bkmonitor-datalink/pkg/influxdb-proxy/mocktest
- github.com/TencentBlueKing/bkmonitor-datalink/pkg/ingester/processor
- github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/kafka
- github.com/TencentBlueKing/bkmonitor-datalink/pkg/transfer/testsuite
- github.com/TencentBlueking/beats/libbeat/common/kafka
- github.com/TencentBlueking/beats/libbeat/outputs/kafka
- github.com/TencentBlueking/beats/metricbeat/module/kafka
- github.com/TencentBlueking/beats/metricbeat/module/kafka/consumergroup
- github.com/TencentBlueking/beats/metricbeat/module/kafka/partition
- github.com/TetrationAnalytics/sarama/examples/http_server
- github.com/TetrationAnalytics/sarama/mocks
- github.com/TetrationAnalytics/sarama/tools/kafka-console-consumer
- github.com/TetrationAnalytics/sarama/tools/kafka-console-partitionconsumer
- github.com/TetrationAnalytics/sarama/tools/kafka-console-producer
- github.com/Theodoree/tools/mq/kafka
- github.com/ThreeDotsLabs/watermill-benchmark/pkg
- github.com/Tokumicn/lego-lib/mq
- github.com/Tooooommy/zero-kit/pubsub/kafka
- github.com/TopJohn/Hyperledger-Fabric-v1.4.1-with-gm/common/viperutil
- github.com/TopJohn/Hyperledger-Fabric-v1.4.1-with-gm/orderer/common/localconfig
- github.com/TopJohn/Hyperledger-Fabric-v1.4.1-with-gm/orderer/consensus/kafka
- github.com/TopJohn/Hyperledger-Fabric-v1.4.1-with-gm/orderer/consensus/kafka/mock
- github.com/TrHung-297/fountain/baselib/kafka_client
- github.com/TraceabilityChain/TAC/common/viperutil
- github.com/TranDuyThanh/kafka-client
- github.com/TremblingV5/DouTok/applications/favorite/service
- github.com/TremblingV5/DouTok/applications/message/service
- github.com/TremblingV5/DouTok/applications/relation/service
- github.com/TremblingV5/DouTok/pkg/kafka
- github.com/TremblingV5/DouTok/pkg/kafka/producer
- github.com/TremblingV5/DouTok/pkg/kafka/test
- github.com/Tungnt24/bounce-mail-counter/bounce_mail_counter/worker
- github.com/UESTC-KEEP/keep/cloud/pkg/common/kafka
- github.com/Verizon/vflow/producer
- github.com/VerveWireless/vmetrics/vmetrics
- github.com/Vivino/go-shezmu/examples/daemons-kafka/kafka
- github.com/WSBenson/goku/internal/kafku
- github.com/WiFeng/go-sky/kafka
- github.com/Wikia/goreplay
- github.com/WingGao/go-utils/wlog
- github.com/Winiex/heka/plugins/kafka
- github.com/XC-Zero/yinwan/pkg/client
- github.com/XingYuanHuang/go-demo/kafka
- github.com/YOJIA-yukino/simple-douyin-backend/init
- github.com/YOJIA-yukino/simple-douyin-backend/internal/dao
- github.com/YOJIA-yukino/simple-douyin-backend/internal/service
- github.com/YOJIA-yukino/simple-douyin-backend/internal/utils/kafka/kafkaClient
- github.com/YOJIA-yukino/simple-douyin-backend/internal/utils/kafka/kafkaServer
- github.com/ZQCard/charging-station-administrator/pkg/utils/kafkaHelper
- github.com/ZQCard/kratos-base-project/pkg/utils/kafkaHelper
- github.com/ZQCard/kratos_shop_template/pkg/myKafka
- github.com/Zahrapurfallah/sysu_VWR/tooling/flow
- github.com/a-inacio/hermit-shell/internal/kafka
- github.com/a-palchikov/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/a-romancev/crud_task/internal/event
- github.com/a5347354/go-simple-project/kafka
- github.com/aSquidsBody/go-common/kafka
- github.com/aaron-zeisler/kafka-the-definitive-guide/ch04-consumers
- github.com/aaronize/essai/pkg/queue
- github.com/aaronize/grandonion/examples/file_process
- github.com/aaronize/grandonion/examples/file_process/bufio_demo
- github.com/aaronize/grandonion/examples/file_process/pingmesh2
- github.com/aaronize/grandonion/examples/message_queue/kafka-demo
- github.com/aaronize/grandonion/examples/message_queue/kafka-demo/pingmesh
- github.com/aaronzheng815/golang4beginner/kafka
- github.com/abdullokh-mukhammadjonov/template_api_gateway/pkg/util
- github.com/abhinavdahiya/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/acger/chat-api/tool
- github.com/achille-roussel/veneur/sinks/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/bookingservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/eventservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/lib/helper/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter04/src/lib/msgqueue/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/bookingservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/eventservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/lib/helper/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter05/src/lib/msgqueue/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/bookingservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/eventservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/lib/helper/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter06/src/lib/msgqueue/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/bookingservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/eventservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/lib/helper/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter09/src/lib/msgqueue/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/bookingservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/eventservice
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/lib/helper/kafka
- github.com/acornpublishing/cloud-native-golang/Cloud-Native-programming-with-Golang-master/Chapter10/src/lib/msgqueue/kafka
- github.com/actank/burrow
- github.com/actiontech/dtle/driver/kafka
- github.com/activeshadow/goflow/transport
- github.com/adaickalavan/kafkapc
- github.com/adambaumeister/goflow/backends/kafka
- github.com/adamdecaf/burrow
- github.com/adamnoto/banku
- github.com/adamxiao/code_snippets
- github.com/adevinta/kafka_exporter
- github.com/adityjoshi/avinya/Backend/kafka
- github.com/adminwjp/infrastructure-go/mqs/kafkas
- github.com/admpub/spider/common/kafka
- github.com/adrian83/go-mvc-library/library/queue
- github.com/adrianco/spigo/tooling/flow
- github.com/adxhyt/kafka-consumer-lag
- github.com/aehler/uas2/lib/kafka/consumer
- github.com/aesoper101/kratos-utils/internal/log/zapx
- github.com/afsheenb/logger_example/udp2kafka
- github.com/agapoff/kafka-ops
- github.com/agave/ah-microservices/services/users/events
- github.com/agilebits/beats/filebeat/input/kafka
- github.com/agilebits/beats/libbeat/common/kafka
- github.com/agilebits/beats/libbeat/outputs/kafka
- github.com/agilebits/beats/metricbeat/module/kafka
- github.com/agilebits/beats/metricbeat/module/kafka/consumergroup
- github.com/agilebits/beats/metricbeat/module/kafka/partition
- github.com/agnivade/funnel/outputs
- github.com/ahamidi/kafka-pixy/admin
- github.com/ahamidi/kafka-pixy/config
- github.com/ahamidi/kafka-pixy/consumer/consumerimpl
- github.com/ahamidi/kafka-pixy/consumer/groupcsm
- github.com/ahamidi/kafka-pixy/consumer/msgfetcher
- github.com/ahamidi/kafka-pixy/logging
- github.com/ahamidi/kafka-pixy/mapper
- github.com/ahamidi/kafka-pixy/offsetmgr
- github.com/ahamidi/kafka-pixy/producer
- github.com/ahamidi/kafka-pixy/proxy
- github.com/ahamidi/kafka-pixy/server/grpcsrv
- github.com/ahamidi/kafka-pixy/server/httpsrv
- github.com/ahamidi/kafka-pixy/testhelpers/kafkahelper
- github.com/ai0by/zipkin-go-opentracing
- github.com/ainiaa/kafkahook
- github.com/ainsleyc/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/ainsleyc/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/ainsleyc/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/ainsleyc/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/ainsleyc/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/ainsleyc/cadvisor/storage/kafka
- github.com/aipave/go-utils/gkafka
- github.com/air-go/rpc/library/queue/kafka
- github.com/ajiany/pikachu/tools/producer
- github.com/ajruckman/vflow/producer
- github.com/akamensky/kafka_exporter
- github.com/akshayvijapur/go_sample_microservice/src/kafka
- github.com/akutta/veneur/sinks/kafka
- github.com/alan0127/yyds-project/server/kafka
- github.com/alapha23/lambdaship/relay
- github.com/albaizzz/wptest/pkg/kafka
- github.com/albertogg/cadvisor/storage/kafka
- github.com/albertrdixon/cadvisor/storage/kafka
- github.com/alejotem11/go-kafka-avro
- github.com/aleksmaus/beats/filebeat/input/kafka
- github.com/aleksmaus/beats/libbeat/common/kafka
- github.com/aleksmaus/beats/libbeat/outputs/kafka
- github.com/aleksmaus/beats/metricbeat/module/kafka
- github.com/aleksmaus/beats/metricbeat/module/kafka/consumergroup
- github.com/aleksmaus/beats/metricbeat/module/kafka/partition
- github.com/alexapps/go-plugins/broker/kafka
- github.com/alexeigr/vflow/producer
- github.com/alexhu421/tdh/TDH-Cost_Index/TDH-HardWareCrawl/colly
- github.com/alexhu421/tdh/TDH-Cost_Index/TDHDbaMoitor/src
- github.com/alexhu421/tdh/TDH-Cost_Index/TDHDbaMoitor/src/api/querymap
- github.com/alexhu421/tdh/TDH-Cost_Index/TDHDbaMoitor/src/service/crawldetailspage
- github.com/alexhu421/tdh/TDH-Cost_Index/TDHDbaMoitor/src/util
- github.com/alexhuyc/tdh/TDH-Cost_Index/TDH-HardWareCrawl/colly
- github.com/alexhuyc/tdh/TDH-Cost_Index/TDHDbaMoitor/src
- github.com/alexhuyc/tdh/TDH-Cost_Index/TDHDbaMoitor/src/api/querymap
- github.com/alexhuyc/tdh/TDH-Cost_Index/TDHDbaMoitor/src/service/crawldetailspage
- github.com/alexhuyc/tdh/TDH-Cost_Index/TDHDbaMoitor/src/util
- github.com/alexjohnkennedy/rickrollrankings/ElasticClientGo/kafkatoelastic
- github.com/alexsergivan/avroma
- github.com/alexstocks/goext/log/kafka
- github.com/aliarbak/ethereum-connector/destination
- github.com/alibaba/mongoshake/src/mongoshake/tunnel/kafka
- github.com/aliensero/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/alikhtag/go-carbon/receiver/kafka
- github.com/alirezarostami9047/goflow/transport
- github.com/aliwaremq/aliware-kafka-demos/kafka-go-demo/vpc-ssl/src/services/consumer
- github.com/aliwaremq/aliware-kafka-demos/kafka-go-demo/vpc-ssl/src/services/producer
- github.com/aliwaremq/aliware-kafka-demos/kafka-go-demo/vpc/src/services/consumer
- github.com/aliwaremq/aliware-kafka-demos/kafka-go-demo/vpc/src/services/producer
- github.com/aliyun/mongo-shake/src/mongoshake/tunnel/kafka
- github.com/allan-2stars/bstation/app/admin/main/apm/service
- github.com/allan-2stars/bstation/app/infra/canal/service/reader
- 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/allan-2stars/bstation/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/allencloud/cadvisor/storage/kafka
- github.com/alonegrowing/purple/pkg/sea/kafka
- github.com/alsad-project/alsad-core/cmd/learners/drivers/kafka
- github.com/altairsix/pkg/eventsourcex/kafka
- github.com/altchain/prototube-go
- github.com/alvarocabanas/cart/internal/messaging
- github.com/alwaysthanks/data-sync/src/lib/mq/kafka
- github.com/amato1oveing/ctool/kafka
- github.com/ambientsound/productshredder
- github.com/amcosta/cloudevent/cmd
- github.com/amrnt/go-plugins/broker/kafka
- github.com/anarkigotic/poc-async-go/ms-consumer
- github.com/andesmal/e-go-lib/pkg/queue
- github.com/andream16/go-opentracing-example/src/grpc-server/cmd
- github.com/andream16/go-opentracing-example/src/grpc-server/transport/grpc/todo
- github.com/andream16/go-opentracing-example/src/kafka-consumer/cmd
- github.com/andream16/go-opentracing-example/src/kafka-consumer/transport/kafka
- github.com/andream16/go-opentracing-example/src/shared/kafka
- github.com/andream16/go-opentracing-example/src/test/mock/kafka
- github.com/andream16/sarama-transactional-api-demo/cmd/async-abort
- github.com/andream16/sarama-transactional-api-demo/cmd/async-simple
- github.com/andream16/sarama-transactional-api-demo/cmd/consumer
- github.com/andream16/sarama-transactional-api-demo/cmd/sync-abort
- github.com/andream16/sarama-transactional-api-demo/cmd/sync-abort-multiple
- github.com/andream16/sarama-transactional-api-demo/cmd/sync-multiple
- github.com/andream16/sarama-transactional-api-demo/cmd/sync-simple
- github.com/andream16/sarama-transactional-api-demo/internal/kafka
- github.com/andreiko/veneur/sinks/kafka
- github.com/andrew-jones/go-plugins/broker/kafka
- github.com/andrewinci/rap/kafka
- github.com/andrewkandzuba/openexchange-go-data-gov/pkg/kafka
- github.com/androidjp/llib-kafka
- github.com/androidsr/paas-go/skafka
- github.com/andrsj/feedback-service/internal/infrastructure/broker/kafka
- github.com/andyxning/cadvisor/storage/kafka
- github.com/anexia-it/go-cloudlog
- github.com/angel-msil/libspark-msil/kafka
- github.com/ansoni/beats/filebeat/input/kafka
- github.com/ansoni/beats/libbeat/common/kafka
- github.com/ansoni/beats/libbeat/outputs/kafka
- github.com/ansoni/beats/metricbeat/module/kafka
- github.com/ansoni/beats/metricbeat/module/kafka/consumergroup
- github.com/ansoni/beats/metricbeat/module/kafka/partition
- github.com/antiWalker/golib/mq/kafka
- github.com/anubhavmishra/components-contrib/bindings/kafka
- github.com/aogoogle/common/tools/kafka
- github.com/apache/incubator-trafficcontrol/traffic_stats
- github.com/aperg/my-api/internal/retranslator/sender
- github.com/apoldev/trackchecker/internal/app/track/delivery/watermill-kafka
- github.com/appcelerator-archive/amp-agent/core
- github.com/appcelerator/amp-agent/core
- github.com/appuri/burrow
- github.com/ar-rostami/goflow/transport
- github.com/ar00ro/goflow/transport
- github.com/aranair/heka/plugins/kafka
- github.com/arch3754/sarama-cluster
- github.com/ardaxi/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/arekkas/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/argoeu/argo-messaging/brokers
- github.com/argoproj-labs/argo-dataflow/hack/kafka
- github.com/ariannamiao/multi-currency-wallet/hyperledger/fabric/common/viperutil
- github.com/ariefdarmawan/gleam/plugins/kafka
- 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/canal/service/reader
- 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/arlxn/bilibili-master-backup/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/armiariyan/logger
- github.com/arockpool/explorer_api
- github.com/arsonistgopher/jkafkaexporter/kafka
- github.com/arttet/reddit-feed-api/internal/broker
- github.com/arush15june/bench/requester
- github.com/aryayunanta-ralali/shorty/pkg/kafka
- github.com/as-polyakov/minio/pkg/event/target
- github.com/as-rabbit/go-connect/event_driven/events/water-mill
- github.com/asalih/beats/filebeat/input/kafka
- github.com/asalih/beats/libbeat/common/kafka
- github.com/asalih/beats/libbeat/outputs/kafka
- github.com/asalih/beats/metricbeat/module/kafka
- github.com/asalih/beats/metricbeat/module/kafka/consumergroup
- github.com/asalih/beats/metricbeat/module/kafka/partition
- github.com/asdfsx/zhihu-golang-web/queue
- github.com/ashedow/sqs-s3-kafka
- github.com/ashleighj/kafkaclient
- github.com/aslom/repdroduce-kafka-source/KafkaProducer
- github.com/asppj/delay-queue/consumer
- github.com/asve79/yarnlogs2kafka
- github.com/asyncapi/event-gateway/kafka
- github.com/asyou-me/lib.v1/log_client
- github.com/atlanssia/jackdaw/controller
- github.com/auctadev/go-kafka-avro
- github.com/augustu/go-plugins/broker/kafka
- github.com/aungmawjj/piechain/cclib
- github.com/autumnqfeng/beats-7.13.3/filebeat/input/kafka
- github.com/autumnqfeng/beats-7.13.3/libbeat/common/kafka
- github.com/autumnqfeng/beats-7.13.3/libbeat/outputs/kafka
- github.com/autumnqfeng/beats-7.13.3/metricbeat/module/kafka
- github.com/autumnqfeng/beats-7.13.3/metricbeat/module/kafka/consumergroup
- github.com/autumnqfeng/beats-7.13.3/metricbeat/module/kafka/partition
- github.com/autumnqfeng/beats/filebeat/input/kafka
- github.com/autumnqfeng/beats/libbeat/common/kafka
- github.com/autumnqfeng/beats/libbeat/outputs/kafka
- github.com/autumnqfeng/beats/metricbeat/module/kafka
- github.com/autumnqfeng/beats/metricbeat/module/kafka/consumergroup
- github.com/autumnqfeng/beats/metricbeat/module/kafka/partition
- github.com/avDec25/airbus-go/bcp
- github.com/avDec25/airbus-go/constants
- github.com/avDec25/airbus-go/consumer
- github.com/avDec25/airbus-go/consumer/cluster
- github.com/avDec25/airbus-go/consumer/executor
- github.com/avDec25/airbus-go/consumer/listener
- github.com/avDec25/airbus-go/entry
- github.com/avDec25/airbus-go/producer
- github.com/avaco2312/eventsgitn/msgqueue
- github.com/avdec25/airbus-go/bcp
- github.com/avdec25/airbus-go/constants
- github.com/avdec25/airbus-go/consumer
- github.com/avdec25/airbus-go/consumer/cluster
- github.com/avdec25/airbus-go/consumer/executor
- github.com/avdec25/airbus-go/consumer/listener
- github.com/avdec25/airbus-go/entry
- github.com/avdec25/airbus-go/producer
- github.com/axibase/cadvisor-atsd/storage/kafka
- github.com/aximchain/flash-node/app/pub
- github.com/axrayn/beats/filebeat/input/kafka
- github.com/axrayn/beats/libbeat/common/kafka
- github.com/axrayn/beats/libbeat/outputs/kafka
- github.com/axrayn/beats/metricbeat/module/kafka
- github.com/axrayn/beats/metricbeat/module/kafka/consumergroup
- github.com/axrayn/beats/metricbeat/module/kafka/partition
- github.com/aychcom/veneur/sinks/kafka
- github.com/azure/azure-event-hubs-for-kafka/quickstart/go-sarama-client/consumer
- github.com/azure/azure-event-hubs-for-kafka/quickstart/go-sarama-client/producer
- github.com/azure/azure-event-hubs-for-kafka/tutorials/oauth/go-sarama/consumer
- github.com/azure/azure-event-hubs-for-kafka/tutorials/oauth/go-sarama/producer
- github.com/b3ns44d/sarama-kafka-sasl-test
- github.com/babex-group/babex-kafka
- github.com/backlin/resources/event-sourcing-in-go/examples/marshaler
- github.com/backlin/resources/event-sourcing-in-go/examples/marshaler/cmd
- github.com/backlin/resources/event-sourcing-in-go/examples/orchestrator
- github.com/backlin/resources/event-sourcing-in-go/examples/orchestrator/cli
- github.com/backlin/resources/event-sourcing-in-go/examples/orchestrator/tracker
- github.com/backlin/resources/event-sourcing-in-go/examples/orchestrator/worker
- github.com/bakhdaulet/kit/transport/kafka
- github.com/bakins/cadvisor/storage/kafka
- github.com/bamarni/cadvisor/storage/kafka
- github.com/banqinghong/screws/golang/kafka
- github.com/bas-baskara/abango
- github.com/bastillenetworks/beats/filebeat/input/kafka
- github.com/bastillenetworks/beats/libbeat/common/kafka
- github.com/bastillenetworks/beats/libbeat/outputs/kafka
- github.com/bastillenetworks/beats/metricbeat/module/kafka
- github.com/bastillenetworks/beats/metricbeat/module/kafka/consumergroup
- github.com/bastillenetworks/beats/metricbeat/module/kafka/partition
- github.com/basvanbeek/pubsub/kafka
- github.com/basvdlei/cadvisor/storage/kafka
- github.com/batchcorp/kng
- github.com/batigo/bati-go
- github.com/battbeach/cadvisor/storage/kafka
- github.com/bboreham/cadvisor/storage/kafka
- github.com/bcbchain/thirdparty/github.com/Shopify/sarama/examples/http_server
- github.com/bcbchain/thirdparty/github.com/Shopify/sarama/mocks
- github.com/bcbchain/thirdparty/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/bcbchain/thirdparty/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/bcbchain/thirdparty/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/bcyxy/learngo/kafka
- github.com/bear2b/kafka-helpers
- github.com/beatlabs/patron/client/kafka
- github.com/beatlabs/patron/client/kafka/v2
- github.com/beatlabs/patron/component/async/kafka
- github.com/beatlabs/patron/component/async/kafka/group
- github.com/beatlabs/patron/component/async/kafka/simple
- github.com/beatlabs/patron/component/kafka
- github.com/beatlabs/patron/component/kafka/group
- github.com/beatlabs/patron/examples/http-sec
- github.com/beatlabs/patron/examples/kafka
- github.com/beatlabs/patron/test/kafka
- github.com/begenov/admin-service/pkg/kafka
- github.com/benero/beats/filebeat/input/kafka
- github.com/benero/beats/libbeat/common/kafka
- github.com/benero/beats/libbeat/outputs/kafka
- github.com/benero/beats/metricbeat/module/kafka
- github.com/benero/beats/metricbeat/module/kafka/consumergroup
- github.com/benero/beats/metricbeat/module/kafka/partition
- github.com/benjaminph1112/pholcus/common/kafka
- github.com/benschumacher/cadvisor/storage/kafka
- github.com/bentheelder/cadvisor/storage/kafka
- github.com/bestkanthed/bookmyshow_third_party
- github.com/better-go/pkg/mq/kafka
- github.com/bhambri94/kafka-proto-consumer-api/Utils
- github.com/bhanuprakash-ch/gateway
- github.com/bhanuprakash-ch/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/bhanuprakash-ch/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/bhanuprakash-ch/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/bhanuprakash-ch/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/bhanuprakash-ch/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/bhojpur/space/pkg/tile/endpoint
- github.com/bhoriuchi/opa-plugin-subscribe/subscribe/kafka
- github.com/bhs/zipkin-go-opentracing
- github.com/bigjar/coredns-kafka
- github.com/bigomby/k2http
- github.com/bigpigeon/beats/filebeat/input/kafka
- github.com/bigpigeon/beats/libbeat/common/kafka
- github.com/bigpigeon/beats/libbeat/outputs/kafka
- github.com/bigpigeon/beats/metricbeat/module/kafka
- github.com/bigpigeon/beats/metricbeat/module/kafka/consumergroup
- github.com/bigpigeon/beats/metricbeat/module/kafka/partition
- github.com/bigtong/goreplay
- github.com/bigzhuk/kafka-adapter
- github.com/bilbercode/protoc-gen-prokaf/prokaf
- github.com/bilginyuksel/notification-server/server
- github.com/bimoyong/go-plugins/broker/kafka/v2
- github.com/binarly-io/atlas/pkg/kafka
- github.com/bingohuang/cadvisor/storage/kafka
- github.com/bingoohuang/elasticproxy/pkg/source
- github.com/bingoohuang/kafka-cli/cmd/kafka-cli
- github.com/bingoohuang/kt
- github.com/bitini111/mvta/eventbus/kafka
- github.com/bitxx/pholcus/common/kafka
- github.com/bjorand/burrow
- github.com/bjorngylling/kafka-acl-viewer
- github.com/bjzhang03/go-awesome/kafka/main
- github.com/blacklightops/libbeat/outputs/kafka
- github.com/blaskovicz/heroku-kafka-demo-go
- github.com/blastbao/openbilibili-go-common-1/app/admin/main/apm/service
- github.com/blastbao/openbilibili-go-common-1/app/infra/canal/service/reader
- 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/blastbao/openbilibili-go-common-1/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/blendle/burrow
- github.com/blessmylovexy/kafka
- github.com/blink22/hmq/plugins/bridge
- github.com/blockfi/go-micro/plugins/broker/kafka/v4
- github.com/bloomberg/metrictank/cluster/partitioner
- github.com/bloomberg/metrictank/cmd/metrictank
- github.com/bloomberg/metrictank/input/kafkamdm
- github.com/bloomberg/metrictank/kafka
- github.com/bloomberg/metrictank/mdata/notifierKafka
- github.com/bloomberg/metrictank/stacktest/fakemetrics/out
- github.com/bloomberg/metrictank/stacktest/fakemetrics/out/kafkamdm
- github.com/bluebreezecf/cadvisor/storage/kafka
- github.com/bluecat-japac/dns-traffic-statistics-agent/packetbeat/protos/dns
- github.com/blueskan/cadvisor/storage/kafka
- github.com/bmeg/grip/cmd/stream
- github.com/bmoylan/beats/filebeat/input/kafka
- github.com/bmoylan/beats/libbeat/common/kafka
- github.com/bmoylan/beats/libbeat/outputs/kafka
- github.com/bmoylan/beats/metricbeat/module/kafka
- github.com/bmoylan/beats/metricbeat/module/kafka/consumergroup
- github.com/bmoylan/beats/metricbeat/module/kafka/partition
- github.com/bnb-chain/node/app/pub
- github.com/bo-hao/go_code/kafka-golang
- github.com/bobintornado/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/bogdan-d/kafkalogrus
- github.com/bom-d-van/go-carbon/receiver/kafka
- github.com/bpdlampung/banklampung-core-backend-go/queue/kafka
- github.com/bptlab/cepta/auxiliary/producers/generator/notifications
- github.com/bptlab/cepta/auxiliary/producers/replayer
- github.com/bptlab/cepta/auxiliary/producers/replayer/tests
- github.com/bptlab/cepta/osiris/lib/kafka/consumer
- github.com/bptlab/cepta/osiris/lib/kafka/producer
- github.com/bptlab/cepta/osiris/notification/tests
- github.com/brain-gamer/cadvisor/storage/kafka
- github.com/brainlabs/cadvisor/storage/kafka
- github.com/briansamuel/kafpubsub
- github.com/briansorahan/jocko/_examples/sarama
- github.com/brierlog/sniffer-agent-better/exporter
- github.com/brightoneqq/go-tools/kafka
- github.com/brinkpku/training_center/kafka
- github.com/broswen/pg-publisher/internal/producer
- github.com/bsdavidson/trimetric/logic
- github.com/bsingr/cadvisor/storage/kafka
- github.com/bsm/bps/kafka
- github.com/bsm/rumour/internal/rumour
- github.com/btrace-baader/kafka-topic-operator/topic
- github.com/btwiuse/cadvisor/storage/kafka
- github.com/buchanae/funnel/events
- github.com/buddhamagnet/gizmo/pubsub
- github.com/budiariyanto/mbludak/producer
- github.com/buger/goreplay
- github.com/bugscatcher/test-utils
- github.com/build-security/beats/filebeat/input/kafka
- github.com/build-security/beats/libbeat/common/kafka
- github.com/build-security/beats/libbeat/outputs/kafka
- github.com/build-security/beats/metricbeat/module/kafka
- github.com/build-security/beats/metricbeat/module/kafka/consumergroup
- github.com/build-security/beats/metricbeat/module/kafka/partition
- github.com/burubur/grabtechtalks-go-concurrency
- github.com/buzhiyun/go-mysql-replication/service/endpoint
- github.com/bwnetflow/dashboard
- github.com/bwnetflow/flowdumper
- github.com/bwnetflow/protobuf_to_csv_converter
- github.com/bxsmart/bxcore/kafka
- github.com/byannnn/kafka-rtsp/goproducer
- github.com/byeol-i/battery-level-checker/cmd/cache
- github.com/byeol-i/battery-level-checker/cmd/consumer
- github.com/byeol-i/battery-level-checker/pkg/config
- github.com/byeol-i/battery-level-checker/pkg/consumer
- github.com/byeol-i/battery-level-checker/pkg/producer
- github.com/byeol-i/battery-level-checker/pkg/topic
- github.com/bygui86/go-kafka/consumer
- github.com/bygui86/go-kafka/other-samples/erenga/conzumer/src
- github.com/bygui86/go-kafka/other-samples/erenga/produzer/src
- github.com/bygui86/go-kafka/other-samples/sarama/consumer
- github.com/bygui86/go-kafka/other-samples/sarama/producer_TODO
- github.com/bygui86/go-kafka/other-samples/sarama/producer_TODO/origin
- github.com/bygui86/go-kafka/producer/string
- github.com/bygui86/go-kafka/producer/user
- github.com/bykoala/go-code/app/admin/main/apm/service
- github.com/bykoala/go-code/app/infra/canal/service/reader
- github.com/bykoala/go-code/app/infra/databus/tcp
- github.com/bykoala/go-code/app/infra/notify/notify
- github.com/bykoala/go-code/app/interface/openplatform/monitor-end/service
- github.com/bykoala/go-code/app/job/main/app-wall/service/offer
- github.com/bykoala/go-code/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/bzed/carbon-relay-ng/route
- github.com/c4o/juggler/web
- github.com/cafra/utils/mq/kafka
- github.com/calebikhuohon/kafka-play
- github.com/cameronbraid/go-kafka-avro
- github.com/camlabs/gomq-kafka
- github.com/caoxu9/linux/Kafka
- github.com/carter-zhao/rambles/golang/zk
- github.com/casfia/vflow/producer
- github.com/cdbarbosa/clone/pkg/event/target
- github.com/cdsailing/pkg/kafka
- github.com/ch629/go-irc-kafka/kafka
- github.com/chalfel/kafka_cassandra_golang_template/pkg/kafka
- github.com/chandu5566/fsmetricbeat1/filebeat/input/kafka
- github.com/chandu5566/fsmetricbeat1/libbeat/common/kafka
- github.com/chandu5566/fsmetricbeat1/libbeat/outputs/kafka
- github.com/chandu5566/fsmetricbeat1/metricbeat/module/kafka
- github.com/chandu5566/fsmetricbeat1/metricbeat/module/kafka/consumergroup
- github.com/chandu5566/fsmetricbeat1/metricbeat/module/kafka/partition
- github.com/changwh/go-common/app/admin/main/apm/service
- github.com/changwh/go-common/app/infra/canal/service/reader
- 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/changwh/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/channelmeter/kafka/consumergroup
- github.com/channelmeter/kafka/examples/consumergroup
- github.com/channelmeter/kafka/tools/consoleconsumer
- github.com/channelmeter/kafka/tools/consoleproducer
- github.com/channelmeter/kafka/tools/stressproducer
- github.com/channelmeter/kafka/tools/transferoffsets
- github.com/channelmeter/kafka/tools/verifier
- github.com/chaolihf/udpgo/kafka
- github.com/charlie/substrate/kafka
- github.com/charsyam/heka/plugins/kafka
- github.com/checkking/notes/codes/kafka
- github.com/checkr/openmock
- github.com/chen56/go-common/configs/kafkax
- github.com/chenbaihu/go_coding/src/go_kafka/src/consume_group
- github.com/chenbaihu/go_coding/src/go_kafka/src/consume_low_level
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/Shopify/sarama/examples/http_server
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/Shopify/sarama/mocks
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/wvanbergen/kafka/consumergroup
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/wvanbergen/kafka/examples/consumergroup
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/wvanbergen/kafka/tools/consoleconsumer
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/wvanbergen/kafka/tools/consoleproducer
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/wvanbergen/kafka/tools/stressproducer
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/wvanbergen/kafka/tools/transferoffsets
- github.com/chenbaihu/go_coding/src/go_kafka/src/github.com/wvanbergen/kafka/tools/verifier
- github.com/chenbaihu/go_coding/src/go_kafka/src/produce
- github.com/chenchun/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/chenchun/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/chenchun/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/chenchun/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/chenchun/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/chenchun/cadvisor/storage/kafka
- github.com/chengjing1181122598/go-plugins/broker/kafka
- github.com/chengjinwu/learning/kafka
- 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/canal/service/reader
- 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/chenjinya/dilidili-go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/chentao/heka/plugins/kafka
- github.com/chentao/logkit/reader
- github.com/chenxinqun/ginWarpPkg/datax/kafkax
- github.com/chenyoufu/yfstream/pull
- github.com/chiennguyen196/go-library/internal/lending/ports
- github.com/chobostar/pg_listener/internal/cmd
- github.com/chris-nthu/fabric-based-traceability-system/fabric/common/viperutil
- github.com/chris-nthu/fabric-based-traceability-system/fabric/orderer/common/localconfig
- github.com/chris-nthu/fabric-based-traceability-system/fabric/orderer/consensus/kafka
- github.com/chris-nthu/fabric-based-traceability-system/fabric/orderer/consensus/kafka/mock
- github.com/chrisho/mosquito/alikafka
- github.com/chrislusf/gleamold/plugins/kafka
- github.com/christiancadieux/sarama/examples/http_server
- github.com/christiancadieux/sarama/examples/sasl_scram_client
- github.com/christiancadieux/sarama/mocks
- github.com/christiancadieux/sarama/tools/kafka-console-consumer
- github.com/christiancadieux/sarama/tools/kafka-console-partitionconsumer
- github.com/christiancadieux/sarama/tools/kafka-console-producer
- github.com/christiancadieux/sarama/tools/kafka-producer-performance
- github.com/christianherweg0807/beats/filebeat/input/kafka
- github.com/christianherweg0807/beats/libbeat/common/kafka
- github.com/christianherweg0807/beats/libbeat/outputs/kafka
- github.com/christianherweg0807/beats/metricbeat/module/kafka
- github.com/christianherweg0807/beats/metricbeat/module/kafka/consumergroup
- github.com/christianherweg0807/beats/metricbeat/module/kafka/partition
- github.com/christiankniep/burrow
- github.com/chtisgit/go-flows/modules/exporters/kafka
- github.com/chuhengyu/goreplay
- github.com/chusyclub/go-1/metrics
- github.com/chuxin123/go-mysql-transfer/service/endpoint
- github.com/chyeyun/beats/filebeat/input/kafka
- github.com/chyeyun/beats/libbeat/common/kafka
- github.com/chyeyun/beats/libbeat/outputs/kafka
- github.com/chyeyun/beats/metricbeat/module/kafka
- github.com/chyeyun/beats/metricbeat/module/kafka/consumergroup
- github.com/chyeyun/beats/metricbeat/module/kafka/partition
- github.com/chzyer-dev/heka/plugins/kafka
- github.com/chzyer/heka/plugins/kafka
- github.com/ciblele/siemens-energy/Rascunhos
- github.com/circlesgit/resources/heapster-master/common/kafka
- github.com/cisco/bigmuddy-network-telemetry-pipeline
- github.com/ciscocloud/syslog-service
- github.com/ciscodevnet/bigmuddy-network-telemetry-pipeline
- github.com/ciscosrapps/topology/kafka
- github.com/cision-prcomms/oip-influencer-commons/config
- github.com/citysir/heka/plugins/kafka
- github.com/civet148/gotools/mq/kafka
- github.com/ckbball/smurfin-email
- github.com/clackiverse/redmon-shared/redmonobservers
- github.com/clanstyles/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/claudiuszhang/sarama-cluster
- github.com/clearbit/kafka_exporter
- github.com/clement-casse/spigo/tooling/flow
- github.com/click-stream/feeder/output
- github.com/cloudevents/sdk-go/pkg/bindings/kafka_sarama
- github.com/cloudevents/sdk-go/v2/protocol/kafka_sarama
- github.com/cloudevents/sdk-go/v2/samples/kafka/receiver
- github.com/cloudevents/sdk-go/v2/samples/kafka/sender
- github.com/cloudevents/sdk-go/v2/samples/kafka/sender-receiver
- github.com/cloudevents/sdk-go/v2/samples/message-handle-non-cloudevents
- github.com/cloudflare/bbmp2kafka
- github.com/cloudfoundry-community/ws-collector/backend
- github.com/cloudtides/CloudTides/tides-broker
- github.com/cmceniry/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/cnpst/zmon-common-go/pubsub
- github.com/cntechpower/utils/kafka
- github.com/cod1ng-earth/event-web-store/backend/cmd/api
- github.com/cod1ng-earth/event-web-store/backend/cmd/import-products
- github.com/cod1ng-earth/event-web-store/backend/cmd/import-stock
- github.com/cod1ng-earth/event-web-store/backend/pkg/catalog
- github.com/cod1ng-earth/event-web-store/backend/pkg/checkout
- github.com/cod1ng-earth/event-web-store/backend/pkg/simba
- github.com/codebeautiful/hmq/plugins/bridge
- github.com/codebien/k6/stats/kafka
- github.com/codeding/go-example/kafka
- github.com/codeout/bigmuddy-network-telemetry-pipeline
- github.com/codeslala/gotil/zlog
- github.com/codragonzuo/beats/filebeat/input/kafka
- github.com/codragonzuo/beats/libbeat/common/kafka
- github.com/codragonzuo/beats/libbeat/outputs/kafka
- github.com/codragonzuo/beats/metricbeat/module/kafka
- github.com/codragonzuo/beats/metricbeat/module/kafka/consumergroup
- github.com/codragonzuo/beats/metricbeat/module/kafka/partition
- github.com/coffeehc/gizmo/pubsub
- github.com/colincgn/emsk/pkg
- github.com/collinmsn/heka/plugins/kafka
- github.com/colstuwjx/beats/filebeat/input/kafka
- github.com/colstuwjx/beats/libbeat/common/kafka
- github.com/colstuwjx/beats/libbeat/outputs/kafka
- github.com/colstuwjx/beats/metricbeat/module/kafka
- github.com/colstuwjx/beats/metricbeat/module/kafka/consumergroup
- github.com/colstuwjx/beats/metricbeat/module/kafka/partition
- github.com/commitHub/commitBlockchain/kafka
- github.com/companieshouse/chs-delta-api/services
- github.com/companieshouse/company-search-consumer
- github.com/companieshouse/kafka-management-tool
- github.com/competewith/go-common/clients/kafka
- github.com/concorder911220/burrowx-kafka/monitor
- github.com/confluentinc/cli/internal/cmd/kafka
- github.com/connordoyle/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/containers-ai/alameda/internal/pkg/message-queue/kafka/client
- github.com/contentsquare/burrow
- github.com/continuumllc/elastic-beats/filebeat/input/kafka
- github.com/continuumllc/elastic-beats/libbeat/common/kafka
- github.com/continuumllc/elastic-beats/libbeat/outputs/kafka
- github.com/continuumllc/elastic-beats/metricbeat/module/kafka
- github.com/continuumllc/elastic-beats/metricbeat/module/kafka/consumergroup
- github.com/continuumllc/elastic-beats/metricbeat/module/kafka/partition
- github.com/convee/golab/kafka
- github.com/cookingkode/book/reservation
- github.com/copybird/copybird/modules/global/notifier/kafka
- github.com/cornelk/go-cloud/pubsub/kafkapubsub
- github.com/coryb/zipkin-go/reporter/kafka
- github.com/cosminrentea/franz/models
- github.com/cougarwww/beats/filebeat/input/kafka
- github.com/cougarwww/beats/libbeat/common/kafka
- github.com/cougarwww/beats/libbeat/outputs/kafka
- github.com/cougarwww/beats/metricbeat/module/kafka
- github.com/cougarwww/beats/metricbeat/module/kafka/consumergroup
- github.com/cougarwww/beats/metricbeat/module/kafka/partition
- github.com/covine/bifrost/plugins/bridge
- github.com/covrom/kafkaframe
- github.com/cpg1111/cadvisor/storage/kafka
- github.com/cra/npl-dataeng-demo/70_kafka
- github.com/crask/kafka-offset-mon/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/examples/http_server
- github.com/crask/kafka-offset-mon/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/mocks
- github.com/crask/kafka-offset-mon/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-consumer
- github.com/crask/kafka-offset-mon/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-partitionconsumer
- github.com/crask/kafka-offset-mon/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-producer
- github.com/crask/kafka-pusher
- github.com/crask/kafka-pusher/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/crask/kafka-pusher/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/crask/kafka-pusher/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/crask/kafka-pusher/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/crask/kafka-pusher/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/crask/kafka-pusher/tools/message_to_curl
- github.com/creker/goflow/transport
- github.com/cristicretan/golearn/kafka_TradingSystem
- github.com/crowdstrike/burrow
- github.com/crud3306/go/02-Advance/05-MQ/01-Kafka/src
- github.com/crxfoz/teaserad/adclick/cmd/adclick
- github.com/crxfoz/teaserad/adclick/internal/delivery/kafka
- github.com/crxfoz/teaserad/adclick/internal/repo/kafka
- github.com/crxfoz/teaserad/adeliver/cmd/adeliver
- github.com/crxfoz/teaserad/adeliver/internal/delivery/kafka
- github.com/crxfoz/teaserad/adeliver/internal/repo/kafka
- github.com/crxfoz/teaserad/adeliver/pkg/gateways/adshow
- github.com/crxfoz/teaserad/adeliver/pkg/kafka
- github.com/crxfoz/teaserad/adshow/cmd/adshow
- github.com/crxfoz/teaserad/adshow/internal/delivery/kafka
- github.com/crxfoz/teaserad/adshow/internal/repo/kafka
- github.com/crxfoz/teaserad/crmad/cmd/crmad
- github.com/crxfoz/teaserad/crmad/internal/delivery/kafka
- github.com/crxfoz/teaserad/crmad/pkg/gateways/adeliver
- github.com/crxfoz/teaserad/crmad/pkg/gateways/crmadm
- github.com/crxfoz/teaserad/crmadm/cmd/crmadm
- github.com/crxfoz/teaserad/crmadm/internal/delivery/kafka
- github.com/crxfoz/teaserad/crmadm/pkg/gateways/crmad
- github.com/cryptounicorns/queues/queue/kafka
- github.com/csmarchbanks/cadvisor/storage/kafka
- github.com/cstcen/gore/db/kafka
- github.com/cuizhimou/log_transfer
- github.com/curihub/cbaasdesk/src/app/backend/core/tools/fabric/common/viperutil
- github.com/cvtjnii/burrow
- github.com/cxlcxl/hw-ads/library/queue
- github.com/cy83rc0llect0r/kafka-consumer-for-splunk/go
- github.com/cybertec-postgresql/debezium2postgres/internal/kafka
- github.com/cygy/ginamite/common/kafka
- github.com/cyril1929/zipkin-go-opentracing
- github.com/cyrusbiotechnology/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/cyub/hyper/pkg/queue/kafka
- github.com/d1egoaz/sarama-consumer-group-test
- github.com/d2jvkpn/go-web/pkg/kafka
- github.com/d3luxee/mirrormaker
- github.com/dabory/abango
- github.com/daddylab/go-plugins/broker/kafka
- github.com/daffaalex22/blacksmith
- github.com/dairongpeng/gbase
- github.com/daizi120/gorr
- github.com/dangkaka/go-kafka-avro
- github.com/danh996/go-shop-kit/kafka_utils
- github.com/danielkrainas/cadvisor/storage/kafka
- github.com/danielqsj/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/daniil-kzn/graphql-go-tools/examples/kafka_pubsub
- github.com/danlitman/go-kafka-avro
- github.com/daocloud/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/daocloud/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/daocloud/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/daocloud/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/daocloud/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/daocloud/cadvisor/storage/kafka
- github.com/daominah/gomicrokit/kafka
- github.com/darccio/dd-trace-go/v2/contrib/Shopify/sarama
- github.com/dashuaiduan/go/code/kafka
- github.com/dataStation-go/go/metrics
- github.com/datager/codes/gocodes/dg/utils/clients
- github.com/datasift/kafka-cg/consumergroup
- github.com/datasift/kafka-cg/examples/consumergroup
- github.com/datasift/kafka-cg/tools/consoleconsumer
- github.com/datasift/kafka-cg/tools/consoleproducer
- github.com/datasift/kafka-cg/tools/stressproducer
- github.com/datasift/kafka-cg/tools/transferoffsets
- github.com/datasift/kafka-cg/tools/verifier
- github.com/datastation-go/go/metrics
- github.com/datawisesystems/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/datawisesystems/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/datawisesystems/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/datawisesystems/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/datawisesystems/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/datawisesystems/cadvisor/storage/kafka
- github.com/datewu/playaround/kafkaBenchmak
- github.com/daveadams/nomad-firehose/sink
- github.com/davewalk/adventures-in-go/graceful-shutdown
- github.com/davidamitchell/go_green_screens/src/main
- github.com/davidandradeduarte/sarama/examples/http_server
- github.com/davidandradeduarte/sarama/examples/sasl_scram_client
- github.com/davidandradeduarte/sarama/mocks
- github.com/davidandradeduarte/sarama/tools/kafka-console-consumer
- github.com/davidandradeduarte/sarama/tools/kafka-console-partitionconsumer
- github.com/davidandradeduarte/sarama/tools/kafka-console-producer
- github.com/davidandradeduarte/sarama/tools/kafka-producer-performance
- github.com/davidsbond/kollect/pkg/event
- github.com/davudsafarli/twitter/auth/event_streamer/kafka_sarama
- github.com/dbenders/dtap
- github.com/dbr65/go-kafka-avro
- github.com/ddkddown/go_learn/codes/kafka
- github.com/ddnWizzie/transport
- github.com/deadmanssnitch/sarama-heroku
- github.com/dearcode/libbeat/outputs/kafka
- github.com/debashismondal/beats_latest/libbeat/common/kafka
- github.com/debashismondal/beats_latest/libbeat/outputs/kafka
- github.com/debashismondal/beats_latest/metricbeat/module/kafka
- github.com/debashismondal/beats_latest/metricbeat/module/kafka/consumergroup
- github.com/debashismondal/beats_latest/metricbeat/module/kafka/partition
- github.com/dedihartono801/go-clean-architecture-v2/internal/app/queue/kafka
- github.com/deepflowio/df-evaluation/eval-bench/client/kafka
- github.com/degendra/kafka/consumergroup
- github.com/degendra/kafka/examples/consumergroup
- github.com/degendra/kafka/tools/consoleconsumer
- github.com/degendra/kafka/tools/consoleproducer
- github.com/degendra/kafka/tools/stressproducer
- github.com/degendra/kafka/tools/transferoffsets
- github.com/degendra/kafka/tools/verifier
- github.com/dejan/tailtopic
- github.com/delanri/commonutil/messaging/kafka-sarama
- github.com/deliangyang/learn-go/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter04/src/bookingservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter04/src/eventservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter04/src/lib/helper/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter04/src/lib/msgqueue/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter05/src/bookingservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter05/src/eventservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter05/src/lib/helper/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter05/src/lib/msgqueue/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter06/src/bookingservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter06/src/eventservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter06/src/lib/helper/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter06/src/lib/msgqueue/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter09/src/bookingservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter09/src/eventservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter09/src/lib/helper/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter09/src/lib/msgqueue/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter10/src/bookingservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter10/src/eventservice
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter10/src/lib/helper/kafka
- github.com/delightwook/Cloud-Native-programming-with-Golang/Chapter10/src/lib/msgqueue/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter04/src/bookingservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter04/src/eventservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter04/src/lib/helper/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter04/src/lib/msgqueue/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter05/src/bookingservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter05/src/eventservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter05/src/lib/helper/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter05/src/lib/msgqueue/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter06/src/bookingservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter06/src/eventservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter06/src/lib/helper/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter06/src/lib/msgqueue/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter09/src/bookingservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter09/src/eventservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter09/src/lib/helper/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter09/src/lib/msgqueue/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter10/src/bookingservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter10/src/eventservice
- github.com/delightwook/cloud-native-programming-with-golang/Chapter10/src/lib/helper/kafka
- github.com/delightwook/cloud-native-programming-with-golang/Chapter10/src/lib/msgqueue/kafka
- github.com/dematesistemas/microservices_go_kafka
- github.com/demon-xxi/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/demon-xxi/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/demon-xxi/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/demon-xxi/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/demon-xxi/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/demon-xxi/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/demon-xxi/telegraf/outputs/kafka
- github.com/demon-xxi/telegraf/plugins/kafka_consumer
- github.com/denislobanov/go-pubsub/kafka
- github.com/denlipov/com-request-api/internal/app/sender
- github.com/depocket/support/queue/kafka
- github.com/derekelkins/logspout
- github.com/dersalvador/eventing-contrib/kafka/channel/pkg/controller/channel
- github.com/dersalvador/eventing-contrib/kafka/channel/pkg/dispatcher
- github.com/dersalvador/eventing-contrib/kafka/channel/pkg/reconciler/controller
- github.com/dersalvador/eventing-contrib/kafka/channel/pkg/reconciler/controller/resources
- github.com/dersalvador/eventing-contrib/kafka/source/pkg/adapter
- github.com/destinyyu/kafka-topic-exporter
- github.com/devhg/kafka-go-example/cmd/consumer
- github.com/devhg/kafka-go-example/cmd/producer
- github.com/devhg/kafka-go-example/consumer/group
- github.com/devhg/kafka-go-example/consumer/standalone
- github.com/devhg/kafka-go-example/helloworld/consumer
- github.com/devhg/kafka-go-example/helloworld/producer
- github.com/devhg/kafka-go-example/offsetmanager
- github.com/devhg/kafka-go-example/producer/async
- github.com/devhg/kafka-go-example/producer/sync
- github.com/deviceinsight/kafkactl/internal
- github.com/deviceinsight/kafkactl/internal/acl
- github.com/deviceinsight/kafkactl/internal/broker
- github.com/deviceinsight/kafkactl/internal/consumer
- github.com/deviceinsight/kafkactl/internal/consumergroupoffsets
- github.com/deviceinsight/kafkactl/internal/consumergroups
- github.com/deviceinsight/kafkactl/internal/partition
- github.com/deviceinsight/kafkactl/internal/producer
- github.com/deviceinsight/kafkactl/internal/topic
- github.com/deviceinsight/kafkactl/output
- github.com/deviceinsight/kafkactl/testutil
- github.com/devit-tel/melonade-client-go
- github.com/devit-tel/melonade-discord-noti
- github.com/devoxel/otelsarama
- github.com/devplayg/kafka
- github.com/devplayg/kafka/consumer-group
- github.com/devplayg/kafka/kafka-console-consumer
- github.com/devplayg/kafka/old/comsumer
- github.com/devplayg/kafka/old/consumer_group
- github.com/devplayg/kafka/old/producer
- github.com/devplayg/kafka/produce_rand_consume_rand
- github.com/devplayg/kafka/producer
- github.com/devx/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/devx/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/devx/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/devx/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/devx/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/devx/cadvisor/storage/kafka
- github.com/dfarr/kafkanaut/eventbus/kafka
- github.com/dhnikolas/kafkahelper
- github.com/diabeticmike/kafkaservice/api
- github.com/dialogbox/gofka/kafka
- github.com/diamondnetwork2000/diamond-sdk/msgqueue
- github.com/diaohaha/termite/dal/mq
- github.com/didip/gizmo/pubsub/kafka
- github.com/dilllay/sarama-cluster
- github.com/dimadeush/docker-k6-influxdb-grafana/stats/kafka
- github.com/dimagolomozy/goreplay
- github.com/dims/cadvisor/storage/kafka
- github.com/dingzhenying/bilibili-opencode/app/admin/main/apm/service
- github.com/dingzhenying/bilibili-opencode/app/infra/canal/service/reader
- 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/dingzhenying/bilibili-opencode/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/dinoba/gocker/storage
- github.com/dirkarnez/kafka-playground
- github.com/discretemind/glink/plugin/kafka
- github.com/dishesdog/b-go-common/app/admin/main/apm/service
- github.com/dishesdog/b-go-common/app/infra/canal/service/reader
- 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/dishesdog/b-go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/dishine/libary/mq/kafka
- github.com/disq/kt
- github.com/distribworks/dkron/v3/builtin/bins/dkron-executor-kafka
- github.com/dmichael/gizmo/pubsub/kafka
- github.com/dmitryilyin/kafkabeat/beater
- github.com/doc22940/gleam.go/plugins/kafka
- github.com/dodirepository/common-lib/kafka
- github.com/domac/go-trial/kafka
- github.com/domehuhu/logspout-kafka
- github.com/donghwicha/cadvisor/storage/kafka
- github.com/donkeywon/s-proxy/services/kafka
- github.com/dot-run-code/emsgrpc/services
- github.com/doudou215/LogCollection/logAgent/kafka
- github.com/dougwilloughby/sarama-kafka-offset-test
- github.com/dpCnx/go-study/demo/kafka
- github.com/dqzboy/goproject/logAgent/kafka
- github.com/dreamedofme/barrage-kit/barrage-forwarder
- github.com/dubin555/kafkascale/worker
- github.com/ducksoso/kitex/queue/kfk
- github.com/ducminhnguyen/gleam/plugins/kafka
- github.com/ducquyen2509/common-go/kafka
- github.com/dueruen/learning-kubernetes/application/performance-demo
- github.com/duglin/knkafka
- github.com/duguyifang/go-plugins/broker/kafka
- github.com/dukeann/gohangout-input-kafka_sarama
- github.com/duolabmeng6/go-rabbitmq-easy/LLRPC/kafka
- github.com/dup2X/gopkg/dkafka
- github.com/duyledat197/go-gen-tools/pkg/kafka
- github.com/duysmile/kafka-go-simple/saramalib/pubsub/kafka
- github.com/dydxprotocol/v4-chain/protocol/indexer/msgsender
- github.com/dyihs/logagent/kafka
- github.com/dylanmei/kafka-snitch
- github.com/dylanpeng/golib/kafka
- github.com/eager7/go_study/2019/kafka
- github.com/easyops-cn/beats/filebeat/input/kafka
- github.com/easyops-cn/beats/libbeat/common/kafka
- github.com/easyops-cn/beats/libbeat/outputs/kafka
- github.com/easyops-cn/beats/metricbeat/module/kafka
- github.com/easyops-cn/beats/metricbeat/module/kafka/consumergroup
- github.com/easyops-cn/beats/metricbeat/module/kafka/partition
- github.com/easyriderk0c9g/linarkou/kafka/kafka-operator-krallistic/kafka
- github.com/easywalk/go-simply-cqrs
- github.com/eavgerinos/goreplay
- github.com/ecasilla/brokergen/pkg/broker/kafka
- github.com/echojc/kt
- github.com/edarha/kafka-golang/cmd/consumer-all
- github.com/edarha/kafka-golang/cmd/consumer-create
- github.com/edarha/kafka-golang/cmd/consumer-register-class
- github.com/edarha/kafka-golang/cmd/consumer-update
- github.com/edarha/kafka-golang/cmd/server
- github.com/edarha/kafka-golang/internals/services
- github.com/edarha/kafka-golang/internals/services/consumers
- github.com/edfungus/conduction/messenger
- github.com/edgexr/edge-cloud-platform/pkg/cloudcommon/node
- github.com/edgulczynski/gizmo/pubsub/kafka
- github.com/edswarchitect/go-k8s-kafka-external
- github.com/eferro/spikes/gokafka/kafkaexample
- github.com/egustafson/sandbox/go/kafka-sarama
- github.com/ehsbaiu/backup-of-openbilibili-go-common/app/admin/main/apm/service
- github.com/ehsbaiu/backup-of-openbilibili-go-common/app/infra/canal/service/reader
- 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/ehsbaiu/backup-of-openbilibili-go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/ekarak/kafka_exporter
- github.com/ekini/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/ekini/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/ekini/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/ekini/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/ekini/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/ekini/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/ekini/telegraf/outputs/kafka
- github.com/ekini/telegraf/plugins/kafka_consumer
- github.com/ekto-dev/ekto/example
- github.com/elastic/beats/filebeat/input/kafka
- github.com/elastic/beats/libbeat/common/kafka
- github.com/elastic/beats/libbeat/outputs/kafka
- github.com/elastic/beats/metricbeat/module/kafka
- github.com/elastic/beats/metricbeat/module/kafka/consumergroup
- github.com/elastic/beats/metricbeat/module/kafka/partition
- github.com/elastic/beats/v7/filebeat/input/kafka
- github.com/elastic/beats/v7/libbeat/common/kafka
- github.com/elastic/beats/v7/libbeat/outputs/kafka
- github.com/elastic/beats/v7/metricbeat/module/kafka
- github.com/elastic/beats/v7/metricbeat/module/kafka/consumergroup
- github.com/elastic/beats/v7/metricbeat/module/kafka/partition
- github.com/elastic/stream/internal/output/kafka
- github.com/eldarion-gondor/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/eliben/gocdkx/pubsub/kafkapubsub
- github.com/elireisman/sarama-easy/kafka
- github.com/elitecodegroovy/tos/pkg/event/target
- github.com/ellavs/tg-bot-golang/internal/helpers/kafka
- github.com/elliottpolk/jaeger/cmd/ingester/app/consumer
- github.com/elliottpolk/jaeger/cmd/ingester/app/consumer/mocks
- github.com/elliottpolk/jaeger/pkg/kafka/auth
- github.com/elliottpolk/jaeger/pkg/kafka/consumer
- github.com/elliottpolk/jaeger/pkg/kafka/producer
- github.com/elliottpolk/jaeger/plugin/storage/kafka
- github.com/elodina/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client
- github.com/elodina/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client/producers
- github.com/elodina/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client/producers/tailf
- github.com/elodina/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client/syslog
- github.com/elodina/go-kafka/Godeps/_workspace/src/github.com/stealthly/siesta/consumer_benchmark
- github.com/elodina/go-kafka/producer
- github.com/elodina/go_kafka_client
- github.com/elodina/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/elodina/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/elodina/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/elodina/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/elodina/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/elvenworks/kafka-conector
- github.com/elvenworks/kafka-conector/internal/delivery/worker/consumer
- github.com/elvenworks/kafka-conector/internal/delivery/worker/consumer/v1
- github.com/elvenworks/kafka-conector/internal/delivery/worker/consumer/v2
- github.com/elvenworks/kafka-conector/internal/delivery/worker/producer
- github.com/elvenworks/kafka-conector/internal/driver/kafka
- github.com/elvenworks/kafka-conector/internal/factory
- github.com/elvenworks/kafka-conector/v2/internal/delivery/worker/consumer
- github.com/elvenworks/kafka-conector/v2/internal/delivery/worker/consumer/v1
- github.com/elvenworks/kafka-conector/v2/internal/delivery/worker/consumer/v2
- github.com/elvenworks/kafka-conector/v2/internal/delivery/worker/producer
- github.com/elvenworks/kafka-conector/v2/internal/driver/kafka
- github.com/elvenworks/kafka-conector/v2/internal/factory
- github.com/elvenworks/kafka-conector/v2/kafka/consumer
- github.com/elvenworks/kafka-conector/v2/kafka/producer-async
- github.com/elvenworks/kafka-conector/v2/kafka/producer-sync
- github.com/elweb9858/cadvisor/storage/kafka
- github.com/emeno89/kafkalib/kafka
- github.com/entertainment-venue/sarama/examples/http_server
- github.com/entertainment-venue/sarama/examples/sasl_scram_client
- github.com/entertainment-venue/sarama/mocks
- github.com/entertainment-venue/sarama/tools/kafka-console-consumer
- github.com/entertainment-venue/sarama/tools/kafka-console-partitionconsumer
- github.com/entertainment-venue/sarama/tools/kafka-console-producer
- github.com/entertainment-venue/sarama/tools/kafka-producer-performance
- github.com/enverbisevac/xdefi/internal/queue/kafka
- github.com/eolinker/apinto/drivers/output/kafka
- github.com/ep-infosec/37_cisco_mongoshake/src/mongoshake/tunnel/kafka
- github.com/erenming/beats/filebeat/input/kafka
- github.com/erenming/beats/libbeat/common/kafka
- github.com/erenming/beats/libbeat/outputs/kafka
- github.com/erenming/beats/metricbeat/module/kafka
- github.com/erenming/beats/metricbeat/module/kafka/consumergroup
- github.com/erenming/beats/metricbeat/module/kafka/partition
- github.com/eric-erki/goreplay
- github.com/eric4545/beats/filebeat/input/kafka
- github.com/eric4545/beats/libbeat/common/kafka
- github.com/eric4545/beats/libbeat/outputs/kafka
- github.com/eric4545/beats/metricbeat/module/kafka
- github.com/eric4545/beats/metricbeat/module/kafka/consumergroup
- github.com/eric4545/beats/metricbeat/module/kafka/partition
- github.com/ericchiang/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/ericchiang/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/ericchiang/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/ericchiang/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/ericchiang/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/ericchiang/cadvisor/storage/kafka
- github.com/ericliu68/golang-notes
- github.com/ericpubu/go-kafka-avro
- github.com/ericyaoxr/mcube/bus/broker/kafka
- github.com/erikbozic/zipkin-go/reporter/kafka
- github.com/ernestoguimaraes/gokafkaproducer
- github.com/eryx/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/esdb/kafka-agent/kafka-agent/backend
- github.com/esser420/multistreamingserver/consumer/kafka
- github.com/euank/cadvisor/storage/kafka
- github.com/evalphobia/go-saas-code-analysis-sample
- github.com/evalsocket/kafka-connector
- github.com/evertontomalok/distributed-system-go/internal/infra/kafka
- github.com/evonck/go-lib/kafka
- github.com/ewanvalentine/go-plugins/broker/kafka
- github.com/expediadotcom/haystack-idl/fakespans
- github.com/eyugod/beats/filebeat/input/kafka
- github.com/eyugod/beats/libbeat/common/kafka
- github.com/eyugod/beats/libbeat/outputs/kafka
- github.com/eyugod/beats/metricbeat/module/kafka
- github.com/eyugod/beats/metricbeat/module/kafka/consumergroup
- github.com/eyugod/beats/metricbeat/module/kafka/partition
- github.com/fabregas/sarama/examples/http_server
- github.com/fabregas/sarama/examples/sasl_scram_client
- github.com/fabregas/sarama/mocks
- github.com/fabregas/sarama/tools/kafka-console-consumer
- github.com/fabregas/sarama/tools/kafka-console-partitionconsumer
- github.com/fabregas/sarama/tools/kafka-console-producer
- github.com/fabregas/sarama/tools/kafka-producer-performance
- github.com/faec/kafkawrite
- github.com/fahmyabdul/golibs/kafka
- github.com/fajarabdillahfn/go-wallet/internal/broker/kafka
- github.com/fakenetflix/uber-repo-cherami-server/services/outputhost
- github.com/faozimipa/micro/shared/kafka
- github.com/fathomdb/cadvisor/storage/kafka
- github.com/fawrince/eventrecord/broker
- github.com/fberrez/romantic-aggregator/kafka
- github.com/fbiville/eventing-contrib/kafka/channel/pkg/dispatcher
- github.com/fbiville/eventing-contrib/kafka/channel/pkg/reconciler/controller
- github.com/fbiville/eventing-contrib/kafka/channel/pkg/reconciler/controller/resources
- github.com/fbiville/eventing-contrib/kafka/common/pkg/kafka
- github.com/fbiville/eventing-contrib/kafka/source/pkg/adapter
- github.com/fbiville/eventing-contrib/test/test_images/kafka_performance
- github.com/fcddk/kafkagolearning/msg
- github.com/fdingiit/zipkin-go/reporter/kafka
- github.com/fdjrn/go-libs-kafka
- github.com/fearful-symmetry/beats/libbeat/common/kafka
- github.com/fearful-symmetry/beats/libbeat/outputs/kafka
- github.com/fearful-symmetry/beats/metricbeat/module/kafka
- github.com/fearful-symmetry/beats/metricbeat/module/kafka/consumergroup
- github.com/fearful-symmetry/beats/metricbeat/module/kafka/partition
- github.com/featurebasedb/pdk/kafka
- github.com/fedir/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/feiin/go-binlog-kafka
- github.com/felixb/logstash-kafka-tail
- github.com/fernandezvara/heka/plugins/kafka
- github.com/fgrosse/kafkactl/cmd
- github.com/fgrosse/kafkactl/cmd/consume
- github.com/fgrosse/kafkactl/cmd/create
- github.com/fgrosse/kafkactl/cmd/delete
- github.com/fgrosse/kafkactl/cmd/get
- github.com/fgrosse/kafkactl/cmd/produce
- github.com/fgrosse/kafkactl/cmd/replay
- github.com/fgrosse/kafkactl/cmd/update
- github.com/fgrosse/kafkactl/internal
- github.com/fichas/mq-benchmarking/benchmark/mq
- github.com/fiery/heka/plugins/kafka
- github.com/filariow/thsock/cmd/cloud/weather
- github.com/financial-times/kafkaduct/kafkaduct
- github.com/findcoo/stream/kafka
- github.com/finn-no/burrow
- github.com/finogeeks/ligase/cmd/kafka-test
- github.com/fish-pro/ginbase
- github.com/fklostland/dkspider/src/FKKafka
- github.com/fklostland/dkspider/src/github.com/Shopify/sarama/examples/http_server
- github.com/fklostland/dkspider/src/github.com/Shopify/sarama/mocks
- github.com/fklostland/dkspider/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/fklostland/dkspider/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/fklostland/dkspider/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/flachnetz/flatnet-agent
- github.com/flachnetz/zipkin-go-opentracing
- github.com/flavio/cadvisor/storage/kafka
- github.com/flaviostutz/coinbase-vwap/kafka
- github.com/flinox/kafka_golang_producer/webserver
- github.com/fluidstackio/nomad-firehose/sink
- github.com/flyxiao2000/gobundle/pkg/msgbus
- github.com/focalsolution/micro-go-plugins/broker/kafka
- github.com/fogray/baasmanager/baas-core/core/tools/fabric/common/viperutil
- github.com/foolusion/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/fotomxq/weeekj_core/v5/core/kafka
- github.com/foxcomm/go_kafka_client
- github.com/foxcomm/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/foxcomm/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/foxcomm/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/foxcomm/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/foxcomm/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/frairon/goka-godays2019/01-sarama
- github.com/freezeChen/studio-library/zlog
- github.com/fretkak/elastic-beats/filebeat/input/kafka
- github.com/fretkak/elastic-beats/libbeat/common/kafka
- github.com/fretkak/elastic-beats/libbeat/outputs/kafka
- github.com/fretkak/elastic-beats/metricbeat/module/kafka
- github.com/fretkak/elastic-beats/metricbeat/module/kafka/consumergroup
- github.com/fretkak/elastic-beats/metricbeat/module/kafka/partition
- github.com/friddle/openbilibili-go-common/app/admin/main/apm/service
- github.com/friddle/openbilibili-go-common/app/infra/canal/service/reader
- 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/friddle/openbilibili-go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/fsedano/pipeline_influx_grafana/pipeline/pipeline_data
- github.com/funkygao/gafka/cmd/actord/executor
- github.com/funkygao/gafka/cmd/gk
- github.com/funkygao/gafka/cmd/gk/command
- github.com/funkygao/gafka/cmd/gk/command/kfs
- github.com/funkygao/gafka/cmd/gk/command/mirror
- github.com/funkygao/gafka/cmd/kateway/bench
- github.com/funkygao/gafka/cmd/kateway/gateway
- github.com/funkygao/gafka/cmd/kateway/store
- github.com/funkygao/gafka/cmd/kateway/store/dummy
- github.com/funkygao/gafka/cmd/kateway/store/kafka
- github.com/funkygao/gafka/cmd/kguard/watchers/influxdb
- github.com/funkygao/gafka/cmd/kguard/watchers/kafka
- github.com/funkygao/gafka/cmd/kguard/watchers/kateway
- github.com/funkygao/gafka/zk
- github.com/funkygao/kafka-cg/consumergroup
- github.com/funkygao/kafka-cg/examples/consumergroup
- github.com/funkygao/kafka-cg/tools/consoleconsumer
- github.com/funkygao/kafka-cg/tools/consoleproducer
- github.com/funkygao/kafka-cg/tools/stressproducer
- github.com/funkygao/kafka-cg/tools/transferoffsets
- github.com/funkygao/kafka-cg/tools/verifier
- github.com/furyanprotocol/v4-chain/protocol/indexer/msgsender
- github.com/fusion-app/fusion-app/pkg/mq-hub
- github.com/fwidjaya20/symphonic/contracts/event
- github.com/fzu-huang/cadvisor/storage/kafka
- github.com/g-airport/go-infra/mq
- github.com/g10guang/graduation/dal/mq
- github.com/gaantunes/kafka_exporter
- github.com/gabbottron/goflow/v3/transport
- github.com/gabrielmougard/rapgo.io/src/bucketuploaderservice/pkg/eventproc
- github.com/gabrielmougard/rapgo.io/src/bucketuploaderservice/pkg/kafka/helper
- github.com/gabrielmougard/rapgo.io/src/bucketuploaderservice/pkg/kafka/kafkalib
- github.com/gabrielmougard/rapgo.io/src/converterserverservice/pkg/fswatcher
- github.com/gabrielmougard/rapgo.io/src/converterserverservice/pkg/kafka/helper
- github.com/gabrielmougard/rapgo.io/src/converterserverservice/pkg/kafka/lib
- github.com/gabrielmougard/rapgo.io/src/heartbeatservice
- github.com/gabrielmougard/rapgo.io/src/heartbeatservice/pkg/statehandler
- github.com/gain620/logurus-kafka-hook
- github.com/galamsiva2020/kubernetes-heapster-monitoring/common/kafka
- github.com/galaxy-future/cudgx/common/kafka
- github.com/gamedev-ai/bilibili_repo/app/admin/main/apm/service
- github.com/gamedev-ai/bilibili_repo/app/infra/canal/service/reader
- 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/gamedev-ai/bilibili_repo/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/ganesh-karthick/bigmuddy-network-telemetry-pipeline
- github.com/gaoljhy/pilipili/app/admin/main/apm/service
- github.com/gaoljhy/pilipili/app/infra/canal/service/reader
- github.com/gaoljhy/pilipili/app/infra/databus/tcp
- github.com/gaoljhy/pilipili/app/infra/notify/notify
- github.com/gaoljhy/pilipili/app/interface/openplatform/monitor-end/service
- github.com/gaoljhy/pilipili/app/job/main/app-wall/service/offer
- github.com/gaoljhy/pilipili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/gaorx/stardust3/sdkafka
- github.com/gattermeier/gizmo/pubsub/kafka
- github.com/gaurav04/go-practises/kafka
- github.com/gautham365/hashedtokens
- github.com/gaystudio/openbilibili/app/admin/main/apm/service
- github.com/gaystudio/openbilibili/app/infra/canal/service/reader
- 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/gaystudio/openbilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/gdchenli/kafka_demo/pkg/kafka
- github.com/gdfragoso/dd-trace-go/contrib/Shopify/sarama
- github.com/gdwgh/mu-li-xian-bei/app/admin/main/apm/service
- github.com/gdwgh/mu-li-xian-bei/app/infra/canal/service/reader
- 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/gdwgh/mu-li-xian-bei/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/geekboydqz/goproject/logAgent/kafka
- github.com/geiqin/go-plugins/broker/kafka/v2
- github.com/genghongjie/go-code/middleware/kafka/ksmonitor_producer/md_kafka
- github.com/genius52/bigdata/kafka_demo/main
- github.com/geniusrabbit/notificationcenter/kafka
- github.com/germanramos/kafka-console-consumer
- github.com/germanramos/kafka-console-consumer/gopath/src/github.com/Shopify/sarama/examples/http_server
- github.com/germanramos/kafka-console-consumer/gopath/src/github.com/Shopify/sarama/mocks
- github.com/germanramos/kafka-console-consumer/gopath/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/germanramos/kafka-console-consumer/gopath/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/germanramos/kafka-console-consumer/gopath/src/github.com/bsm/sarama-cluster
- github.com/germanramos/kafka-console-consumer/gopath/src/github.com/bsm/sarama-cluster/cmd/sarama-cluster-cli
- github.com/germanramos/kafka-console-producer/gopath/src/gopkg.in/Shopify/sarama.v1/examples/http_server
- github.com/germanramos/kafka-console-producer/gopath/src/gopkg.in/Shopify/sarama.v1/mocks
- github.com/germanramos/kafka-console-producer/gopath/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-consumer
- github.com/germanramos/kafka-console-producer/gopath/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-partitionconsumer
- github.com/germanramos/kafka-console-producer/gopath/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-producer
- github.com/gertcuykens/jocko/examples/sarama
- github.com/gfremex/logrus-kafka-hook
- github.com/ggordan/go-pubsub/kafka
- github.com/gguridi/benchmark-kafka-go-clients/sarama
- github.com/ghetzel/tile38/pkg/endpoint
- github.com/ghodss/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/ghouleztt/pangolin/cmd
- github.com/giautm/eh-kafka
- github.com/gihyunk/dd-trace-go/contrib/Shopify/sarama
- github.com/git-hulk/go-consumergroup
- github.com/github-muzilong/go-toolkit/kafka
- github.com/gitmine/pholcus/common/kafka
- github.com/giuseppe/cadvisor/storage/kafka
- github.com/gkarlik/quark-go/broker/kafka
- github.com/gksinghjsr/carbon-relay-ng/route
- github.com/glaslos/honeytail/producers/kafka
- github.com/glide-im/glide/pkg/store
- github.com/glowwormx/mongoshake/src/mongoshake/tunnel/kafka
- github.com/gmbyapa/kafka-connector
- github.com/go-alive/go-plugins/broker/kafka
- github.com/go-chassis/zipkin-go-opentracing
- github.com/go-crt/golib/base
- github.com/go-god/broker/gkafka
- github.com/go-gulfstream/gulfstream/pkg/eventbus/kafka
- github.com/go-hare/haremicro/broker/kafka
- github.com/go-ocf/cqrs/eventbus/kafka
- github.com/go-parrot/parrot/pkg/queue/kafka
- github.com/go-saas/kit/event/kafka
- github.com/go-tyrion/tyrion/driver/kafka
- github.com/gocollection/kafka-go
- github.com/gocommon/go-plugins/broker/kafka
- github.com/godaner/gocipher/log/logv1
- github.com/goees/yago/coms/kafka
- github.com/goferHiro/goreplay
- github.com/gojaden/gotest/gotest/basic/zookeeper
- github.com/gojek/kat/pkg/client
- github.com/gojet/pkg/queue/kafka
- github.com/golangltd/pholcus/common/kafka
- github.com/goldenbean/go-common/utils/kafka
- github.com/gole-dev/gole/pkg/queue/kafka
- github.com/gomicroim/gomicroim/pkg/kafka
- github.com/gonet2/game/kafka
- github.com/goodpotatoe/potatoe/cadvisor-master/storage/kafka
- github.com/google/cadvisor/cmd/internal/storage/kafka
- github.com/goplume/core/kafka
- github.com/gordon-h/sarama/mocks
- github.com/goriller/ginny-broker/kafka
- github.com/goserizz/mq-benchmarking/benchmark/mq
- github.com/gotcp/connector
- github.com/gotoblink/go-plugins/broker/kafka
- github.com/gowins/go-plugins/broker/kafka
- github.com/gowroc/meetups/kafka2go/kafka
- github.com/gphat/veneur/sinks/kafka
- github.com/grafana/agent/pkg/integrations/kafka_exporter
- github.com/grafana/alloy/internal/cmd/integration-tests/configs/kafka
- github.com/grafana/carbon-relay-ng/route
- github.com/grafana/metrictank/cmd/metrictank
- github.com/grafana/metrictank/cmd/mt-fakemetrics/out
- github.com/grafana/metrictank/cmd/mt-fakemetrics/out/kafkamdm
- github.com/grafana/metrictank/input/kafkamdm
- github.com/grafana/metrictank/kafka
- github.com/grafana/metrictank/mdata/notifierKafka
- github.com/grafana/metrictank/publish/kafka
- github.com/grafana/worldping-gw/events/publish
- github.com/grafana/xk6-output-kafka/pkg/kafka
- github.com/graphext/furan/lib/kafka
- github.com/gratno/go-plugins/broker/kafka
- github.com/grepplabs/docker-it/wait/kafka
- github.com/gritt/go-data-intensive/internal/details/kafka
- github.com/grobie/cadvisor/storage/kafka
- github.com/grpc-kit/pkg/cfg
- github.com/gsakun/alerttransfer/parsedata
- github.com/gstarikov/go-plugins/broker/kafka
- github.com/gua-pian/alibaba-dts-go
- github.com/gucio321/mosquito/alikafka
- github.com/guitmz/goreplay
- github.com/guiyunweb/openbilibili/app/admin/main/apm/service
- github.com/guiyunweb/openbilibili/app/infra/canal/service/reader
- 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/guiyunweb/openbilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/guobin8205/api_demo/models/db/kafka
- github.com/guozhuang/grpcproduction/server
- github.com/guozijing/onos-lib-go/pkg/logging
- github.com/h4sh5/goflow-clickhouse/transport
- github.com/hackxi/minio/pkg/event/target
- github.com/haircommander/cadvisor/storage/kafka
- github.com/hajhatten/cadvisor/storage/kafka
- github.com/halega/sarama/examples/http_server
- github.com/halega/sarama/examples/sasl_scram_client
- github.com/halega/sarama/mocks
- github.com/halega/sarama/tools/kafka-console-consumer
- github.com/halega/sarama/tools/kafka-console-partitionconsumer
- github.com/halega/sarama/tools/kafka-console-producer
- github.com/halega/sarama/tools/kafka-producer-performance
- github.com/hanf1983/go-plugins/broker/kafka
- github.com/hanguofeng/taiji
- github.com/hanguofeng/taiji/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/hanguofeng/taiji/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/hanguofeng/taiji/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/hanguofeng/taiji/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/hanguofeng/taiji/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/hanguofeng/taiji/tools/message_to_curl
- github.com/hanyidreamer/zipkin-go-opentracing
- github.com/hanyuancheung/kafka_exporter
- github.com/hanzeingithub/binlog_monitor
- github.com/haoyuehong/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/hardeep18/heapster/common/kafka
- github.com/harveywangdao/ants/app/order/service
- github.com/hassanbabaie/minio/pkg/event/target
- github.com/hattrickcr7/myminio/internal/event/target
- github.com/hb-chen/gmqtt/pkg/broker/kafka
- github.com/hectorgool/kafka1
- github.com/hegeng1212/pholcus/common/kafka
- github.com/heikuo/minio/pkg/event/target
- github.com/heimdall-controller/heimdall/pkg/controllers
- github.com/helios/go-sdk/proxy-libs/heliossarama
- github.com/hellobike/amazonriver/handler/output
- github.com/hellofresh/kandalf/pkg/producer
- github.com/henderiw/telemetrycollector
- github.com/henrion-y/base.services/infra/kafka_client
- github.com/henrylee2cn/pholcus/common/kafka
- github.com/heptio/eventrouter/sinks
- github.com/heptiolabs/eventrouter/sinks
- github.com/herman-hang/herman/kernel/kafka
- github.com/hero576/logcollection
- github.com/heshaofeng1991/core/middlewares/kafka
- github.com/heyHui2018/best-practise/service/kafka
- github.com/heyhui2018/best-practise/service/kafka
- github.com/hidevopsio/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/highalpha/go-plugins/broker/kafka
- github.com/hikubernetes/logagent/kafka
- github.com/hilittlecat/pholcus/common/kafka
- github.com/hiromaily/golibs/messaging/kafka
- github.com/hisheng/dataStructure/database/kafka
- github.com/hkm15022001/Supply-Chain-Event-Management/api/kafka
- github.com/hodgekou/openbilibili/app/admin/main/apm/service
- github.com/hodgekou/openbilibili/app/infra/canal/service/reader
- 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/hodgekou/openbilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/hollo08/go-test/test/kafka
- github.com/honeytrap/honeytrap/pushers/kafka
- github.com/hongshibao/cadvisor/storage/kafka
- github.com/horoshi10v/grpc-benchmarks/server
- github.com/hourback/heka/plugins/kafka
- github.com/howge/ops
- github.com/hpcslag/mqtt2kafka
- github.com/hrojas2021/go-kafka-mongodb/pkg/kafka/sarama
- github.com/hsuan-jen/go-common/app/admin/main/apm/service
- github.com/hsuan-jen/go-common/app/infra/canal/service/reader
- 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/hsuan-jen/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/huakwan/message-broker/kafka
- github.com/huangjiasingle/cadvisor/storage/kafka
- github.com/huangnauh/gommon/kafka
- github.com/huangshaokun/funnel/outputs
- github.com/huchgit/golang_zk/kafka_consumer
- github.com/hukaixuan/beats/filebeat/input/kafka
- github.com/hukaixuan/beats/libbeat/common/kafka
- github.com/hukaixuan/beats/libbeat/outputs/kafka
- github.com/hukaixuan/beats/metricbeat/module/kafka
- github.com/hukaixuan/beats/metricbeat/module/kafka/consumergroup
- github.com/hukaixuan/beats/metricbeat/module/kafka/partition
- github.com/hulklab/yago/coms/kafka
- github.com/humorliang/go-demo/mq/kakfa/kafka
- github.com/hunknownz/tiq/cdc/sink/producer/kafka
- github.com/huynguyen-quoc/go/streams/sarama
- github.com/huytikii/go-plugins/broker/kafka
- github.com/hyeonjae/go-eventsource/eventbus
- github.com/hyperledger-labs/fabric-block-archiving/common/viperutil
- github.com/hyperledger-labs/fabric-block-archiving/orderer/common/localconfig
- github.com/hyperledger-labs/fabric-block-archiving/orderer/consensus/kafka
- github.com/hyperledger-labs/fabric-block-archiving/orderer/consensus/kafka/mock
- github.com/hyperledger-labs/fabric-machine/v2.2/orderer/common/localconfig
- github.com/hzde0128/data_receiver/common/kafkaclient
- github.com/iTheWindRises/bilibili-source/app/admin/main/apm/service
- github.com/iTheWindRises/bilibili-source/app/infra/canal/service/reader
- 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/iTheWindRises/bilibili-source/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/iamduo/go-plugins/broker/kafka
- 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/canal/service/reader
- 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/iamfaith/go_common/Desktop/go-common-master/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/iamshreeram/go-kafka-stream
- github.com/iamthemuffinman/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/ianfoo/gizmo/pubsub/kafka
- github.com/ianneub/heka/plugins/kafka
- github.com/ibm-cloud/argo-events/gateways/core/stream/kafka
- github.com/ibm-sevone-npm/eng-platform-ezkafka
- github.com/ibuildthecloud/cadvisor/storage/kafka
- github.com/iddqdeika/kafka-adapter
- github.com/ie310mu/ie310go/forks/github.com/aristanetworks/goarista/cmd/ockafka
- github.com/ie310mu/ie310go/forks/github.com/aristanetworks/goarista/kafka
- github.com/ie310mu/ie310go/forks/github.com/aristanetworks/goarista/kafka/openconfig
- github.com/ie310mu/ie310go/forks/github.com/aristanetworks/goarista/kafka/producer
- github.com/ifttt/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/ifttt/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/ifttt/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/ifttt/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/ifttt/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/ifttt/cadvisor/storage/kafka
- github.com/igilliano/kafka_test/kafka
- github.com/igungor/goreplay
- github.com/ihatemodels/klog
- github.com/iheartradio/cog/cio/eio/kafka
- github.com/ihsanul14/go-confluent-kafka
- github.com/ijalalfrz/coinbit-test/config
- github.com/ijh4565/kafka_neo/pkg/kafka
- github.com/iluminae/goflow/transport
- github.com/imc-trading/ifwatch/backend/kafka
- github.com/imcom/burrow
- github.com/imduffy15/kafka_exporter
- github.com/imikushin/cadvisor/storage/kafka
- github.com/imind-lab/micro/broker
- github.com/imjerrychan/gostudy/bilibili_fork-master/app/admin/main/apm/service
- github.com/imjerrychan/gostudy/bilibili_fork-master/app/infra/canal/service/reader
- 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/imjerrychan/gostudy/bilibili_fork-master/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/imopro/minio/pkg/event/target
- github.com/imw7/studygo/day11/logagent/kafka
- github.com/imzack/hmq/plugins/bridge
- github.com/infantbee/skills/golang/kafka
- github.com/infinimesh/infinimesh/cmd/mqtt-bridge
- github.com/infinimesh/infinimesh/cmd/shadow-api
- github.com/infinimesh/infinimesh/cmd/shadow-delta-merger
- github.com/infinimesh/infinimesh/cmd/shadow-persister
- github.com/infinimesh/infinimesh/cmd/telemetry-router
- github.com/infinimesh/infinimesh/cmd/timescale-connector
- github.com/infinimesh/infinimesh/pkg/shadow
- github.com/infinimesh/infinimesh/pkg/timeseries
- github.com/iniyusril/qframework/pkg/common/kafka
- github.com/innocentkithinji/xmtest/repository
- github.com/insomniacoder/go-kafka/producers
- github.com/intelsdi-x/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/introvertautist/kafka_consumer/consumer/kafka
- github.com/inwecrypto/gomq-kafka
- github.com/iosif02/contrib/trigger/kafka
- github.com/iqoqo/nomad-firehose/sink
- github.com/iris-contrib/examples/tutorial/api-for-apache-kafka/src
- github.com/ischenkx/kantoku/pkg/common/transport/broker/watermill
- github.com/ischenxin/cloudevents-sdk-go/pkg/bindings/kafka_sarama
- github.com/ishanjain28/vflow/producer
- github.com/ithewindrises/bilibili-source/app/admin/main/apm/service
- github.com/ithewindrises/bilibili-source/app/infra/canal/service/reader
- 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/ithewindrises/bilibili-source/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/itsfinn/kfkcli
- github.com/itumbrella/clicli-go-backend/app/admin/main/apm/service
- github.com/itumbrella/clicli-go-backend/app/infra/canal/service/reader
- 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/itumbrella/clicli-go-backend/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/j2gg0s/kubenotify/pkg/client
- github.com/jace996/multiapp/event/kafka
- github.com/jackhopner/kt
- github.com/jaden-xxl/gotest/gotest/basic/zookeeper
- github.com/jaden7856/go-kafka
- github.com/jaegertracing/jaeger/cmd/ingester/app/consumer
- github.com/jaegertracing/jaeger/cmd/opentelemetry/app/receiver/kafkareceiver
- github.com/jaegertracing/jaeger/pkg/kafka/auth
- github.com/jaegertracing/jaeger/pkg/kafka/consumer
- github.com/jaegertracing/jaeger/pkg/kafka/producer
- github.com/jaegertracing/jaeger/plugin/storage/kafka
- github.com/jagath01234/kafka_go_example
- github.com/jageros/hawox/queues/kafka
- github.com/jakubmleczakHPE/kafka
- github.com/jalapeno/bgp-processor/pkg/kafkamessenger
- github.com/james-dao/test/src/github.com/Shopify/sarama/examples/http_server
- github.com/james-dao/test/src/github.com/Shopify/sarama/mocks
- github.com/james-dao/test/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/james-dao/test/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/james-dao/test/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/jamesblackmantfs/plutocore
- github.com/jamesjaj2dc6j/bao17634h/kafka/kafka-operator-krallistic/kafka
- github.com/jamesowenhall/kafka/consumergroup
- github.com/jamesowenhall/kafka/examples/consumergroup
- github.com/jamesowenhall/kafka/tools/consoleconsumer
- github.com/jamesowenhall/kafka/tools/consoleproducer
- github.com/jamesowenhall/kafka/tools/stressproducer
- github.com/jamesowenhall/kafka/tools/transferoffsets
- github.com/jamesowenhall/kafka/tools/verifier
- github.com/jameswei/burrow
- github.com/jamiealquiza/sangrenel
- github.com/jan-zajic/sarama/examples/http_server
- github.com/jan-zajic/sarama/examples/sasl_scram_client
- github.com/jan-zajic/sarama/mocks
- github.com/jan-zajic/sarama/tools/kafka-console-consumer
- github.com/jan-zajic/sarama/tools/kafka-console-partitionconsumer
- github.com/jan-zajic/sarama/tools/kafka-console-producer
- github.com/jan-zajic/sarama/tools/kafka-producer-performance
- github.com/janelia-flyem/dvid/storage
- github.com/jantb/search/kafka
- github.com/jasonfeng1980/pg/mq/kafka
- github.com/javierdlrm/inference-logger
- github.com/jawshua/zipkin-go-opentracing
- github.com/jbochi/gizmo/pubsub/kafka
- github.com/jbvmio/krc
- github.com/jcudit/beats/filebeat/input/kafka
- github.com/jcudit/beats/libbeat/common/kafka
- github.com/jcudit/beats/libbeat/outputs/kafka
- github.com/jcudit/beats/metricbeat/module/kafka
- github.com/jcudit/beats/metricbeat/module/kafka/consumergroup
- github.com/jcudit/beats/metricbeat/module/kafka/partition
- github.com/jdcloud-bds/bds/common/kafka
- github.com/jdcohen220/go-kafka
- github.com/jdrews/go-tailer
- github.com/jeffotoni/gokafka.poc/controller/handler/topic
- github.com/jeffreyDing11223/kago
- github.com/jeffreyding11223/kago
- github.com/jeffzhangme/zapx
- github.com/jeichorn/heka/plugins/kafka
- github.com/jeniawhite/beats/filebeat/input/kafka
- github.com/jeniawhite/beats/libbeat/common/kafka
- github.com/jeniawhite/beats/libbeat/outputs/kafka
- github.com/jeniawhite/beats/metricbeat/module/kafka
- github.com/jeniawhite/beats/metricbeat/module/kafka/consumergroup
- github.com/jeniawhite/beats/metricbeat/module/kafka/partition
- github.com/jessfraz/cadvisor/storage/kafka
- github.com/jessynt/kafka_exporter
- github.com/jetenov/product-storage-api/internal/app/producer
- github.com/jezell/kafka-pixy/admin
- github.com/jezell/kafka-pixy/apiserver
- github.com/jezell/kafka-pixy/config
- github.com/jezell/kafka-pixy/consumer/consumerimpl
- github.com/jezell/kafka-pixy/consumer/groupcsm
- github.com/jezell/kafka-pixy/consumer/mapper
- github.com/jezell/kafka-pixy/consumer/msgstream
- github.com/jezell/kafka-pixy/consumer/offsetmgr
- github.com/jezell/kafka-pixy/consumer/partitioncsm
- github.com/jezell/kafka-pixy/logging
- github.com/jezell/kafka-pixy/producer
- github.com/jezell/kafka-pixy/testhelpers/kafkahelper
- github.com/jghiloni/kafka-firehose-nozzle
- github.com/jiangfans/handy/kafka_tools
- github.com/jiaoshenmene/bilibili-backup/app/admin/main/apm/service
- github.com/jiaoshenmene/bilibili-backup/app/infra/canal/service/reader
- 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/jiaoshenmene/bilibili-backup/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/jiaxwu/dq
- github.com/jiaxwu/dq/kafka_delay_queue_example/consumer
- github.com/jiaxwu/dq/kafka_delay_queue_example/delay_service
- github.com/jiaxwu/dq/kafka_delay_queue_example/producer
- github.com/jiaxwu/dq/kafka_delay_queue_producer_test/consumer
- github.com/jiaxwu/dq/kafka_delay_queue_producer_test/producer
- github.com/jin06/binlogo/app/pipeline/output/sender/kafka
- github.com/jin06/binlogo/examples/kafka
- github.com/jin06/binlogo/pkg/store/model/pipeline
- github.com/jin06/binlogo/v2/app/pipeline/output/sender/kafka
- github.com/jin06/binlogo/v2/examples/kafka
- github.com/jin06/binlogo/v2/pkg/store/model/pipeline
- github.com/jinagamvasubabu/golang-boilerplate/adapters/kafka
- github.com/jinbanglin/go-plugins/broker/kafka
- github.com/jingchengli/dannytools/mykafka
- github.com/jingyanlei/go-test/src/kafka
- github.com/jinhuiztg/kafka-file-producer
- github.com/jinnzy/log-collection/sqlserver2kafka/models
- github.com/jintao-zero/go-practice/kafka/consumer
- github.com/jinxprotocol/v4-chain/protocol/indexer/msgsender
- github.com/jiucaixiansheng/windyandwarm/common/kafka
- github.com/jizishuo/logagent/kafka
- github.com/jjneely/go-carbon/receiver/kafka
- github.com/jkrus/test_sarama/consumer/cmd/app
- github.com/jksroot/beats/v7/filebeat/input/kafka
- github.com/jksroot/beats/v7/libbeat/common/kafka
- github.com/jksroot/beats/v7/libbeat/outputs/kafka
- github.com/jksroot/beats/v7/libbeat/outputs/kafkarest
- github.com/jksroot/beats/v7/metricbeat/module/kafka
- github.com/jksroot/beats/v7/metricbeat/module/kafka/consumergroup
- github.com/jksroot/beats/v7/metricbeat/module/kafka/partition
- github.com/jlfxt/traefik-plugin
- github.com/jmuyuyang/queue_proxy/backend
- github.com/joemadeus/gizmo/pubsub/kafka
- github.com/joey92/tile38/controller/endpoint
- github.com/johann8384/libbeat/outputs/kafka
- github.com/john-shepherdson/argo-messaging/brokers
- github.com/johnnadratowski/batch/app/model
- github.com/jonluo94/baasmanager/baas-core/core/tools/fabric/common/viperutil
- github.com/jorgecarleitao/gleam/plugins/kafka
- github.com/josa42/mini-bcr/pkg/kafka
- github.com/joshgav/eventing-contrib/kafka/channel/pkg/dispatcher
- github.com/joshgav/eventing-contrib/kafka/channel/pkg/reconciler/controller
- github.com/joshgav/eventing-contrib/kafka/channel/pkg/reconciler/controller/resources
- github.com/joshgav/eventing-contrib/kafka/common/pkg/kafka
- github.com/joshgav/eventing-contrib/kafka/source/pkg/adapter
- github.com/joshgav/eventing-contrib/test/test_images/kafka_performance
- github.com/joshqu1985/fireman/mq
- github.com/joshuabezaleel/test-kafka
- github.com/journeymidnight/kafka
- github.com/joyllee/blocks/kafka
- github.com/jpfaria/tests/sarama
- github.com/jrasell/nomad-firehose/sink
- github.com/jrdani/cobra-commandline-kafka-producer/kafka
- github.com/jrolstad/engineering-signal-collector/internal/pkg/messaging
- github.com/jrxfive/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/jrxfive/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/jrxfive/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/jrxfive/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/jrxfive/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/jrxfive/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/jrxfive/telegraf/outputs/kafka
- github.com/jrxfive/telegraf/plugins/kafka_consumer
- github.com/jscode017/sarama_kafka_producer
- github.com/jstang9527/go-elk/log_transfer/kafka
- github.com/jtri/kafka-go-consumer-producer
- github.com/julianlee107/logagent/kafka
- github.com/jumboframes/tigerbalm/frame/capal/tbkafka
- github.com/junxin-huo/go_test
- github.com/justcallmewilliam/b_source_code/app/admin/main/apm/service
- github.com/justcallmewilliam/b_source_code/app/infra/canal/service/reader
- 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/justcallmewilliam/b_source_code/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/justin0u0/protoc-gen-grpc-sarama/example
- github.com/justinyaoqi/pholcus/common/kafka
- github.com/justsocialapps/kafkabeat/beater
- github.com/jxwt/tools
- github.com/k-paas-archive/cadvisor/src/github.com/google/cadvisor/storage/kafka
- github.com/k0ffee/beats/filebeat/input/kafka
- github.com/k0ffee/beats/libbeat/common/kafka
- github.com/k0ffee/beats/libbeat/outputs/kafka
- github.com/k0ffee/beats/metricbeat/module/kafka
- github.com/k0ffee/beats/metricbeat/module/kafka/consumergroup
- github.com/k0ffee/beats/metricbeat/module/kafka/partition
- github.com/k13w/go-kafka/infrastructure/kafka/consumer
- github.com/k8guard/k8guardlibs/messaging/kafka
- github.com/k8s-kollect/kollect/pkg/event
- github.com/ka1251/core
- github.com/kackerx/katools/middleware/kafka
- github.com/kadaan/kafka_exporter
- github.com/kailashyogeshwar85/slim-orderbook/cmd/slim-orderbook
- github.com/kalmanb/datapipelinepoc/kafka
- github.com/kamva/hexa-event/examples/failkafka
- github.com/kamva/hexa-event/examples/kafka_dead_letter_queue
- github.com/kamva/hexa-event/examples/kafka_multiple_dead_letter_queue
- github.com/kamva/hexa-event/examples/kafka_outbox_with_consumer
- github.com/kamva/hexa-event/examples/kafka_with_metrics
- github.com/kamva/hexa-event/examples/kafkaretry
- github.com/kamva/hexa-event/examples/rawkafkaconsumergroup
- github.com/kamva/hexa-event/examples/simplekafka
- github.com/kamva/hexa-event/hafka
- github.com/kanatohodets/carbonsearch/consumer/kafka
- github.com/karlem/nomad-firehose/sink
- github.com/karuppiah7890/kong-plugin-kafka-upstream
- github.com/kasper023/shop/transport
- github.com/kavyanshpandey/go-api-for-sending-data-to-apache-kafka
- github.com/kazekim/backend-engineer-challenge/grlib/bekafka
- github.com/kazoup/go-plugins/broker/kafka
- github.com/kazukgw/kafka-mysql-binloger/producer
- github.com/kbdy/pholcus/common/kafka
- github.com/kbtxwer/openbilibili-go/app/admin/main/apm/service
- github.com/kbtxwer/openbilibili-go/app/infra/canal/service/reader
- 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/kbtxwer/openbilibili-go/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/kcajmagic/k6/stats/kafka
- github.com/kdcer/go-lib/lib/kafka
- github.com/kdpujie/log4go
- github.com/kedacore/keda/pkg/scalers
- github.com/keitaro1020/kafka-go
- github.com/kelindar/veneur/sinks/kafka
- github.com/ken-house/go-contrib/prototype/kafkaClient
- github.com/kenshin579/tutorials-go/go-kafka/consumer
- github.com/kenshin579/tutorials-go/go-kafka/consumer-group
- github.com/kenshin579/tutorials-go/go-kafka/producer
- github.com/kenshin579/tutorials-go/go-kafka/sarama/example
- github.com/kenshin579/tutorials-go/go-kafka/sarama/tools/kafka-console-consumer
- github.com/kenshin579/tutorials-go/go-kafka/sarama/tools/kafka-console-partitionconsumer
- github.com/kenshin579/tutorials-go/go-kafka/sarama/tools/kafka-console-producer
- github.com/kenshin579/tutorials-go/go-kafka/sarama/tools/kafka-producer-performance
- github.com/kesavand/case-study/internal/pkg/kafka
- github.com/kestrelcjx/beats/filebeat/input/kafka
- github.com/kestrelcjx/beats/libbeat/common/kafka
- github.com/kestrelcjx/beats/libbeat/outputs/kafka
- github.com/kestrelcjx/beats/metricbeat/module/kafka
- github.com/kestrelcjx/beats/metricbeat/module/kafka/consumergroup
- github.com/kestrelcjx/beats/metricbeat/module/kafka/partition
- github.com/kevinclcn/parsebinlog
- github.com/kevinfan0/bilibili-go/app/admin/main/apm/service
- github.com/kevinfan0/bilibili-go/app/infra/canal/service/reader
- 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/kevinfan0/bilibili-go/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/kevinsamoei/sarama-clone-topic
- github.com/kgtw/cadvisor/storage/kafka
- 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/canal/service/reader
- 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/king2200/bilibli_golang/src/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/kiriminaja/kaj-golang-pkg/kafka
- github.com/kiririx/go-base
- github.com/kirves/kafka_exporter
- github.com/kishansairam9/bench/v2/requester
- github.com/kistler-group/eh-kafka
- github.com/kjschnei001/jaeger/cmd/ingester/app/consumer
- github.com/kjschnei001/jaeger/cmd/ingester/app/consumer/mocks
- github.com/kjschnei001/jaeger/pkg/kafka/auth
- github.com/kjschnei001/jaeger/pkg/kafka/consumer
- github.com/kjschnei001/jaeger/pkg/kafka/producer
- github.com/kjschnei001/jaeger/plugin/storage/kafka
- github.com/kkangxu/himlad-magic/microservice
- github.com/klaus/zipkin-go-opentracing
- github.com/kmetaxas/gafkalo
- github.com/kmiku7/kafka/consumergroup
- github.com/kmiku7/kafka/examples/consumergroup
- github.com/kmiku7/kafka/tools/consoleconsumer
- github.com/kmiku7/kafka/tools/consoleproducer
- github.com/kmiku7/kafka/tools/stressproducer
- github.com/kmiku7/kafka/tools/transferoffsets
- github.com/kmiku7/kafka/tools/verifier
- github.com/kms9/publicyc/pkg/client/okafka
- github.com/knative/eventing-sources/kafka/channel/pkg/dispatcher
- github.com/knative/eventing-sources/kafka/channel/pkg/reconciler/controller
- github.com/knative/eventing-sources/kafka/channel/pkg/reconciler/controller/resources
- github.com/knative/eventing-sources/kafka/common/pkg/kafka
- github.com/knative/eventing-sources/kafka/source/pkg/adapter
- github.com/knative/eventing-sources/test/test_images/kafka_performance
- github.com/knmsk/xk6-output-kafka/pkg/kafka
- github.com/kobtea/cadvisor/storage/kafka
- github.com/kochava/firehose/cmd/internal/kafka
- github.com/kojhliang/hyperledger-fabric-resolve-make-docker-error/fabric/common/viperutil
- github.com/kojhliang/hyperledger-fabric-resolve-make-docker-error/fabric/orderer/common/localconfig
- github.com/kojhliang/hyperledger-fabric-resolve-make-docker-error/fabric/orderer/consensus/kafka
- github.com/kojhliang/hyperledger-fabric-resolve-make-docker-error/fabric/orderer/consensus/kafka/mock
- github.com/konfortes/tbd
- github.com/kong36088/danmu
- github.com/koorsha/sample_go_projects/src/Advanced-Go-Programming-in-7-Days/Day-7/4-Message-Queues/easy-issues/application
- github.com/koorsha/sample_go_projects/src/Advanced-Go-Programming-in-7-Days/Day-7/4-Message-Queues/easy-issues/cmd/user
- github.com/koorsha/sample_go_projects/src/Advanced-Go-Programming-in-7-Days/Day-7/4-Message-Queues/easy-issues/web
- github.com/krunal4amity/cfn-infra/custom_resources/msk/postprocesskafka
- github.com/kryloffgregory/kafka-to-ws
- github.com/ksang/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/ksh24865/smart-park/logic-core/kafkaConsumer/sarama
- github.com/kubeless/kafka-trigger/pkg/event-consumers/kafka
- github.com/kubeshop/tracetest/examples/quick-start-go-and-kafka/consumer-worker/streaming
- github.com/kubeshop/tracetest/examples/quick-start-go-and-kafka/producer-api/streaming
- github.com/kubeshop/tracetest/examples/tracetesting-event-driven-systems/payment-order-api/streaming
- github.com/kubeshop/tracetest/examples/tracetesting-event-driven-systems/payment-storage-worker/streaming
- github.com/kulak/goreplay
- github.com/kumparan/go-lib/kafka
- github.com/kuoss/eventrouter/sinks
- github.com/kurnifamili/sarama-test
- github.com/kwilsono/log-collector/server
- github.com/kwins/virgo/export/kafaka
- github.com/kyh0703/kafka
- github.com/kylemcc/jocko/examples/sarama
- github.com/kyleu/libnpn/npnqueue
- github.com/kylin-ops/kafka/test
- github.com/kylinhe/go-plugins/broker/kafka
- github.com/kzh125/go-saga/storage/kafka
- github.com/l-lin/architecture-cheat-sheet/event-sourcing/cat
- github.com/laincheung/bilibili-go-codego/app/admin/main/apm/service
- github.com/laincheung/bilibili-go-codego/app/infra/canal/service/reader
- 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/laincheung/bilibili-go-codego/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/lalifeier/vvgo-mall/app/shop/admin/internal/data
- github.com/lanastasov/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/examples/http_server
- github.com/lanastasov/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/mocks
- github.com/lanastasov/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-consumer
- github.com/lanastasov/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-partitionconsumer
- github.com/lanastasov/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-producer
- github.com/lancelui/snyk_go
- github.com/lanfang/mysql-river/queue
- github.com/lannguyen-c0x12c/dd-trace-go/contrib/Shopify/sarama
- github.com/lateefj/shylock/kafka
- github.com/layasugar/gkafka
- github.com/laydong/toolpkg/db
- github.com/lcl1992421/bilibili/app/admin/main/apm/service
- github.com/lcl1992421/bilibili/app/infra/canal/service/reader
- 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/lcl1992421/bilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/leehinman/beats/filebeat/input/kafka
- github.com/leehinman/beats/libbeat/common/kafka
- github.com/leehinman/beats/libbeat/outputs/kafka
- github.com/leehinman/beats/metricbeat/module/kafka
- github.com/leehinman/beats/metricbeat/module/kafka/consumergroup
- github.com/leehinman/beats/metricbeat/module/kafka/partition
- github.com/leeson1995/gopkg/kafka
- github.com/legionus/kafka-http-proxy
- github.com/lei006/gmqtt-broker/plugins/bridge
- github.com/leicc520/go-core
- github.com/leisheyoufu/golangstudy/kafka/consumer
- github.com/leisheyoufu/golangstudy/kafka/partition
- github.com/leisheyoufu/golangstudy/kafka/partition_seq
- github.com/leisheyoufu/golangstudy/kafka/producer
- github.com/leisheyoufu/golangstudy/kafka/sasl_sarama/consumer
- github.com/leisheyoufu/golangstudy/kafka/sasl_sarama/consumer_group
- github.com/leisheyoufu/golangstudy/kafka/sasl_sarama/metadata
- github.com/leisheyoufu/golangstudy/kafka/sasl_sarama/producer
- github.com/leisheyoufu/golangstudy/kafka/timestampoffset
- github.com/leizhu/incidents_consume
- github.com/lenfree/burrow
- github.com/leoberteck/kafka-demo
- github.com/leocrispindev/streaming-video/fileSentry/internal/consumer
- github.com/leocrispindev/streaming-video/indexer/internal/consumer
- github.com/leocrispindev/streaming-video/stream-go-commons/pkg/broker/admin
- github.com/leocrispindev/streaming-video/stream-go-commons/pkg/broker/consumer
- github.com/leocrispindev/streaming-video/stream-go-commons/pkg/broker/producer
- github.com/leodimano/eventsgateway/app
- github.com/leoluk/vflow/producer
- github.com/levelord1311/grpc-microservices/grpc-user-service/internal/relay/producer/kafka
- github.com/lexiangh/tprof/jaeger/cmd/ingester/app/consumer
- github.com/lexiangh/tprof/jaeger/cmd/ingester/app/consumer/mocks
- github.com/lexiangh/tprof/jaeger/pkg/kafka/auth
- github.com/lexiangh/tprof/jaeger/pkg/kafka/consumer
- github.com/lexiangh/tprof/jaeger/pkg/kafka/producer
- github.com/lexiangh/tprof/jaeger/plugin/storage/kafka
- github.com/lfxnxf/frame/BackendPlatform/golang/kafka
- github.com/lfxnxf/frame/BackendPlatform/kafka/consumergroup
- github.com/lfxnxf/frame/BackendPlatform/kafka/examples/consumergroup
- github.com/lfxnxf/frame/BackendPlatform/kafka/tools/consoleconsumer
- github.com/lfxnxf/frame/BackendPlatform/kafka/tools/consoleproducer
- github.com/lfxnxf/frame/BackendPlatform/kafka/tools/stressproducer
- github.com/lfxnxf/frame/BackendPlatform/kafka/tools/transferoffsets
- github.com/lfxnxf/frame/BackendPlatform/kafka/tools/verifier
- github.com/lharenski/goflow/transport
- github.com/liangjfblue/gpusher/common/push
- github.com/liangreng/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/life123/zp_event_kafka
- github.com/ligang7138/go_rest/storage/kafka
- github.com/lightstaff/go-kafka-example
- github.com/liguoqinjim/go-labs/lab178/lab001/producer
- github.com/lihuacai168/kaf/cmd/kaf
- github.com/lingmiaotech/tonic
- github.com/link-duan/go-plugins/broker/kafka
- github.com/linux-doc/openbilibili-go-common/app/admin/main/apm/service
- github.com/linux-doc/openbilibili-go-common/app/infra/canal/service/reader
- 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/linux-doc/openbilibili-go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/lioroger/subscribe_example/goimpl
- github.com/liquidm/dd-trace-go/contrib/Shopify/sarama
- 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/canal/service/reader
- 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/service/main/dapper/pkg/collect/kafkacollect
- 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/canal/service/reader
- 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/service/main/dapper/pkg/collect/kafkacollect
- github.com/liubin/dd-server/sink
- github.com/liudaved/go-lean-bilibili/app/admin/main/apm/service
- github.com/liudaved/go-lean-bilibili/app/infra/canal/service/reader
- 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/liudaved/go-lean-bilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/liuyp5181/base/mq
- github.com/liuzw3018/basedemo
- github.com/livelybug/foreign-trade/chaincode/hyperledger/fabric/common/viperutil
- github.com/livelybug/foreign-trade/chaincode/hyperledger/fabric/orderer/common/localconfig
- github.com/livelybug/foreign-trade/chaincode/hyperledger/fabric/orderer/consensus/kafka
- github.com/livelybug/foreign-trade/chaincode/hyperledger/fabric/orderer/consensus/kafka/mock
- github.com/lixianliang/hello-go/go-example/kafka
- github.com/liyuhuana/kit/kafka
- github.com/ljjgs/pkg/mq
- github.com/lksunshine/zipkin-go-opentracing
- github.com/lkveltris/notificationpoc/kafka
- github.com/llqgit/go-test/kafka
- github.com/lmx1989219/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/lmx1989219/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/lmx1989219/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/lmx1989219/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/lmx1989219/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/lmx1989219/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/lmx1989219/telegraf/outputs/kafka
- github.com/lmx1989219/telegraf/plugins/kafka_consumer
- github.com/loadimpact/speedboat/stats/kafka
- github.com/loebfly/ezgin/internal/dblite/kafka
- github.com/lomik/zapwriter/kafka
- github.com/loois-io/relay-lib/kafka
- github.com/loopring/relay-lib/kafka
- github.com/lopezator/gizmo/pubsub/kafka
- github.com/lotreal/pdk/kafka
- github.com/lovoo/burrow
- github.com/lpetcana-gpsw/go-workshop/Advanced-Go-Programming-in-7-Days-master/Day-7/4-Message-Queues/easy-issues/application
- github.com/lpetcana-gpsw/go-workshop/Advanced-Go-Programming-in-7-Days-master/Day-7/4-Message-Queues/easy-issues/cmd/user
- github.com/lpetcana-gpsw/go-workshop/Advanced-Go-Programming-in-7-Days-master/Day-7/4-Message-Queues/easy-issues/web
- github.com/lpflpf/kafka-command-line/kafkahelper
- github.com/lqy007700/exchange/common/mq
- github.com/ls-2018/bilibilicode/app/admin/main/apm/service
- github.com/ls-2018/bilibilicode/app/infra/canal/service/reader
- 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/ls-2018/bilibilicode/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/lsgndln/dd-trace-go/contrib/Shopify/sarama
- github.com/lstruman/sarama/examples/http_server
- github.com/lstruman/sarama/examples/sasl_scram_client
- github.com/lstruman/sarama/mocks
- github.com/lstruman/sarama/tools/kafka-console-consumer
- github.com/lstruman/sarama/tools/kafka-console-partitionconsumer
- github.com/lstruman/sarama/tools/kafka-console-producer
- github.com/lstruman/sarama/tools/kafka-producer-performance
- github.com/lsy357/golang/kafka
- github.com/ltick/tick-framework/module/queue
- github.com/lubinszARM/cadvisor/storage/kafka
- github.com/lubinszarm/cadvisor/storage/kafka
- github.com/lubit/klient
- github.com/lubit/sarama/examples/http_server
- github.com/lubit/sarama/examples/sasl_scram_client
- github.com/lubit/sarama/mocks
- github.com/lubit/sarama/tools/kafka-console-consumer
- github.com/lubit/sarama/tools/kafka-console-partitionconsumer
- github.com/lubit/sarama/tools/kafka-console-producer
- github.com/lubit/sarama/tools/kafka-producer-performance
- github.com/lucasmbaia/forcloudy/monitoring/kafka
- github.com/luckybroman5/http-log-reconstructor/k6/stats/kafka
- github.com/luckyweiwei/websocketserver/consumerhandlers/external-handler
- github.com/luckyweiwei/websocketserver/consumerhandlers/external-handler/external-return
- github.com/luckyweiwei/websocketserver/consumerhandlers/external-handler/own-return
- github.com/luckyweiwei/websocketserver/kafka/consumer
- github.com/luckyweiwei/websocketserver/kafka/producer
- github.com/ludashi2020/go-plugins/broker/kafka
- github.com/luffy0223/go-parse-tcp/fetch/impl
- github.com/luhuiguo/fabric/common/viperutil
- github.com/luhuiguo/fabric/orderer/common/localconfig
- github.com/luhuiguo/fabric/orderer/consensus/kafka
- github.com/luhuiguo/fabric/orderer/consensus/kafka/mock
- github.com/luhuiguo/fabric/v2/common/viperutil
- github.com/luhuiguo/fabric/v2/orderer/common/localconfig
- github.com/luhuiguo/fabric/v2/orderer/consensus/kafka
- github.com/luhuiguo/fabric/v2/orderer/consensus/kafka/mock
- github.com/luizbafilho/k6/stats/kafka
- github.com/lukmanlukmin/golib/messaging/kafka
- github.com/lulinloo/nemo/pkg/config
- github.com/luobangkui/go_learn/aboutkafka
- github.com/luobote55/hmq/plugins/bridge
- github.com/luohuahuang/qex/internal/kafka
- github.com/luolr/bilibili_backup/app/admin/main/apm/service
- github.com/luolr/bilibili_backup/app/infra/canal/service/reader
- 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/luolr/bilibili_backup/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/luzejia/logsystem_monitor/pkg/kafka
- github.com/lv093/awesomelib-go/kafka/sarama_client
- github.com/lynxbat/vulcan/kafka
- github.com/lysu/go-saga/storage/kafka
- github.com/lzhz2012/netsim/kafkaCliWrapper
- github.com/lzw5399/go-common-public/library/mq/k
- github.com/m-pavel/firebolt/testutil
- github.com/machenggong1996/golang-learn/kafka
- github.com/maclon-lee/golanglib/lib/mq/kafka
- github.com/mactynow/commonutil/messaging/kafka-sarama
- github.com/madridwan/consumego
- github.com/maestre3d/gluon/gkafka
- github.com/mailgun/kafka-pixy/admin
- github.com/mailgun/kafka-pixy/config
- github.com/mailgun/kafka-pixy/consumer
- github.com/mailgun/kafka-pixy/consumer/consumerimpl
- github.com/mailgun/kafka-pixy/consumer/groupcsm
- github.com/mailgun/kafka-pixy/consumer/msgfetcher
- github.com/mailgun/kafka-pixy/logging
- github.com/mailgun/kafka-pixy/mapper
- github.com/mailgun/kafka-pixy/offsetmgr
- github.com/mailgun/kafka-pixy/producer
- github.com/mailgun/kafka-pixy/proxy
- github.com/mailgun/kafka-pixy/server/grpcsrv
- github.com/mailgun/kafka-pixy/server/httpsrv
- github.com/mailgun/kafka-pixy/testhelpers/kafkahelper
- github.com/makiko-fly/peterstd/datasource
- github.com/mamalmaleki/go-r-kafka-ec/internal/service
- github.com/mancubus77/bigmuddy-network-telemetry-pipeline
- github.com/mandarjog/zipkin-go-opentracing
- github.com/maomaochina/myfabric/orderer
- github.com/maomaochina/myfabric/orderer/common/localconfig
- github.com/maomaochina/myfabric/orderer/consensus/kafka
- github.com/maomaochina/myfabric/orderer/consensus/kafka/mock
- github.com/maomaochina/myfabric/orderer/kafka
- github.com/maomaochina/myfabric/orderer/localconfig
- github.com/mapgoo-lab/atreus/pkg/queue/databus
- github.com/maratori/training-async-architecture/infra
- github.com/marc-gr/beats/filebeat/input/kafka
- github.com/marc-gr/beats/libbeat/common/kafka
- github.com/marc-gr/beats/libbeat/outputs/kafka
- github.com/marc-gr/beats/metricbeat/module/kafka
- github.com/marc-gr/beats/metricbeat/module/kafka/consumergroup
- github.com/marc-gr/beats/metricbeat/module/kafka/partition
- github.com/marcantoine-bibeau/zipkin-go/reporter/kafka
- github.com/marcinwyszynski/terraform-provider-kafka/topic
- github.com/marcotroisi/gizmo/pubsub
- github.com/mardukbp/k6/stats/kafka
- github.com/marekgalovic/kafka-mysql
- github.com/marianogappa/bookie
- github.com/marsccm/sarama/examples/http_server
- github.com/marsccm/sarama/examples/sasl_scram_client
- github.com/marsccm/sarama/mocks
- github.com/marsccm/sarama/tools/kafka-console-consumer
- github.com/marsccm/sarama/tools/kafka-console-partitionconsumer
- github.com/marsccm/sarama/tools/kafka-console-producer
- github.com/marsccm/sarama/tools/kafka-producer-performance
- github.com/marshhu/go-learn/day11/kafka
- github.com/marshyski/cadvisor/storage/kafka
- github.com/marsmay/golib/kafka
- github.com/marv2097/beats/filebeat/input/kafka
- github.com/marv2097/beats/libbeat/common/kafka
- github.com/marv2097/beats/libbeat/outputs/kafka
- github.com/marv2097/beats/metricbeat/module/kafka
- github.com/marv2097/beats/metricbeat/module/kafka/consumergroup
- github.com/marv2097/beats/metricbeat/module/kafka/partition
- github.com/marwan-at-work/gizmo/pubsub/kafka
- github.com/marzagao/gizmo/pubsub/kafka
- github.com/maskwang/pholcus/common/kafka
- github.com/massimo-gollo/benchy/pkg/kafka
- github.com/matcornic/cadvisor/storage/kafka
- github.com/mateusmacedo/go-bff/cmd/watermill/kafka
- github.com/mateuszzawisza/burrow
- github.com/matrixvirus/bilibili_20190421/app/admin/main/apm/service
- github.com/matrixvirus/bilibili_20190421/app/infra/canal/service/reader
- 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/matrixvirus/bilibili_20190421/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/matt-christiansen-exa/kafka-operator/pkg/kafkaclient
- github.com/matthewjsalerno/goflow/backends/kafka
- github.com/matthewmcneely/graphql-go-tools/v2/examples/kafka_pubsub
- github.com/mattkanwisher/microservices-book-code/kafka
- github.com/mattmoor/eventing-contrib/kafka/channel/pkg/controller/channel
- github.com/mattmoor/eventing-contrib/kafka/channel/pkg/dispatcher
- github.com/mattmoor/eventing-contrib/kafka/channel/pkg/reconciler/controller
- github.com/mattmoor/eventing-contrib/kafka/channel/pkg/reconciler/controller/resources
- github.com/mattmoor/eventing-contrib/kafka/source/pkg/adapter
- github.com/matzew/kafka-receiver/cmd/receiver
- github.com/maxchen299/my-code/app/admin/main/apm/service
- github.com/maximepeschard/kafkadog/client
- github.com/maxsuelmarinho/golang-my-events-example/events-service
- github.com/maxthomas/kafka-pixy/admin
- github.com/maxthomas/kafka-pixy/config
- github.com/maxthomas/kafka-pixy/consumer
- github.com/maxthomas/kafka-pixy/consumer/consumerimpl
- github.com/maxthomas/kafka-pixy/consumer/groupcsm
- github.com/maxthomas/kafka-pixy/consumer/msgfetcher
- github.com/maxthomas/kafka-pixy/logging
- github.com/maxthomas/kafka-pixy/mapper
- github.com/maxthomas/kafka-pixy/offsetmgr
- github.com/maxthomas/kafka-pixy/producer
- github.com/maxthomas/kafka-pixy/proxy
- github.com/maxthomas/kafka-pixy/server/grpcsrv
- github.com/maxthomas/kafka-pixy/server/httpsrv
- github.com/maxthomas/kafka-pixy/testhelpers/kafkahelper
- github.com/mbeacom/cadvisor/storage/kafka
- github.com/mbergo/kafka-topics/src
- github.com/megaease/consuldemo/cmd/http2kafka
- github.com/megaease/easegress/pkg/filter/kafka
- github.com/megaease/easegress/pkg/filter/kafkabackend
- github.com/megaease/easegress/pkg/object/easemonitormetrics
- github.com/megaease/easegress/v2/pkg/filters/kafka
- github.com/megaease/easegress/v2/pkg/filters/kafkabackend
- github.com/megaease/easegress/v2/pkg/object/easemonitormetrics
- github.com/meixinyun/cadvisor/storage/kafka
- github.com/melkor/test-thrift/server
- github.com/menderesk/beats/filebeat/input/kafka
- github.com/menderesk/beats/libbeat/common/kafka
- github.com/menderesk/beats/libbeat/outputs/kafka
- github.com/menderesk/beats/metricbeat/module/kafka
- github.com/menderesk/beats/metricbeat/module/kafka/consumergroup
- github.com/menderesk/beats/metricbeat/module/kafka/partition
- github.com/mengbaby/go-common/app/admin/main/apm/service
- github.com/mengbaby/go-common/app/infra/canal/service/reader
- 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/mengbaby/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/mengjinglei/logkit-1/reader
- github.com/menyasosali/mts/internal/service/kafka
- github.com/meongbego/bgin/app/moduls/package
- github.com/meredithlind/goheroku
- github.com/meroxa/kafka-pixy/admin
- github.com/meroxa/kafka-pixy/config
- github.com/meroxa/kafka-pixy/consumer
- github.com/meroxa/kafka-pixy/consumer/consumerimpl
- github.com/meroxa/kafka-pixy/consumer/groupcsm
- github.com/meroxa/kafka-pixy/consumer/msgfetcher
- github.com/meroxa/kafka-pixy/logging
- github.com/meroxa/kafka-pixy/mapper
- github.com/meroxa/kafka-pixy/offsetmgr
- github.com/meroxa/kafka-pixy/producer
- github.com/meroxa/kafka-pixy/proxy
- github.com/meroxa/kafka-pixy/server/grpcsrv
- github.com/meroxa/kafka-pixy/server/httpsrv
- github.com/meroxa/kafka-pixy/testhelpers/kafkahelper
- github.com/metinagaoglu/go-network-packet-listener/stream
- github.com/metno/productshredder
- github.com/mfateev/cadence/common/messaging
- github.com/mfournier/cadvisor/storage/kafka
- github.com/mgcicd/cicd-core/logs
- github.com/mhausenblas/dnpipes
- github.com/mhfinans/health-go/checks/kafka
- github.com/micahhausler/cadvisor/storage/kafka
- github.com/michelaquino/gizmo/pubsub/kafka
- github.com/micor6588/logcollection/LogAgent/kafka
- github.com/microhq/go-plugins/broker/kafka
- github.com/microsoft/presidio/pkg/stream/kafka
- github.com/midnightexigent/SaramaExt
- github.com/miketonks/go_kafka_client
- github.com/miketonks/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/miketonks/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/miketonks/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/miketonks/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/miketonks/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/mikkeloscar/cadvisor/storage/kafka
- github.com/mikudos/mikudos-schedule/broker
- github.com/mileschao/go-plugins/broker/kafka
- github.com/mindprince/cadvisor/storage/kafka
- github.com/mineubob/goflow/transport
- github.com/minhajuddinkhan/kafka-client
- github.com/minhvh93/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/mintel/eventrouter/sinks
- github.com/misphix/kafka-producer
- github.com/mistsys/sarama-consumer
- github.com/mistsys/sarama-consumer/offsets
- github.com/mistsys/sarama-consumer/roundrobin
- github.com/mistsys/sarama-consumer/stable
- github.com/mistsys/sarama-consumer/v3
- github.com/mistsys/sarama-consumer/v3/offsets
- github.com/mistsys/sarama-consumer/v3/roundrobin
- github.com/mistsys/sarama-consumer/v3/stable
- github.com/miweiweigithub/begin-gobili/app/admin/main/apm/service
- github.com/miweiweigithub/begin-gobili/app/infra/canal/service/reader
- 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/miweiweigithub/begin-gobili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/mixedmessages/gizmo/pubsub/kafka
- github.com/mixton/tsdb-gw/publish/kafka
- github.com/mjasion/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/mjasion/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/mjasion/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/mjasion/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/mjasion/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/mjasion/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/mjasion/telegraf/outputs/kafka
- github.com/mjasion/telegraf/plugins/kafka_consumer
- github.com/mjmyaseer/golang-kafka-publisher/kafka-publisher/global
- github.com/mjolnir42/erebos
- github.com/mjolnir42/privprod/internal/privacy
- github.com/ml444/glog2kafka
- github.com/mmadfox/esp/internal/kafka
- github.com/modern-apis-architecture/coinsure-cards/internal/message/kafka
- github.com/momo247/go-common/app/admin/main/apm/service
- github.com/momo247/go-common/app/infra/canal/service/reader
- 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/momo247/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/monojitbarua/go-avro-kafka/avro
- github.com/moodleexpert/http2kafka
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/Card
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/Employee
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/Merchant
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/Outlet
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/Program
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/Reward
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/SendEmail
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/SpecialProgram
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/TransactionMerchant
- github.com/moonlay/loyalti-go-echo/src/api/apiKafka/Voucher
- github.com/moonlay/loyalti-go-echo/src/api/host/Config
- github.com/moonlay/loyalti-go-echo/src/api/host/consumer
- github.com/moonlay/loyalti-go-echo/src/api/host/producer
- github.com/moooofly/cadvisor/storage/kafka
- github.com/morganfly/bilibili/app/admin/main/apm/service
- github.com/morganfly/bilibili/app/infra/canal/service/reader
- 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/morganfly/bilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/mouminoux/kafkacli
- github.com/mous77/go/mq
- github.com/mover-code/micro-util/mq
- github.com/movio/go-kafka/partitioner
- github.com/moyuanhui/go-dev/day11/kafka
- github.com/mozilla-services/data-pipeline/heka/plugins/kafkaconsumergroup
- github.com/mqiqe/prometheus-sarama-adapter
- github.com/mrlyc/sarama-demo/sarama
- github.com/mrnonz/logspout-kafka
- github.com/msales/archive-transporter/kafka
- github.com/msales/double-team/streaming
- github.com/msales/kage/kafka
- github.com/msales/streams/example/kafka
- github.com/msales/streams/kafka
- github.com/msales/streams/v2/example/kafka
- github.com/msales/streams/v2/kafka
- github.com/msales/streams/v4/example/kafka
- github.com/msales/streams/v4/kafka
- github.com/msales/streams/v6/example/kafka
- github.com/msales/streams/v6/kafka
- github.com/msales/transporter/kafka
- github.com/mstoykov/k6/stats/kafka
- github.com/mujiansu/openbilibili-common/app/admin/main/apm/service
- github.com/mujiansu/openbilibili-common/app/infra/canal/service/reader
- 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/mujiansu/openbilibili-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/mutou1225/go-frame/implements/kafka
- github.com/muyong88/gofront/src/kafka
- github.com/mweagle/gizmo/pubsub/kafka
- github.com/mxlxm/exporters/exporter/kafka
- github.com/mxlxm/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/mxlxm/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/mxlxm/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/mxlxm/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/mxlxm/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/mxlxm/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/mxlxm/telegraf/outputs/kafka
- github.com/mxlxm/telegraf/plugins/kafka_consumer
- github.com/my6889/k8s.yaml/heapster/common/kafka
- github.com/mybee/goreplay
- github.com/myboran/openim/pkg/common/kafka
- github.com/mycroft/bookish-couscous/generator
- github.com/myksc/ksc-base/golib/kafka
- github.com/myodc/go-plugins/broker/kafka
- github.com/mytokenio/go/metrics
- github.com/mywrap/kafka
- github.com/myzhan/goreplay
- github.com/namreg/cadvisor/storage/kafka
- github.com/nani231/go/src/Kafka
- github.com/nanoservice/core-fanout/fanout/fanout
- github.com/narqo/test-kafka
- github.com/narslan/gleam/plugins/kafka
- github.com/nasermirzaei89/go-plugins/broker/kafka
- github.com/nash-io/jocko/_examples/sarama
- github.com/naveego/api/pipeline/subscriber
- github.com/navychi/zipkin-go/reporter/kafka
- github.com/nbit99/open_base/major
- github.com/nds15763/feed/producer/service/kafka
- github.com/neilw/jocko/examples/sarama
- github.com/nemanjamikic/zipkin-go/reporter/kafka
- github.com/neohe/prom-kafka
- github.com/neoxue/opentracing
- github.com/neptune-networks/flow-exporter/internal/consumer
- github.com/netdetpla/ndp-scheduler/src
- github.com/newgate8820/commonlib/dbcommon
- github.com/newhorizon-tech-vn/tracing-example/pkg/kafka
- github.com/newnius/yao-scheduler/src
- github.com/newrelic-forks/kafka/consumergroup
- github.com/newrelic-forks/kafka/examples/consumergroup
- github.com/newrelic-forks/kafka/tools/consoleconsumer
- github.com/newrelic-forks/kafka/tools/consoleproducer
- github.com/newrelic-forks/kafka/tools/stressproducer
- github.com/newrelic-forks/kafka/tools/transferoffsets
- github.com/newrelic-forks/kafka/tools/verifier
- github.com/ngreatorex/goflow/transport
- github.com/nickchappell/heka/plugins/kafka
- github.com/nicky-cage/sports-game-cron-v2/src/libs
- github.com/nicky-cage/sports-game-v2/src/controllers
- github.com/niedbalski/cadvisor/storage/kafka
- github.com/nikgalushko/kafka-drivers-competition/sarama
- github.com/nikhil-thomas/technik-dojo/cloud-native-programming-with-golang/chp04/src/lib/helper/kafka
- github.com/nikhilpnik/http2kafka
- github.com/nikp359/ates/internal/estream
- github.com/nikugame/public/mq
- github.com/nikunjt0/sendrecvgoroutine
- github.com/ninadingole/kafka-playground/go
- github.com/ninjatux/example-kafka-producer
- github.com/nipuntalukdar/kafka_consumer_exporter
- github.com/niteshjain/mconsumer
- github.com/nitishm/go-micro-framework/microservice/server
- github.com/nivista/steady/elastic_consumer
- github.com/nivista/steady/elastic_consumer/consumer
- github.com/nivista/steady/frontend
- github.com/nivista/steady/frontend/queue
- github.com/nivista/steady/kafkareader
- github.com/nivista/steady/kafkareader/consumer
- github.com/nivista/steady/runtimers
- github.com/nivista/steady/runtimers/consumer
- github.com/nivista/steady/runtimers/coordinator
- github.com/niwho/utils
- github.com/nj-leegern/goprophet/mq/kafka
- github.com/nkatsaros/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/nkatsaros/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/nkatsaros/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/nkatsaros/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/nkatsaros/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/nkatsaros/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/nkatsaros/telegraf/outputs/kafka
- github.com/nkatsaros/telegraf/plugins/kafka_consumer
- github.com/noahgoldman/veneur/sinks/kafka
- github.com/nosinovacao/floki
- github.com/nowfred/dd-trace-go/contrib/Shopify/sarama
- github.com/npateriya/logspout
- github.com/nraythz/cloud-native-with-golang/Chapter04/src/bookingservice
- github.com/nraythz/cloud-native-with-golang/Chapter04/src/eventservice
- github.com/nraythz/cloud-native-with-golang/Chapter04/src/lib/helper/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter04/src/lib/msgqueue/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter05/src/bookingservice
- github.com/nraythz/cloud-native-with-golang/Chapter05/src/eventservice
- github.com/nraythz/cloud-native-with-golang/Chapter05/src/lib/helper/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter05/src/lib/msgqueue/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter06/src/bookingservice
- github.com/nraythz/cloud-native-with-golang/Chapter06/src/eventservice
- github.com/nraythz/cloud-native-with-golang/Chapter06/src/lib/helper/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter06/src/lib/msgqueue/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter09/src/bookingservice
- github.com/nraythz/cloud-native-with-golang/Chapter09/src/eventservice
- github.com/nraythz/cloud-native-with-golang/Chapter09/src/lib/helper/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter09/src/lib/msgqueue/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter10/src/bookingservice
- github.com/nraythz/cloud-native-with-golang/Chapter10/src/eventservice
- github.com/nraythz/cloud-native-with-golang/Chapter10/src/lib/helper/kafka
- github.com/nraythz/cloud-native-with-golang/Chapter10/src/lib/msgqueue/kafka
- github.com/nrwiersma/kage/kafka
- github.com/nstankov-bg/oaievals-collector/pkg/kafka
- github.com/nuokaqiao/omata
- github.com/nzubarev122/inserter
- github.com/obase/kafka
- github.com/obgnail/audit-log/broker
- github.com/objectundefined/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/odinuge/cadvisor/storage/kafka
- github.com/oemdaro/mqtt-microservices/data-service/workque
- github.com/ofey404/experiments/cloud/volcengine/log-as-kafka
- github.com/offlinebrain/cqrs-bank-example/command-app/infrastructure/kafka
- github.com/ofiriro3/beats-1/filebeat/input/kafka
- github.com/ofiriro3/beats-1/libbeat/common/kafka
- github.com/ofiriro3/beats-1/libbeat/outputs/kafka
- github.com/ofiriro3/beats-1/metricbeat/module/kafka
- github.com/ofiriro3/beats-1/metricbeat/module/kafka/consumergroup
- github.com/ofiriro3/beats-1/metricbeat/module/kafka/partition
- github.com/ognitio/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/ognitio/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/ognitio/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/ognitio/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/ognitio/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/ognitio/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/ognitio/telegraf/outputs/kafka
- github.com/ognitio/telegraf/plugins/kafka_consumer
- github.com/ohdat/app/kafka
- github.com/ohsu-comp-bio/funnel/events
- github.com/olaola-chat/bc-library/kafka
- github.com/oliveagle/funnel/outputs
- github.com/oliver-zhang/kafka-data-transfer/transfer/bj
- github.com/omnibuildplatform/omni-repository/common/messages
- github.com/omniitgmbh/beats/filebeat/input/kafka
- github.com/omniitgmbh/beats/libbeat/common/kafka
- github.com/omniitgmbh/beats/libbeat/outputs/kafka
- github.com/omniitgmbh/beats/metricbeat/module/kafka
- github.com/omniitgmbh/beats/metricbeat/module/kafka/consumergroup
- github.com/omniitgmbh/beats/metricbeat/module/kafka/partition
- github.com/omnition/zipkin-go/reporter/kafka
- github.com/omorfarukmashuk/tm-provision/kafka
- github.com/onepiecelover/cadvisor/storage/kafka
- github.com/onosproject/onos-lib-go/pkg/logging
- github.com/onrik/go-plugins/broker/kafka
- github.com/ooesili/kt
- github.com/oom-killer/fakemetrics_ng/out
- github.com/ooojerryooo/fabric-support-selfbuild-scc/common/viperutil
- github.com/ooojerryooo/fabric-support-selfbuild-scc/orderer/common/localconfig
- github.com/ooojerryooo/fabric-support-selfbuild-scc/orderer/consensus/kafka
- github.com/ooojerryooo/fabric-support-selfbuild-scc/orderer/consensus/kafka/mock
- github.com/oopcode/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/examples/http_server
- github.com/oopcode/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/mocks
- github.com/oopcode/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-consumer
- github.com/oopcode/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-partitionconsumer
- github.com/oopcode/gollum/Godeps/_workspace/src/gopkg.in/Shopify/sarama.v1/tools/kafka-console-producer
- github.com/oopschen/cadvisor/storage/kafka
- github.com/open-micro/plugins/v5/broker/kafka
- github.com/open-scrm/open-scrm/internal/event/publish
- github.com/opencord/opendevice-manager/pkg/msgbus
- github.com/opencord/voltctl/internal/pkg/commands
- github.com/opencord/voltha-go/kafka
- github.com/opencord/voltha-northbound-bbf-adapter/internal/clients
- github.com/openflagr/flagr/pkg/handler
- github.com/openmock/openmock
- github.com/openrelayxyz/xplugeth/plugins/producer
- github.com/openshift/eventrouter/sinks
- github.com/opensourceways/community-robot-lib/kafka
- github.com/opentable/sous/util/logging
- github.com/opsgenie/kubernetes-event-exporter/pkg/sinks
- github.com/orestisfl/beats/filebeat/input/kafka
- github.com/orestisfl/beats/libbeat/common/kafka
- github.com/orestisfl/beats/libbeat/outputs/kafka
- github.com/orestisfl/beats/metricbeat/module/kafka
- github.com/orestisfl/beats/metricbeat/module/kafka/consumergroup
- github.com/orestisfl/beats/metricbeat/module/kafka/partition
- github.com/origoss/beats/filebeat/input/kafka
- github.com/origoss/beats/libbeat/common/kafka
- github.com/origoss/beats/libbeat/outputs/kafka
- github.com/origoss/beats/metricbeat/module/kafka
- github.com/origoss/beats/metricbeat/module/kafka/consumergroup
- github.com/origoss/beats/metricbeat/module/kafka/partition
- github.com/orisano/cadvisor/storage/kafka
- github.com/oruen/kafka-consumer-lag
- github.com/osswangxining/terraform-provider-kafka/kafka
- github.com/ostafen/hermes/internal/processor
- github.com/otoolep/syslog-gollector/output
- github.com/otterize/otterize-cli/src/pkg/kafkamapper
- github.com/outprog/kadb
- github.com/ovat1975/go-plugins/broker/kafka
- github.com/ovh/tat/api/hook
- github.com/ownlocal/heka/plugins/kafka
- github.com/oyjjpp/blog/service/queue
- github.com/ozoncp/ocp-calendar-api/internal/app/api
- github.com/ozoncp/ocp-contact-api/internal/producer
- github.com/ozoncp/ocp-course-api/internal/event_producer
- github.com/ozoncp/ocp-howto-api/internal/producer
- github.com/ozoncp/ocp-meeting-api/internal/producer
- github.com/ozoncp/ocp-problem-api/internal/repo
- github.com/ozoncp/ocp-question-api/internal/producer
- github.com/ozoncp/ocp-remind-api/internal/producer
- github.com/ozoncp/ocp-requirement-api/internal/kafka
- github.com/ozoncp/ocp-resource-api/internal/producer
- github.com/ozoncp/ocp-role-api/internal/producer
- github.com/ozoncp/ocp-runner-api/internal/broker
- github.com/ozoncp/ocp-skill-api/internal/producer
- github.com/ozoncp/ocp-snippet-api/internal/producer
- github.com/ozoncp/ocp-suggestion-api/internal/producer
- github.com/ozoncp/ocp-survey-api/internal/producer
- github.com/ozoncp/ocp-team-api/internal/kafka
- github.com/ozoncp/ocp-tenant-api/internal/producer
- github.com/ozoncp/ocp-timeline-api/internal/broker
- github.com/ozoncp/ocp-user-api/internal/producer
- github.com/ozoncp/ocp-vacancy-api/internal/producer
- github.com/ozonmp/bss-equipment-request-api/internal/retranslator/sender
- github.com/ozonmp/com-message-api/internal/app/sender
- github.com/ozonmp/com-review-api/internal/retranslator/sender
- github.com/ozonmp/est-water-api/internal/app/sender
- github.com/ozonmp/trv-railway-station-api/internal/app/sender
- github.com/ozonmp/trv-ticket-api/internal/app/sender
- github.com/ozonva/ova-entertainment-api/internal/kafka
- github.com/ozonva/ova-game-api/internal/kafka
- github.com/ozonva/ova-joke-api/internal/producer
- github.com/ozonva/ova-journey-api/internal/kafka
- github.com/ozonva/ova-link-api/internal/kafka
- github.com/ozonva/ova-obligation-api/pkg/ova-obligation-producer
- github.com/ozonva/ova-place-api/internal/producer
- github.com/ozonva/ova-plan-api/internal/kafka
- github.com/ozonva/ova-purchase-api/internal/kafka
- github.com/ozonva/ova-service-api/internal/infrastructure/kafka
- github.com/ozonva/ova-song-api/internal/broker
- github.com/packetbeat/packetbeat/filebeat/input/kafka
- github.com/packetbeat/packetbeat/libbeat/common/kafka
- github.com/packetbeat/packetbeat/libbeat/outputs/kafka
- github.com/packetbeat/packetbeat/metricbeat/module/kafka
- github.com/packetbeat/packetbeat/metricbeat/module/kafka/consumergroup
- github.com/packetbeat/packetbeat/metricbeat/module/kafka/partition
- github.com/packethost/goflow/transport
- github.com/packtpublishing/advanced-go-programming-in-7-days/Day-7/4-Message-Queues/easy-issues/application
- github.com/packtpublishing/advanced-go-programming-in-7-days/Day-7/4-Message-Queues/easy-issues/cmd/user
- github.com/packtpublishing/advanced-go-programming-in-7-days/Day-7/4-Message-Queues/easy-issues/web
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter04/src/bookingservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter04/src/eventservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter04/src/lib/helper/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter04/src/lib/msgqueue/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter05/src/bookingservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter05/src/eventservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter05/src/lib/helper/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter05/src/lib/msgqueue/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter06/src/bookingservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter06/src/eventservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter06/src/lib/helper/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter06/src/lib/msgqueue/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter09/src/bookingservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter09/src/eventservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter09/src/lib/helper/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter09/src/lib/msgqueue/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter10/src/bookingservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter10/src/eventservice
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter10/src/lib/helper/kafka
- github.com/packtpublishing/cloud-native-programming-with-golang/Chapter10/src/lib/msgqueue/kafka
- github.com/palchukovsky/rprt-service/rprt
- github.com/pangj520/hello/library/mq
- github.com/panhaulin/go-cloud-fileserver/v1-gin/mq/kafka
- github.com/panyaxbo/libs/saramax
- github.com/paralin/cadvisor/storage/kafka
- github.com/partitio/go-plugins/broker/kafka
- github.com/pasalab/yao/Liquid-scheduler/src
- github.com/pathbox/learning-go/src/kafka_sarama/consumer_group
- github.com/patrobinson/go-fish/input
- github.com/paubox/paubox-flagr/pkg/handler
- github.com/paulcapestany/carbon-relay-ng/route
- github.com/paulusrobin/leaf-utilities/messageQueue/integrations/kafka
- github.com/pauluswi/gopkg-logger
- github.com/pavanmt/otterize-cli/src/pkg/kafkamapper
- github.com/pborgesEdgeX/Video-RTSP-Streaming-/producer
- github.com/pborgesedgex/video-rtsp-streaming-/producer
- github.com/pceric/kafka-offset-lag-for-prometheus
- github.com/pckushan/sarama-producer-consumer/consumer
- github.com/pckushan/sarama-producer-consumer/consumer-group
- github.com/pckushan/sarama-producer-consumer/consumer-group-1-instance-1
- github.com/pckushan/sarama-producer-consumer/consumer-group-1-instance-2
- github.com/pckushan/sarama-producer-consumer/producer
- github.com/pckushan/sarama-producer-consumer/producer-async
- github.com/pd/kt
- github.com/pecigonzalo/cadvisor/storage/kafka
- github.com/pellared/dd-sarama-deadlock-example
- github.com/pepese/golang-CleanArchitecture/app/infrastructure/server
- github.com/persistenceOne/persistenceBridge/application/commands
- github.com/persistenceOne/persistenceBridge/application/configuration
- github.com/persistenceOne/persistenceBridge/application/constants
- github.com/persistenceOne/persistenceBridge/ethereum
- github.com/persistenceOne/persistenceBridge/kafka/handler
- github.com/persistenceOne/persistenceBridge/kafka/utils
- github.com/persistenceOne/persistenceBridge/tendermint
- github.com/pestanko/go-kafka-learning/services/simple-producer
- github.com/peterepsteen/hey-kafka/pkg/avroproducer
- github.com/petr-korobeinikov/seeder/seeder/internal/kafka
- github.com/pgmsoul/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/phensley/nuclio/pkg/processor/eventsource/kafka
- github.com/philips/cadvisor/storage/kafka
- github.com/phillweston/openbilibili/app/admin/main/apm/service
- github.com/phillweston/openbilibili/app/infra/canal/service/reader
- 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/phillweston/openbilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/pholcus-go/pholcus/common/kafka
- github.com/pickme-go/k-stream/admin
- github.com/pickme-go/k-stream/consumer
- github.com/pickme-go/k-stream/data
- github.com/pickme-go/k-stream/k-stream
- github.com/pickme-go/k-stream/k-stream/context
- github.com/pickme-go/k-stream/k-stream/offsets
- github.com/pickme-go/k-stream/k-stream/store
- github.com/pickme-go/k-stream/producer
- github.com/pickme-go/k-stream/v2/admin
- github.com/pickme-go/k-stream/v2/consumer
- github.com/pickme-go/k-stream/v2/k-stream
- github.com/pickme-go/k-stream/v2/k-stream/offsets
- github.com/pickme-go/k-stream/v2/k-stream/store
- github.com/pickme-go/k-stream/v2/producer
- github.com/piclemx/kafka_exporter
- github.com/pilosa/pdk/kafka
- github.com/piovani/script_kafka_mass/cmd
- github.com/pipizhang/goreplay
- github.com/pismo/zipkin-go-opentracing
- github.com/pivotal-cf-experimental/kafka-example-service-adapter/cmd/kafka-client
- github.com/pkbhowmick/go-kafka-demo
- github.com/pkujohnson/solar/std/ec/kafka
- github.com/plexsec/utils/log/agent
- github.com/plgd-dev/cqrs/eventbus/kafka
- github.com/pluto-tv/furan/lib/kafka
- github.com/pmorie/cadvisor/storage/kafka
- github.com/popsa-hq/go-plugins/broker/kafka
- github.com/posener/zipkin-go-opentracing
- github.com/ppruitt-sg/support-billing/kafka
- github.com/pradeepnnv/golang-training/kafka-sarama/producer
- github.com/pradeepp28/eh-kafka
- github.com/prc123/gotest/day2/logagent/kafka
- github.com/prerito/cadvisor/storage/kafka
- github.com/probaaho/quarks-network/node-poc/go/src/github.com/hyperledger/fabric/common/viperutil
- github.com/program-world-labs/DDDGo/pkg/message
- github.com/projectdiscovery/proxify/pkg/logger/kafka
- github.com/projectlukman/lib-go/messaging/kafka
- github.com/projectriff-archive/function-sidecar/cmd
- github.com/promacanthus/design-patterns/interface-abstract
- github.com/protocolone/go-plugins/broker/kafka
- github.com/psoKnight/go-common/kafka
- github.com/psurana-flextrade/beats/filebeat/input/kafka
- github.com/psurana-flextrade/beats/libbeat/common/kafka
- github.com/psurana-flextrade/beats/libbeat/outputs/kafka
- github.com/psurana-flextrade/beats/metricbeat/module/kafka
- github.com/psurana-flextrade/beats/metricbeat/module/kafka/consumergroup
- github.com/psurana-flextrade/beats/metricbeat/module/kafka/partition
- github.com/pupimvictor/gizmo/pubsub/kafka
- github.com/purposeinplay/go-commons/pubsub/kafkashopifysarama
- github.com/pvcy/presidio/pkg/stream/kafka
- github.com/pytimer/beats/filebeat/input/kafka
- github.com/pytimer/beats/libbeat/common/kafka
- github.com/pytimer/beats/libbeat/outputs/kafka
- github.com/pytimer/beats/metricbeat/module/kafka
- github.com/pytimer/beats/metricbeat/module/kafka/consumergroup
- github.com/pytimer/beats/metricbeat/module/kafka/partition
- github.com/q1angch0u/bilibili/go-common/app/admin/main/apm/service
- github.com/q1angch0u/bilibili/go-common/app/infra/canal/service/reader
- 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/q1angch0u/bilibili/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/qclaogui/lg
- github.com/qianyan/sarama/mocks
- github.com/qida/gohp/logx
- github.com/qingsong-he/some/golang/t_kafka
- github.com/qiuyi21/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/qjpcpu/common/kafkautil
- github.com/qmsk/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/qmsk/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/qmsk/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/qmsk/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/qmsk/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/qmsk/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/qmsk/telegraf/outputs/kafka
- github.com/qmsk/telegraf/plugins/kafka_consumer
- github.com/questx-lab/backend/pkg/kafka
- github.com/quesurifn/tile38/pkg/endpoint
- github.com/quexer/go-plugins/broker/kafka
- github.com/qutoutiao/zipkin-go/reporter/kafka
- github.com/quwan-sre/observability-go-contrib/metrics/sarama
- github.com/qwqteam/bilibili-backup/app/admin/main/apm/service
- github.com/qwqteam/bilibili-backup/app/infra/canal/service/reader
- 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/qwqteam/bilibili-backup/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/qypt15/fmq/plugins/bridge
- github.com/r2d2-ai/contrib/trigger/kafka
- github.com/radiantrfid/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/Card
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/Employee
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/Merchant
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/Outlet
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/Program
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/SpecialProgram
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/TransactionMerchant
- github.com/radyatamaa/loyalti-go-echo/src/api/apiKafka/Voucher
- github.com/radyatamaa/loyalti-go-echo/src/api/host/Config
- github.com/radyatamaa/loyalti-go-echo/src/api/host/consumer
- github.com/radyatamaa/loyalti-go-echo/src/api/host/producer
- github.com/rahul-kr/golang-explore
- github.com/rainbowlee/doggy/stat
- github.com/raintank/fakemetrics_ng/out
- github.com/raintank/metrictank/cmd/metrictank
- github.com/raintank/metrictank/cmd/mt-fakemetrics/out
- github.com/raintank/metrictank/cmd/mt-fakemetrics/out/kafkamdm
- github.com/raintank/metrictank/input/kafkamdm
- github.com/raintank/metrictank/kafka
- github.com/raintank/metrictank/mdata/notifierKafka
- github.com/raintank/metrictank/publish/kafka
- github.com/raintank/raintank-metric/cmd/metrictank
- github.com/raintank/raintank-metric/cmd/mt-fakemetrics/out
- github.com/raintank/raintank-metric/cmd/mt-fakemetrics/out/kafkamdm
- github.com/raintank/raintank-metric/input/kafkamdm
- github.com/raintank/raintank-metric/kafka
- github.com/raintank/raintank-metric/mdata/notifierKafka
- github.com/raintank/raintank-metric/publish/kafka
- github.com/raintank/tsdb-gw/publish/kafka
- github.com/rajdhamsaniya/consensus/orderer/kafka
- github.com/rajeevtemani/goreplay
- github.com/rajtpd/telemetry_workshop/environment/pipeline
- github.com/rajveermalviya/unifrost/drivers/kafkadriver
- 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_eventdenormalizer
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_eventdenormalizer_partitioned
- github.com/rakamoviz/kincirair/cmd/kafkasubscriber
- github.com/rakanixu/go-plugins/broker/kafka
- github.com/rakutentech/kafka-firehose-nozzle
- github.com/ramsessw/user-api-microservice/notifier
- github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/multikcat/sarama/consumer
- github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/multikcat/sarama/producer
- github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/sarama/consumer
- github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/sarama/producer
- github.com/random-liu/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/random-liu/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/random-liu/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/random-liu/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/random-liu/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/random-liu/cadvisor/storage/kafka
- github.com/ranjit-git/proxify/pkg/logger/kafka
- github.com/raskchanky/bench/requester
- github.com/raymasson/kafka-elasticsearch-connector
- github.com/raytung/cadvisor/storage/kafka
- github.com/rcsavage/cadvisor/storage/kafka
- github.com/reAsOn2010/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/reactivejson/users-svc/internal/notifier
- github.com/reason2010/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/rebay1982/gkafka
- github.com/rebrainme/yandex-cloud-events-api
- github.com/reddit/baseplate.go/kafkabp
- github.com/relax-space/go-api-producer/adapters
- github.com/rengawm/kafka/consumergroup
- github.com/rengawm/kafka/examples/consumergroup
- github.com/rengawm/kafka/tools/consoleconsumer
- github.com/rengawm/kafka/tools/consoleproducer
- github.com/rengawm/kafka/tools/stressproducer
- github.com/rengawm/kafka/tools/transferoffsets
- github.com/rengawm/kafka/tools/verifier
- github.com/resmoio/kubernetes-event-exporter/pkg/sinks
- github.com/retzkek/gracc-collector
- github.com/reugn/go-streams/kafka
- github.com/rexfordnyrk/redpanda-produce
- github.com/rexmont/flagr/pkg/handler
- github.com/rfancn/hdget-sdk/lib/mq/provider/kafka
- github.com/rfielding/kafka/consumergroup
- github.com/rfielding/kafka/examples/consumergroup
- github.com/rfielding/kafka/tools/consoleconsumer
- github.com/rfielding/kafka/tools/consoleproducer
- github.com/rfielding/kafka/tools/stressproducer
- github.com/rfielding/kafka/tools/transferoffsets
- github.com/rfielding/kafka/tools/verifier
- github.com/rh01/logagent/kafka
- github.com/rhermes/thesis-disk-minder
- github.com/rhishimagdum/customer
- github.com/ricardo-ch/kafka_exporter
- github.com/richard-mauri/beats/filebeat/input/kafka
- github.com/richard-mauri/beats/libbeat/common/kafka
- github.com/richard-mauri/beats/libbeat/outputs/kafka
- github.com/richard-mauri/beats/metricbeat/module/kafka
- github.com/richard-mauri/beats/metricbeat/module/kafka/consumergroup
- github.com/richard-mauri/beats/metricbeat/module/kafka/partition
- github.com/richard-xtek/go-grpc-micro-kit/kafka
- github.com/richardmarshall/zipkin-go-opentracing
- github.com/rickb777/kafka-tool/api
- github.com/rikatz/cadvisor/storage/kafka
- github.com/ringtail/cadvisor/storage/kafka
- github.com/rivid/hmq/plugins/bridge
- github.com/riyadennis/crawler/internal
- github.com/robertchildresscfa/hmq/plugins/bridge
- github.com/robinus2/kafka-proxy
- github.com/rocinantex/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/rogpeppe/hkt
- github.com/rohan-luthra/service-restaurant-go/src/kafka
- github.com/rohitgajbhiye/kafka_util/producer
- github.com/romanblanco/kafka_websockets
- github.com/romberli/go-util/middleware/kafka
- github.com/ronaldoveras/go-labs
- github.com/ronappleton/gk-message-transport/storage
- github.com/rorysavage77/cadvisor/storage/kafka
- github.com/rovergulf/utils/mq/kafka
- github.com/rtb4free/go_rtb_agg
- github.com/rubinus/zgo/zgokafka
- github.com/rubrikinc/zipkin-go/reporter/kafka
- github.com/runabove/metronome/src/aggregator/consumers
- github.com/runabove/metronome/src/api/core
- github.com/runabove/metronome/src/metronome/kafka
- github.com/runabove/metronome/src/metronome/models
- github.com/runabove/metronome/src/scheduler/routines
- github.com/runabove/metronome/src/worker/consumers
- github.com/runabove/queue-examples/go
- github.com/runcom/cadvisor/storage/kafka
- github.com/rustedzone/kafka-sample/internal/repository/consumer/kafka_elasticsearch
- github.com/rwaweber/kt
- github.com/rwdial/beats/libbeat/outputs/kafka
- github.com/rwifeng/logkit/reader
- github.com/rwoj/go-trade
- github.com/rwoj/go-vault/vault_manager/net
- github.com/ryancox/heka/plugins/kafka
- github.com/rzrbld/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/s1377427321/stock_project/github.com/Shopify/sarama/examples/http_server
- github.com/s1377427321/stock_project/github.com/Shopify/sarama/mocks
- github.com/s1377427321/stock_project/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/s1377427321/stock_project/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/s1377427321/stock_project/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/s1377427321/stock_project/github.com/bsm/sarama-cluster
- github.com/s1377427321/stock_project/github.com/bsm/sarama-cluster/cmd/sarama-cluster-cli
- github.com/s1377427321/stock_project/github.com/leisc/llog/llager/kafkawork/services/producer
- github.com/safetyculture/k6/stats/kafka
- github.com/saggymac/kafka-pixy/admin
- github.com/saggymac/kafka-pixy/config
- github.com/saggymac/kafka-pixy/consumer
- github.com/saggymac/kafka-pixy/consumer/consumerimpl
- github.com/saggymac/kafka-pixy/consumer/groupcsm
- github.com/saggymac/kafka-pixy/consumer/msgfetcher
- github.com/saggymac/kafka-pixy/logging
- github.com/saggymac/kafka-pixy/mapper
- github.com/saggymac/kafka-pixy/offsetmgr
- github.com/saggymac/kafka-pixy/producer
- github.com/saggymac/kafka-pixy/proxy
- github.com/saggymac/kafka-pixy/server/grpcsrv
- github.com/saggymac/kafka-pixy/server/httpsrv
- github.com/saggymac/kafka-pixy/testhelpers/kafkahelper
- github.com/sahalazain/kafpro/service
- github.com/sahilkang/terraform-provider-kafka/kafka
- github.com/saikia26/stressity/loadtest
- github.com/saipanno/go-kit/client
- github.com/sajithsebastian/components-contrib/internal/component/kafka
- github.com/sak0/prometheus-to-kafka/pkg/kafka
- github.com/salaxander/cadvisor/storage/kafka
- github.com/saleswise/kafka/consumergroup
- github.com/saleswise/kafka/examples/consumergroup
- github.com/saleswise/kafka/tools/consoleconsumer
- github.com/saleswise/kafka/tools/consoleproducer
- github.com/saleswise/kafka/tools/stressproducer
- github.com/saleswise/kafka/tools/transferoffsets
- github.com/saleswise/kafka/tools/verifier
- github.com/samber/cadvisor/storage/kafka
- github.com/samofintech/go-plugins/v4/broker/kafka
- github.com/san-services/kafkaclient/v2
- github.com/sane4ek55/scriptsgo
- github.com/sanek9/cadvisor/storage/kafka
- github.com/sanservices/kit/kafkalistener
- github.com/saranrapjs/gizmo/pubsub
- github.com/sarath6080/go-kafka/src/producer
- github.com/saschagrunert/cadvisor/storage/kafka
- github.com/sassoftware/event-provenance-registry/pkg/message
- github.com/sbawaska/eventing-contrib/kafka/channel/pkg/dispatcher
- github.com/sbawaska/eventing-contrib/kafka/channel/pkg/reconciler/controller
- github.com/sbawaska/eventing-contrib/kafka/channel/pkg/reconciler/controller/resources
- github.com/sbawaska/eventing-contrib/kafka/common/pkg/kafka
- github.com/sbawaska/eventing-contrib/kafka/source/pkg/adapter
- github.com/sbawaska/eventing-contrib/test/test_images/kafka_performance
- github.com/sbpolar/goflow/transport
- github.com/scholar-ink/go-plugins/broker/kafka
- github.com/scholzj/kafka-topic-view
- github.com/sclasen/event-shuttle
- github.com/scollier/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/scorcher/goflow/transport
- github.com/scott-the-programmer/kafka/consumergroup
- github.com/scott-the-programmer/kafka/examples/consumergroup
- github.com/scott-the-programmer/kafka/tools/consoleconsumer
- github.com/scott-the-programmer/kafka/tools/consoleproducer
- github.com/scott-the-programmer/kafka/tools/stressproducer
- github.com/scott-the-programmer/kafka/tools/transferoffsets
- github.com/scott-the-programmer/kafka/tools/verifier
- github.com/scottai/go-saga/storage/kafka
- github.com/scoutapp/kafka/consumergroup
- github.com/scoutapp/kafka/examples/consumergroup
- github.com/scoutapp/kafka/tools/consoleconsumer
- github.com/scoutapp/kafka/tools/consoleproducer
- github.com/scoutapp/kafka/tools/stressproducer
- github.com/scoutapp/kafka/tools/transferoffsets
- github.com/scoutapp/kafka/tools/verifier
- github.com/sdlyingyong/example_go/kafka/sarama
- github.com/seatgeek/nomad-firehose/sink
- github.com/sebgl/chatbox/chat
- github.com/seborama/bevel
- github.com/secdre4mer/beats/filebeat/input/kafka
- github.com/secdre4mer/beats/libbeat/common/kafka
- github.com/secdre4mer/beats/libbeat/outputs/kafka
- github.com/secdre4mer/beats/metricbeat/module/kafka
- github.com/secdre4mer/beats/metricbeat/module/kafka/consumergroup
- github.com/secdre4mer/beats/metricbeat/module/kafka/partition
- github.com/selonsy/beats/filebeat/input/kafka
- github.com/selonsy/beats/libbeat/common/kafka
- github.com/selonsy/beats/libbeat/outputs/kafka
- github.com/selonsy/beats/metricbeat/module/kafka
- github.com/selonsy/beats/metricbeat/module/kafka/consumergroup
- github.com/selonsy/beats/metricbeat/module/kafka/partition
- github.com/selonsy/beats/v7/filebeat/input/kafka
- github.com/selonsy/beats/v7/libbeat/common/kafka
- github.com/selonsy/beats/v7/libbeat/outputs/kafka
- github.com/selonsy/beats/v7/metricbeat/module/kafka
- github.com/selonsy/beats/v7/metricbeat/module/kafka/consumergroup
- github.com/selonsy/beats/v7/metricbeat/module/kafka/partition
- github.com/senadi/stream-cardinality-excercise/kafka
- github.com/seongjumoon/kafka-produce-consume
- github.com/seongmujeong/LIBS/iCdr
- github.com/septiyanandika/go-kafka-example/avro/consumer
- github.com/septiyanandika/go-kafka-example/avro/producer
- github.com/septiyanandika/go-kafka-example/cmd/avro/consumer
- github.com/septiyanandika/go-kafka-example/cmd/avro/producer
- github.com/septiyanandika/go-kafka-example/cmd/plain/consumer
- github.com/septiyanandika/go-kafka-example/cmd/plain/producer
- github.com/septiyanandika/go-kafka-example/plain/consumer
- github.com/septiyanandika/go-kafka-example/plain/producer
- github.com/serejja/go_kafka_client
- github.com/serkangunes/go-plugins/broker/kafka
- github.com/sestack/smq/bridge
- github.com/sevein/jocko/examples/sarama
- github.com/sftfjugg/beats/filebeat/input/kafka
- github.com/sftfjugg/beats/libbeat/common/kafka
- github.com/sftfjugg/beats/libbeat/outputs/kafka
- github.com/sftfjugg/beats/metricbeat/module/kafka
- github.com/sftfjugg/beats/metricbeat/module/kafka/consumergroup
- github.com/sftfjugg/beats/metricbeat/module/kafka/partition
- github.com/shafreeck/kafka-cli/cmd
- github.com/shaonianyr/goreplay
- github.com/sharkgulf/pkg/qlog
- github.com/shashidharatd/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/shav/telegram-bot/internal/transport/message_queue
- github.com/shelton-hu/pi/kafka
- github.com/shenyangyeshuai/logagent/kafka
- github.com/shikharkannoje/imagestore
- github.com/shiliyuanma/go-plugins/broker/kafka
- github.com/ship-os/ship-micro/plugins/broker/kafka/v2
- github.com/shipengqi/example.v1/packeges/third/kafka
- github.com/shivanggoswami/go-data-cache/kafka
- github.com/shogo82148/beats/filebeat/input/kafka
- github.com/shogo82148/beats/libbeat/common/kafka
- github.com/shogo82148/beats/libbeat/outputs/kafka
- github.com/shogo82148/beats/metricbeat/module/kafka
- github.com/shogo82148/beats/metricbeat/module/kafka/consumergroup
- github.com/shogo82148/beats/metricbeat/module/kafka/partition
- github.com/shokunin/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/shokunin/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/shokunin/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/shokunin/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/shokunin/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/shokunin/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/shokunin/telegraf/outputs/kafka
- github.com/shokunin/telegraf/plugins/kafka_consumer
- github.com/shonpaz123/goflow/transport
- github.com/shootz-developer/gtool/mq
- github.com/shubhamguptafp/dd-trace-go/contrib/Shopify/sarama
- github.com/shubhammishra11/pubsub-app/Shopify
- github.com/shwetabhgarg/jocko/examples/sarama
- github.com/sidleal/beats/filebeat/input/kafka
- github.com/sidleal/beats/libbeat/common/kafka
- github.com/sidleal/beats/libbeat/outputs/kafka
- github.com/sidleal/beats/metricbeat/module/kafka
- github.com/sidleal/beats/metricbeat/module/kafka/consumergroup
- github.com/sidleal/beats/metricbeat/module/kafka/partition
- github.com/sigma/cadvisor/storage/kafka
- github.com/signal/goreplay
- github.com/signalfx/kafka_consumer
- github.com/signalfx/signalfx-go-tracing/contrib/Shopify/sarama
- github.com/signalfx/veneur/sinks/kafka
- github.com/siiick/kafkalib
- github.com/simplefelix/u
- github.com/simplexity-ckcclc/gochannel/tools/kafka
- github.com/sinalpha/playaround/kafkaBenchmak
- github.com/sinzuo/bluedonsave
- github.com/sitano/sarama_close_bug
- github.com/skapfer/dd-trace-go/contrib/Shopify/sarama
- github.com/skeletonkey/ksql-sandbox/producer
- github.com/skkumaravel/grpcdialout/kafka-producer
- github.com/sknv/go-pkg/kafka
- github.com/sko00o/benchmark-kafka-go-clients
- github.com/skroutz/burrow
- github.com/sku4/ozon-route256-spending-bot/cmd/bot
- github.com/sku4/ozon-route256-spending-bot/cmd/report
- github.com/sku4/ozon-route256-spending-bot/internal/handler/consumer
- github.com/sku4/ozon-route256-spending-bot/internal/service
- github.com/sku4/ozon-route256-spending-bot/internal/service/spending
- github.com/sku4/ozon-route256-spending-bot/model/consumer
- github.com/sl33nyc/venom/executors/kafka
- github.com/slackhq/go-metrics-prometheus
- github.com/sleach/goflow/transport
- github.com/slimlima/go-infra/queues
- github.com/slinkydeveloper/kafka-go-clients-benchmarks/sarama
- github.com/slinkydeveloper/loadastic/kafka
- github.com/sllt/parrot/pkg/queue/kafka
- github.com/slotix/go-plugins/broker/kafka
- github.com/slpcat/docker-images/kafka/kafka-operator-krallistic/kafka
- github.com/smbgray/kafkagoer
- github.com/snappyflow/kafka_exporter
- github.com/snow1emperor/marmota/pkg/mq
- github.com/snowlyg/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/socloudng/atem-common/atem-common-middleware/kafka
- github.com/soedev/soelib/net/kafka
- github.com/sokoloffa/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/sokoloffa/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/sokoloffa/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/sokoloffa/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/sokoloffa/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/sokoloffa/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/sokoloffa/telegraf/outputs/kafka
- github.com/sokoloffa/telegraf/plugins/kafka_consumer
- github.com/solidnerd/cadvisor/storage/kafka
- github.com/solost23/tools/kafka
- github.com/solsson/kafka-cluster-metrics/main
- github.com/soltysh/cadvisor/storage/kafka
- github.com/somethinghero/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/songof/kafkapc
- github.com/songrgg/go-plugins/broker/kafka
- github.com/songshubing/vflow/producer
- github.com/soukengo/gopkg/component/mq/kafka
- github.com/space307/zipkin-go-opentracing
- github.com/spacewander/kafka-cli/cmd
- github.com/sparrc/kafka/consumergroup
- github.com/sparrc/kafka/examples/consumergroup
- github.com/sparrc/kafka/tools/consoleconsumer
- github.com/sparrc/kafka/tools/consoleproducer
- github.com/sparrc/kafka/tools/stressproducer
- github.com/sparrc/kafka/tools/transferoffsets
- github.com/sparrc/kafka/tools/verifier
- github.com/sparrc/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/sparrc/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/sparrc/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/sparrc/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/sparrc/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/sparrc/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/sparrc/telegraf/outputs/kafka
- github.com/sparrc/telegraf/plugins/kafka_consumer
- github.com/specialprivacy/demonstrator-log-generator
- github.com/spheromak/carbon-relay-ng/route
- github.com/spider1998/go-kafka
- github.com/spikeekips/heka/plugins/kafka
- github.com/splunk/cadvisor/storage/kafka
- github.com/sqills/zipkin-go-opentracing
- github.com/squ1d123/kafka_exporter
- github.com/sraphs/gdk/pubsub/kafkapubsub
- github.com/srcmesh/kubefaas/pkg/mqtrigger/messageQueue/kafka
- github.com/sredevopsdev/kafka-connect-k8s-operator/pkg/custommetrics
- github.com/ssoor/open-bilibili/app/admin/main/apm/service
- github.com/ssoor/open-bilibili/app/infra/canal/service/reader
- 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/ssoor/open-bilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/st0rmman/actortrader/gosiris
- github.com/st3v/go-plugins/broker/kafka
- github.com/stackdriver/heapster/common/kafka
- github.com/stackroute-practice/stackroute_sourcecodepractice
- github.com/stakhiv/zipkin-go-opentracing
- github.com/stealthly/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client
- github.com/stealthly/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client/producers
- github.com/stealthly/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client/producers/tailf
- github.com/stealthly/go-kafka/Godeps/_workspace/src/github.com/stealthly/go_kafka_client/syslog
- github.com/stealthly/go-kafka/Godeps/_workspace/src/github.com/stealthly/siesta/consumer_benchmark
- github.com/stealthly/go-kafka/producer
- github.com/stealthly/go_kafka_client
- github.com/stealthly/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/stealthly/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/stealthly/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/stealthly/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/stealthly/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/stephanebunel/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/stephanebunel/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/stephanebunel/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/stephanebunel/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/stephanebunel/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/stephanebunel/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/stephanebunel/telegraf/outputs/kafka
- github.com/stephanebunel/telegraf/plugins/kafka_consumer
- github.com/stepsaway/msgqueue
- github.com/stevechan1993/gocomm/pkg/log
- github.com/stevemkroll/eventstream/internal/service
- github.com/stolostron/multicluster-global-hub/manager/pkg/eventcollector
- github.com/stolostron/multicluster-global-hub/pkg/transport/config
- github.com/stolostron/multicluster-global-hub/pkg/transport/consumer
- github.com/stolostron/multicluster-global-hub/pkg/transport/producer
- github.com/stolostron/multicluster-global-hub/samples/cloudevent/receiver
- github.com/stolostron/multicluster-global-hub/samples/cloudevent/sender
- github.com/stolostron/multicluster-global-hub/samples/config
- github.com/stolostron/multicluster-global-hub/samples/kafka/saram_consumer
- github.com/stolostron/multicluster-global-hub/samples/kafka/saram_producer
- github.com/stolostron/multicluster-global-hub/test/pkg/kafka
- github.com/stolsma/go-p4pack/pkg/logging
- github.com/straiforos8bsh5n/tokingsq/kafka/kafka-operator-krallistic/kafka
- github.com/sudeepknair/beats/filebeat/input/kafka
- github.com/sudeepknair/beats/libbeat/common/kafka
- github.com/sudeepknair/beats/libbeat/outputs/kafka
- github.com/sudeepknair/beats/metricbeat/module/kafka
- github.com/sudeepknair/beats/metricbeat/module/kafka/consumergroup
- github.com/sudeepknair/beats/metricbeat/module/kafka/partition
- github.com/sudiyi/sdy/aliware/kafka
- github.com/sugarcrm-zshearin/go-consumer/kafka
- github.com/suitingwei/go-learning/kafka
- github.com/sujamess/k6-the-hard-way/pkgs/broker
- github.com/sunjvhui/go-common/app/infra/canal/service/reader
- github.com/sunjvhui/go-common/app/infra/databus/tcp
- github.com/sunjvhui/go-common/app/infra/notify/notify
- github.com/sunjvhui/go-common/app/interface/openplatform/monitor-end/service
- github.com/sunjvhui/go-common/app/job/main/app-wall/service/offer
- github.com/sunjvhui/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/sunlight2728/testgob/app/admin/main/apm/service
- github.com/sunlight2728/testgob/app/infra/canal/service/reader
- 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/sunlight2728/testgob/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/sunnybug/pholcus/common/kafka
- github.com/sunp13/kfktool
- github.com/sunsingerus/tbox/pkg/kafka
- github.com/sunyanfei/pholcus/common/kafka
- github.com/sushruta/archiver-project/golang-stuff/src/github.com/asappinc/challenge-di-eng/cmd/archiver
- github.com/sushruta/archiver-project/golang-stuff/src/github.com/asappinc/challenge-di-eng/cmd/echoconsume
- github.com/sushruta/archiver-project/golang-stuff/src/github.com/asappinc/challenge-di-eng/cmd/produce
- github.com/sushruta/archiver-project/golang-stuff/src/github.com/asappinc/challenge-di-eng/pkg/kafka/consumer
- github.com/svalleru/cadvisor/storage/kafka
- github.com/syalsr/notification/internal/kafka
- github.com/symsimmy/due/eventbus/kafka
- github.com/syncromatics/kafmesh/pkg/runner
- github.com/syncromatics/proto-schema-registry/internal/storage
- github.com/synfinatic/goflow/transport
- github.com/sysadmind/kafka_exporter
- github.com/tOnkowzl/libs/saramax
- github.com/taboola/goreplay
- github.com/taik/go-plugins/broker/kafka
- github.com/taik0/cadvisor/storage/kafka
- github.com/tal-tech/hera/kafkaconsumer
- github.com/talon-sec/watermill-kafka/v2/pkg/kafka
- github.com/tangentspace/telegraf-cloudwatch-plugin/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/tangentspace/telegraf-cloudwatch-plugin/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/tangentspace/telegraf-cloudwatch-plugin/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/tangentspace/telegraf-cloudwatch-plugin/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/tangentspace/telegraf-cloudwatch-plugin/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/tangentspace/telegraf-cloudwatch-plugin/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/tangentspace/telegraf-cloudwatch-plugin/outputs/kafka
- github.com/tangentspace/telegraf-cloudwatch-plugin/plugins/kafka_consumer
- github.com/tanji/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/tanji/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/tanji/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/tanji/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/tanji/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/tanji/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/tanji/telegraf/outputs/kafka
- github.com/tanji/telegraf/plugins/kafka_consumer
- github.com/tanlei007/bilibili-go-common-master/app/admin/main/apm/service
- github.com/tanlei007/bilibili-go-common-master/app/infra/canal/service/reader
- 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/tanlei007/bilibili-go-common-master/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/tanlinhua/bilibili-backup/app/admin/main/apm/service
- github.com/tanlinhua/bilibili-backup/app/infra/canal/service/reader
- 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/tanlinhua/bilibili-backup/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/tarathep/hellogoapi/kafka
- github.com/tariel-x/iguana/cmd/test_producer
- github.com/tcolgate/cadvisor/storage/kafka
- github.com/tddey01/luffy/day013/kafkademo
- github.com/tddey01/luffy/day014/kafka_consumer
- github.com/tddey01/luffy/day014/loagent/kafka
- github.com/tddey01/luffy/day014/loagent/tailfile
- github.com/tddey01/luffy/day015/loagent/kafka
- github.com/tddey01/luffy/day015/loagent/tailfile
- github.com/tddey01/luffy/day016/log_transfer/kafka
- github.com/team-cymru/vflow/producer
- github.com/team-rocos/sarama/examples/http_server
- github.com/team-rocos/sarama/examples/sasl_scram_client
- github.com/team-rocos/sarama/mocks
- github.com/team-rocos/sarama/tools/kafka-console-consumer
- github.com/team-rocos/sarama/tools/kafka-console-partitionconsumer
- github.com/team-rocos/sarama/tools/kafka-console-producer
- github.com/team-rocos/sarama/tools/kafka-producer-performance
- github.com/teamlint/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/teenkwn/basic-kafka-producer
- github.com/teivah/gosiris/gosiris
- github.com/teixie-go/kafka-sarama
- github.com/telegoim/telegoim-server/common/xmq/kafka
- github.com/tencentblueking/beats/filebeat/input/kafka
- github.com/tencentblueking/beats/libbeat/common/kafka
- github.com/tencentblueking/beats/libbeat/outputs/kafka
- github.com/tencentblueking/beats/metricbeat/module/kafka
- github.com/tencentblueking/beats/metricbeat/module/kafka/consumergroup
- github.com/tencentblueking/beats/metricbeat/module/kafka/partition
- github.com/tencentcloudmiddleware/ckafka-sarama-demo
- github.com/teserakt-io/c2/internal/protocols
- github.com/testeradjust/simple-cobra-app/internal
- github.com/tetration-exchange/pol-client-go
- github.com/tetrationanalytics/sarama/examples/http_server
- github.com/tetrationanalytics/sarama/mocks
- github.com/tetrationanalytics/sarama/tools/kafka-console-consumer
- github.com/tetrationanalytics/sarama/tools/kafka-console-partitionconsumer
- github.com/tetrationanalytics/sarama/tools/kafka-console-producer
- github.com/thbkrkr/qli/client
- github.com/thed00de/hypernetes/Godeps/_workspace/src/github.com/google/cadvisor/storage/kafka
- github.com/thegoodparticle/challan-data-svc/event-consumer
- github.com/thepabloaguilar/sukuna/apps_for_saga/flight_app
- github.com/thepabloaguilar/sukuna/apps_for_saga/hotel_app
- github.com/thepabloaguilar/sukuna/apps_for_saga/payment_app
- github.com/thepabloaguilar/sukuna/entrypoints/api
- github.com/thepabloaguilar/sukuna/entrypoints/kafka
- github.com/thepabloaguilar/sukuna/gateways/step_execution
- github.com/thetherington/beats/filebeat/input/kafka
- github.com/thetherington/beats/libbeat/common/kafka
- github.com/thetherington/beats/libbeat/outputs/kafka
- github.com/thetherington/beats/metricbeat/module/kafka
- github.com/thetherington/beats/metricbeat/module/kafka/consumergroup
- github.com/thetherington/beats/metricbeat/module/kafka/partition
- github.com/theykk/funnel/outputs
- github.com/thomasdesr/cadvisor/storage/kafka
- github.com/thomasmodeneis/flotilla/flotilla-server/daemon/broker/kafka
- github.com/thomaso-mirodin/cadvisor/storage/kafka
- github.com/thoppe-dwarakanath/beats/filebeat/input/kafka
- github.com/thoppe-dwarakanath/beats/libbeat/common/kafka
- github.com/thoppe-dwarakanath/beats/libbeat/outputs/kafka
- github.com/thoppe-dwarakanath/beats/metricbeat/module/kafka
- github.com/thoppe-dwarakanath/beats/metricbeat/module/kafka/consumergroup
- github.com/thoppe-dwarakanath/beats/metricbeat/module/kafka/partition
- github.com/thoppe-dwarakanath/beats/v7/filebeat/input/kafka
- github.com/thoppe-dwarakanath/beats/v7/libbeat/common/kafka
- github.com/thoppe-dwarakanath/beats/v7/libbeat/outputs/kafka
- github.com/thoppe-dwarakanath/beats/v7/metricbeat/module/kafka
- github.com/thoppe-dwarakanath/beats/v7/metricbeat/module/kafka/consumergroup
- github.com/thoppe-dwarakanath/beats/v7/metricbeat/module/kafka/partition
- github.com/thrawn01/kafka-pixy/admin
- github.com/thrawn01/kafka-pixy/apiserver
- github.com/thrawn01/kafka-pixy/config
- github.com/thrawn01/kafka-pixy/consumer/consumerimpl
- github.com/thrawn01/kafka-pixy/consumer/groupcsm
- github.com/thrawn01/kafka-pixy/consumer/mapper
- github.com/thrawn01/kafka-pixy/consumer/msgstream
- github.com/thrawn01/kafka-pixy/consumer/offsetmgr
- github.com/thrawn01/kafka-pixy/consumer/partitioncsm
- github.com/thrawn01/kafka-pixy/logging
- github.com/thrawn01/kafka-pixy/producer
- github.com/thrawn01/kafka-pixy/testhelpers/kafkahelper
- github.com/threatgrid/heka/plugins/kafka
- github.com/tiamxu/kit/kafka
- github.com/tiancai110a/logagent/kafka
- github.com/tianqiqiu/go-iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/tianyabin2010/ludo-gobase/kafka
- github.com/tibcosoftware/mashling/ext/flogo/trigger/kafkasubrouter
- github.com/tidwall/tile38/internal/endpoint
- github.com/timeplus-io/chameleon/dataloader/sinks/kafka
- github.com/tinque/go-plugins/broker/kafka
- github.com/tjmcs/cadvisor/storage/kafka
- github.com/tklauser/cadvisor/storage/kafka
- github.com/tl1644/hmq/plugins/bridge
- github.com/tmax-cloud/hypercloud-api-server/util/consumer
- github.com/tmnhs/fginx/server/internal/service/kafka
- github.com/tnals5152/goormtalk/goorm_socket/config
- github.com/toaiduongdh/ftpd/kafkatools
- github.com/toin0u/gizmo/pubsub
- github.com/tolopsy/rite-events/pubsub/kafka
- github.com/tommynurwantoro/kafkid/internal/adapter/kafka
- github.com/tommyulfsparre/zipkin-go-opentracing
- github.com/tonybka/kafka-go-wrapper
- github.com/topfreegames/kafka/consumergroup
- github.com/topfreegames/kafka/examples/consumergroup
- github.com/topfreegames/kafka/tools/consoleconsumer
- github.com/topfreegames/kafka/tools/consoleproducer
- github.com/topfreegames/kafka/tools/stressproducer
- github.com/topfreegames/kafka/tools/transferoffsets
- github.com/topfreegames/kafka/tools/verifier
- github.com/topfreegames/marathon/extensions
- github.com/tortuoise/funnel/outputs
- github.com/tossp/gizmo/pubsub
- github.com/touchtechnologies-product/message-broker/kafka
- github.com/tozny/utils-go/stream
- github.com/tr3ee/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/traceabilitychain/tac/common/viperutil
- github.com/tracer0tong/kafkalogrus
- github.com/transitorykris/jocko/example
- github.com/traqpl/s01test_tasks/nagios/kafka
- github.com/travisescovar/kafkaop/kafka
- github.com/tregalman/jocko/examples/sarama
- github.com/truemark/terraform-provider-kafka/terraform_kafka
- github.com/trustbloc/fabric-lib-go-ext/internal/github.com/hyperledger/fabric/common/viperutil
- github.com/trustedanalytics/gateway
- github.com/trustedanalytics/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/trustedanalytics/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/trustedanalytics/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/trustedanalytics/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/trustedanalytics/gateway/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/tryfix/krouter
- github.com/tryfix/schemaregistry
- github.com/tsheasha/relayd/forwarder
- github.com/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/admin/main/apm/service
- github.com/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/infra/canal/service/reader
- 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/tsrmtrue/asiotestrobot/openbilibili-go-common-master/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/turtletramp/hmq/plugins/bridge
- github.com/tushar00jain/bench/requester
- github.com/tuxiedev/gotweet/pkg/outputs
- github.com/twotigers93/tidb/tidb-binlog/driver/reader
- github.com/tx7do/go-kafka-example/sarama
- github.com/txchat/im-pkg/trace
- github.com/tyagip966/utility/kafka
- github.com/tyuyu/kafka_util
- github.com/uber-archive/cherami-server/services/outputhost
- github.com/uber-archive/kafka/consumergroup
- github.com/uber-archive/kafka/examples/consumergroup
- github.com/uber-archive/kafka/tools/consoleconsumer
- github.com/uber-archive/kafka/tools/consoleproducer
- github.com/uber-archive/kafka/tools/stressproducer
- github.com/uber-archive/kafka/tools/transferoffsets
- github.com/uber-archive/kafka/tools/verifier
- github.com/uber/cadvisor/storage/kafka
- github.com/uber/cherami-server/services/outputhost
- github.com/uccps-samples/google-cadvisor/storage/kafka
- github.com/ueisele/opentelemetry-collector-contrib/receiver/kafkareceiver
- github.com/uepoch/kafka_exporter
- github.com/uk0/file_to_rocketmq_middleware/kafka
- github.com/ukinhappy/go-example/kafka
- github.com/unifrost/unifrost/drivers/kafkadriver
- github.com/unionmexicanadelnorte/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/upeshpv/elastic-beats2/filebeat/input/kafka
- github.com/upeshpv/elastic-beats2/libbeat/common/kafka
- github.com/upeshpv/elastic-beats2/libbeat/outputs/kafka
- github.com/upeshpv/elastic-beats2/metricbeat/module/kafka
- github.com/upeshpv/elastic-beats2/metricbeat/module/kafka/consumergroup
- github.com/upeshpv/elastic-beats2/metricbeat/module/kafka/partition
- github.com/urans/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/urionz/pholcus/common/kafka
- github.com/usabilla/cadvisor/storage/kafka
- github.com/ustream/kafka-health-check/check
- github.com/uswitch/loglet
- github.com/uthng/gokit-kafka
- github.com/utilitywarehouse/data-infra-benthos/v4/internal/impl/kafka
- github.com/utilitywarehouse/go-pubsub/kafka
- github.com/utilitywarehouse/proximo/proximo-server
- github.com/v1n337/flotilla/flotilla-server/daemon/broker/kafka
- github.com/vadv/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/vadv/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/vadv/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/vadv/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/vadv/telegraf/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/vadv/telegraf/Godeps/_workspace/src/github.com/wvanbergen/kafka/consumergroup
- github.com/vadv/telegraf/outputs/kafka
- github.com/vadv/telegraf/plugins/kafka_consumer
- github.com/vaksi/messaging/pkg/kafka
- github.com/validatecl/kafka-toolkit
- github.com/vasilcovsky/microservices-book-code/kafka
- github.com/vault-thirteen/junk/SSE2/internal/application
- github.com/vault-thirteen/junk/SSE2/internal/application/component/kafka/input
- github.com/vault-thirteen/junk/SSE2/internal/application/component/kafka/output
- github.com/vault-thirteen/junk/gfe/internal/application
- github.com/vault-thirteen/junk/gfe/internal/kafka
- github.com/vault-thirteen/junk/gfe/pkg/models/message
- github.com/vdieulesaint/go-plugins/broker/kafka
- github.com/vechain/thor-go-vendor/github.com/aristanetworks/goarista/cmd/ockafka
- github.com/vechain/thor-go-vendor/github.com/aristanetworks/goarista/kafka
- github.com/vechain/thor-go-vendor/github.com/aristanetworks/goarista/kafka/openconfig
- github.com/vechain/thor-go-vendor/github.com/aristanetworks/goarista/kafka/producer
- github.com/vedicsoft/vamps-core/commons
- github.com/venicegeo/pz-gocommon/kafka
- github.com/ventifang/bilibili-source-code/app/admin/main/apm/service
- github.com/ventifang/bilibili-source-code/app/infra/canal/service/reader
- 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/ventifang/bilibili-source-code/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/veqryn/personal/src/kafka
- github.com/vericlongmore/go-dev/kafka_checker
- github.com/verizon/vflow/producer
- github.com/vince21298/kafkahelloworld
- github.com/vincentserpoul/unifrost/drivers/kafkadriver
- github.com/violetpupil/gos/lib/sarama
- github.com/viru-tech/clickhouse_sinker/input
- github.com/vishh/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/vishh/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/vishh/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/vishh/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/vishh/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/vishh/cadvisor/storage/kafka
- github.com/viteLabs/go-vite/chain/sender
- github.com/vitorsiqueirarecife/bff/app/message
- github.com/vivino/go-shezmu/examples/daemons-kafka/kafka
- github.com/vladiacob/go_kafka_client
- github.com/vmware-archive/dispatch/pkg/events/transport
- github.com/vmyroslav/kafetrain
- github.com/vnroyalclub/go-common/kafka
- github.com/volcengine/datarangers-sdk-go
- github.com/volcengine/volc-sdk-golang/example/dts/data-subscription-demo
- github.com/vpsong/game/kafka
- github.com/vshn/appcat-kafka-example
- github.com/vtta/dgraph/worker
- github.com/vwdsrc/wrench/connector
- github.com/w0nwig/cadvisor/storage/kafka
- github.com/wadeling/kafka-demo
- github.com/wagner-aos/go-kafka-avro
- github.com/wangbokun/cadvisor/storage/kafka
- github.com/wangfeiping/heka/plugins/kafka
- github.com/wanghai328/bil/app/admin/main/apm/service
- github.com/wanghai328/bil/app/infra/canal/service/reader
- github.com/wanghai328/bil/app/infra/databus/tcp
- github.com/wanghai328/bil/app/infra/notify/notify
- github.com/wanghai328/bil/app/interface/openplatform/monitor-end/service
- github.com/wanghai328/bil/app/job/main/app-wall/service/offer
- github.com/wanghai328/bil/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/wangjuelong/go-streams/kafka
- github.com/wangkechen/gotest
- github.com/wangkechun/k6/stats/kafka
- github.com/wangle201210/studyGo/tools/mq/kafka
- github.com/wangping886/mns_consumer
- github.com/wangwg2/iot.sentel/apiserver/util
- github.com/wangwg2/iot.sentel/broker/base
- github.com/wangwg2/iot.sentel/broker/mqtt
- github.com/wangwg2/iot.sentel/ceilometer/collector
- github.com/wangwg2/iot.sentel/conductor/executor
- github.com/wangwg2/iot.sentel/conductor/indicator
- github.com/wangwg2/iot.sentel/iothub
- github.com/wangxn2015/onos-lib-go/pkg/logging
- github.com/wangyihit/libmt/util/kafka
- github.com/warsky007/beats/filebeat/input/kafka
- github.com/warsky007/beats/libbeat/common/kafka
- github.com/warsky007/beats/libbeat/outputs/kafka
- github.com/warsky007/beats/metricbeat/module/kafka
- github.com/warsky007/beats/metricbeat/module/kafka/consumergroup
- github.com/warsky007/beats/metricbeat/module/kafka/partition
- github.com/waszqt/fabric/common/viperutil
- github.com/waszqt/fabric/orderer/common/localconfig
- github.com/waszqt/fabric/orderer/consensus/kafka
- github.com/waszqt/fabric/orderer/consensus/kafka/mock
- github.com/waszqt/fabric/v2/common/viperutil
- github.com/waszqt/fabric/v2/orderer/common/localconfig
- github.com/waszqt/fabric/v2/orderer/consensus/kafka
- github.com/waszqt/fabric/v2/orderer/consensus/kafka/mock
- github.com/watchman1989/rninet/plugin/broker/kafka
- github.com/wayarmy/gonfluent
- github.com/wcygan/ping/server/kafka
- github.com/weaveworks/cadvisor/storage/kafka
- github.com/webb-ai/k8s-agent/pkg/kafka
- github.com/webiks/beats/filebeat/input/kafka
- github.com/webiks/beats/libbeat/common/kafka
- github.com/webiks/beats/libbeat/outputs/kafka
- github.com/webiks/beats/metricbeat/module/kafka
- github.com/webiks/beats/metricbeat/module/kafka/consumergroup
- github.com/webiks/beats/metricbeat/module/kafka/partition
- github.com/weblazy/easy/ekafka
- github.com/wedoca/kafka_produce
- github.com/weichang-bianjie/kafka-sdk-go/kafka
- github.com/weipatty/gomyenv
- github.com/weisd/go-plugins/broker/kafka
- github.com/weitrue/Seckill/infrastructure/mq/kafka
- github.com/wenqingqaq/backend-lib/teckafka
- github.com/wgliang/cadvisor/storage/kafka
- github.com/whereistanya/hello-websockets/kafka
- github.com/whynowy/test/hello
- github.com/wikia/goreplay
- github.com/wingchain/wingbaas/platformsrv/settings/fabric/txgeneratev2/common/viperutil
- github.com/wingyplus/k6/stats/kafka
- github.com/winiex/heka/plugins/kafka
- github.com/wizard-cxy/cadvisor/storage/kafka
- github.com/wjw1758548031/golang
- github.com/wlibo666/go-plugins/broker/kafka
- github.com/wmy595265578/knowledge/kakfa_consumer
- github.com/wolf29f/venom/executors/kafka
- github.com/wong-winnie/library/dao/kafka
- github.com/wonglyxng/gopractice/openbilibili-master/go-common/app/admin/main/apm/service
- github.com/wonglyxng/gopractice/openbilibili-master/go-common/app/infra/canal/service/reader
- 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/wonglyxng/gopractice/openbilibili-master/go-common/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/worldbestpro/burrowx-kafka/monitor
- github.com/worldbug/kafeman/internal/admin
- github.com/worldbug/kafeman/internal/consumer
- github.com/worldbug/kafeman/internal/kafeman
- github.com/worldbug/kafeman/internal/models
- github.com/worldbug/kafeman/internal/producer
- github.com/worldbug/kafeman/internal/sarama_config
- github.com/worldbug/kafeman/internal/utils
- github.com/woshizhang81/pushsystem/src/example
- github.com/wpf1234/aclogtest/kafka
- github.com/wrmn/kafkaprod
- github.com/wshekrota/beats/filebeat/input/kafka
- github.com/wshekrota/beats/libbeat/common/kafka
- github.com/wshekrota/beats/libbeat/outputs/kafka
- github.com/wshekrota/beats/metricbeat/module/kafka
- github.com/wshekrota/beats/metricbeat/module/kafka/consumergroup
- github.com/wshekrota/beats/metricbeat/module/kafka/partition
- github.com/wsqun/go-delay-driver-kafka
- github.com/wtifs/room-booking/app/consumer
- github.com/wulog/plugin-kafka
- 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/canal/service/reader
- 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/wumingshi0531/openbilibili-1/openbilibili-go-common-master/openbilibili-go-common-master/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/wuzhix/example/src/demo/queue
- github.com/wvanbergen/kafka/consumergroup
- github.com/wvanbergen/kafka/examples/consumergroup
- github.com/wvanbergen/kafka/tools/consoleconsumer
- github.com/wvanbergen/kafka/tools/consoleproducer
- github.com/wvanbergen/kafka/tools/stressproducer
- github.com/wvanbergen/kafka/tools/transferoffsets
- github.com/wvanbergen/kafka/tools/verifier
- github.com/wyonghui/biliwebsource/app/admin/main/apm/service
- github.com/wyonghui/biliwebsource/app/infra/canal/service/reader
- 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/wyonghui/biliwebsource/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/wzs654421772/docker-images/kafka/kafka-operator-krallistic/kafka
- github.com/x-chain/baasconsole/baas-core/core/tools/fabric/common/viperutil
- github.com/x1957/cadvisor/storage/kafka
- github.com/xawmx/blockchainthesis/blockchainThesis/blockchain-trace-bcnetwork/basic-network/fabric/common/viperutil
- github.com/xawmx/blockchainthesis/blockchainThesis/blockchain-trace-bcnetwork/basic-network/fabric/orderer/common/localconfig
- github.com/xawmx/blockchainthesis/blockchainThesis/blockchain-trace-bcnetwork/basic-network/fabric/orderer/consensus/kafka
- github.com/xawmx/blockchainthesis/blockchainThesis/blockchain-trace-bcnetwork/basic-network/fabric/orderer/consensus/kafka/mock
- github.com/xbcsmith/shovelput
- github.com/xbitgo/components/MQ
- github.com/xc70203/pholcus/common/kafka
- github.com/xfp-discerning/logagent/kafka
- github.com/xgxw/foundation-go/events
- github.com/xi163/upload_file/src/global/pkg/common/kafka
- github.com/xiang87871/bilibili/app/admin/main/apm/service
- github.com/xiang87871/bilibili/app/infra/canal/service/reader
- 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/xiang87871/bilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/xiaofeialen/gonotes/go/client/kafka
- github.com/xiaojiaoyu100/windlord/alikafkamq
- github.com/xiaonuoz/logagentbyconfig/kafka
- github.com/xiehuanjun/hmq/plugins/bridge
- github.com/xiejq1990/kafka/consumergroup
- github.com/xiejq1990/kafka/examples/consumergroup
- github.com/xiejq1990/kafka/tools/consoleconsumer
- github.com/xiejq1990/kafka/tools/consoleproducer
- github.com/xiejq1990/kafka/tools/stressproducer
- github.com/xiejq1990/kafka/tools/transferoffsets
- github.com/xiejq1990/kafka/tools/verifier
- github.com/xigang/cadvisor/storage/kafka
- github.com/xingobar/kubernetes/monitor/heapster-master/common/kafka
- github.com/xinpianchang/xservice/pkg/kafkax
- github.com/xlt-evil/the_way_to_go/kafka
- github.com/xmseekshine/ssutil/kafka
- github.com/xpunch/go-micro-plugins/v4/broker/kafka
- github.com/xsssends/l9plugins/tcp
- github.com/xtaci/notes/golang/kafka
- github.com/xtaci/rewind
- github.com/xthexder/heka/plugins/kafka
- github.com/xuyun-io/hotrod/src/github.com/jaegertracing/jaeger/cmd/ingester/app/consumer
- github.com/xuyun-io/hotrod/src/github.com/jaegertracing/jaeger/cmd/ingester/app/consumer/mocks
- github.com/xuyun-io/hotrod/src/github.com/jaegertracing/jaeger/pkg/kafka/auth
- github.com/xuyun-io/hotrod/src/github.com/jaegertracing/jaeger/pkg/kafka/consumer
- github.com/xuyun-io/hotrod/src/github.com/jaegertracing/jaeger/pkg/kafka/producer
- github.com/xuyun-io/hotrod/src/github.com/jaegertracing/jaeger/plugin/storage/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/canal/service/reader
- 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/xxxtai/Bilibili-Go-Backup/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/xy-gzf/gzf_server/lib/common/kafka
- github.com/xzjs/golib
- github.com/xzyan/kmq
- github.com/y1015860449/go-tools/hy_mq/kafka
- github.com/yacen/kafkaUtil
- github.com/yacut/kafka_exporter
- github.com/yaminmhd/go-kafka-producer-protobuf/cmd
- github.com/yanchengyou/sk-webhook/test
- github.com/yangji168/omonitor/models
- github.com/yangxikun/kt
- github.com/yangzhao28/gizmo/pubsub/kafka
- github.com/yanuar-nc/go-boiler-plate/src/shared/repository
- github.com/yay14/pulse/internal/kafka
- github.com/yehohanan7/jocko/examples/sarama
- github.com/yejingx/kafka/consumergroup
- github.com/yejingx/kafka/examples/consumergroup
- github.com/yejingx/kafka/tools/consoleconsumer
- github.com/yejingx/kafka/tools/consoleproducer
- github.com/yejingx/kafka/tools/stressproducer
- github.com/yejingx/kafka/tools/transferoffsets
- github.com/yejingx/kafka/tools/verifier
- github.com/yidane/gotest/mq/kafka
- github.com/yidoyoon/cadvisor-lite/cmd/internal/storage/kafka
- github.com/yig-library/kafka
- github.com/yigejidan/logagent/kafka
- github.com/yinzhongyu/ylogs/kafka
- github.com/yixinshuwu/iris/_examples/tutorial/api-for-apache-kafka/src
- github.com/yixinshuwu/openbilibili-go-common-1/app/admin/main/apm/service
- github.com/yixinshuwu/openbilibili-go-common-1/app/infra/canal/service/reader
- 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/yixinshuwu/openbilibili-go-common-1/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/yixinshuwu/pholcus_dependent/github.com/Shopify/sarama/examples/http_server
- github.com/yixinshuwu/pholcus_dependent/github.com/Shopify/sarama/mocks
- github.com/yixinshuwu/pholcus_dependent/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/yixinshuwu/pholcus_dependent/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/yixinshuwu/pholcus_dependent/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/yjdyxg/ychatcore/pkg/common/kafka
- github.com/yjp211/kafka/consumergroup
- github.com/yjp211/kafka/examples/consumergroup
- github.com/yjp211/kafka/tools/consoleconsumer
- github.com/yjp211/kafka/tools/consoleproducer
- github.com/yjp211/kafka/tools/stressproducer
- github.com/yjp211/kafka/tools/transferoffsets
- github.com/yjp211/kafka/tools/verifier
- github.com/yngzij/openbilibili/app/admin/main/apm/service
- github.com/yngzij/openbilibili/app/infra/canal/service/reader
- 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/yngzij/openbilibili/app/service/main/dapper/pkg/collect/kafkacollect
- github.com/yodagogo/adups-go/kafka
- github.com/yoki123/game/kafka
- github.com/yokong/go-pra/kafka-pra/producer
- github.com/yoozoo/protomq
- github.com/youchuangcd/gopkg/kafka
- github.com/younglifestyle/msgmid/kafka
- github.com/younisshah/jakob/jkafka
- github.com/ypyf/golang-study/kafka
- github.com/ytakaya/dd-trace-go/contrib/Shopify/sarama
- github.com/ytf606/golibs/service/kafka
- github.com/yudai/go_kafka_client
- github.com/yudai/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/yudai/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/yudai/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/yudai/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/yudai/go_kafka_client/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/yummyweb/assetmantle-modules/utilities/rest/queuing
- github.com/yunfeiyang1916/toolkit/kafka
- github.com/yunfeiyang1916/toolkit/kafka/consumergroup
- github.com/yunfeiyang1916/toolkit/kafka/examples/consumergroup
- github.com/yunfeiyang1916/toolkit/kafka/tools/consoleconsumer
- github.com/yunfeiyang1916/toolkit/kafka/tools/consoleproducer
- github.com/yunfeiyang1916/toolkit/kafka/tools/stressproducer
- github.com/yunfeiyang1916/toolkit/kafka/tools/transferoffsets
- github.com/yunfeiyang1916/toolkit/kafka/tools/verifier
- github.com/yunxiaozhao/Konsensus/kafka
- github.com/yuriadams/prometheus-kafka-adapter/kafka
- github.com/yusaint/gostream-contrib/mq
- github.com/yushuilong/livebarrage/comet
- github.com/yusufsyaifudin/khook/internal/pkg/kafkaclientmgr
- github.com/yusufsyaifudin/khook/internal/pkg/kafkaconsumermgr
- github.com/yusufsyaifudin/khook/internal/pkg/kafkaconsumermgr/manager
- github.com/yusufsyaifudin/khook/internal/pkg/sipper
- github.com/yusufsyaifudin/khook/internal/pkg/sipper/sippercloudevents
- github.com/yuvakkrishnan/go-kafka/producer
- github.com/ywengineer/g-util/kafka
- github.com/yybirdcf/golib/queue
- github.com/yyd01245/pholcus/common/kafka
- github.com/yyf330/log-operator/common/kafka
- github.com/yyliziqiu/waf/kfk
- github.com/yyn1110/kafka_exporter
- github.com/yzlq99/connector/pkg/connector
- github.com/zacscoding/burrow-all/internal/kafka
- github.com/zahrapurfallah/sysu_vwr/tooling/flow
- github.com/zaquestion/cadvisor/storage/kafka
- github.com/zbrechave/eagle/kafka
- github.com/zcmiss/qpgame/ramcache
- github.com/zcqzcg/sarama/mocks
- github.com/zdavep/dozer/proto/kafka
- github.com/zdnscloud/kafkatest
- github.com/zdyj3170101136/jaeger/cmd/ingester/app/consumer
- github.com/zdyj3170101136/jaeger/cmd/ingester/app/consumer/mocks
- github.com/zdyj3170101136/jaeger/pkg/kafka/auth
- github.com/zdyj3170101136/jaeger/pkg/kafka/consumer
- github.com/zdyj3170101136/jaeger/pkg/kafka/producer
- github.com/zdyj3170101136/jaeger/plugin/storage/kafka
- github.com/zebrium/beats/filebeat/input/kafka
- github.com/zebrium/beats/libbeat/common/kafka
- github.com/zebrium/beats/libbeat/outputs/kafka
- github.com/zebrium/beats/metricbeat/module/kafka
- github.com/zebrium/beats/metricbeat/module/kafka/consumergroup
- github.com/zebrium/beats/metricbeat/module/kafka/partition
- github.com/zeidoo/go-sugar/kafka
- github.com/zeiss/typhoon/pkg/sources/adapter/kafkasource
- github.com/zenghao306/zenghao_all_projects/hdt_app_go/common/dao/kafka
- github.com/zenpk/dorm-system/internal/mq
- github.com/zhang-yu-cn/subscribe_demo/go_demo
- github.com/zhang0137/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/zhang0137/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/zhang0137/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/zhang0137/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/zhang0137/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/zhang0137/cadvisor/storage/kafka
- github.com/zhangdapeng520/zdpgo_kafka
- github.com/zhangdapeng520/zdpgo_kafka/examples/z01_hello_old/consumer
- github.com/zhangdapeng520/zdpgo_kafka/examples/z01_hello_old/producer
- github.com/zhangdapeng520/zdpgo_kafka/examples/z02_hello/consumer
- github.com/zhangdapeng520/zdpgo_kafka/examples/z03_async_producer_and_group_consumer_old/consumer
- github.com/zhangdapeng520/zdpgo_kafka/examples/z03_async_producer_and_group_consumer_old/producer
- github.com/zhangdapeng520/zdpgo_kafka/examples/z04_async_producer_and_group_consumer/consumer
- github.com/zhangdapeng520/zdpgo_kafka/examples/z04_async_producer_and_group_consumer/producer
- github.com/zhanghuizong/bitgame/component/logs
- github.com/zhangjun1234/kafka_test
- github.com/zhangkyou/kafka/consumergroup
- github.com/zhangkyou/kafka/examples/consumergroup
- github.com/zhangkyou/kafka/tools/consoleconsumer
- github.com/zhangkyou/kafka/tools/consoleproducer
- github.com/zhangkyou/kafka/tools/stressproducer
- github.com/zhangkyou/kafka/tools/transferoffsets
- github.com/zhangkyou/kafka/tools/verifier
- github.com/zhangpeihao/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/examples/http_server
- github.com/zhangpeihao/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/mocks
- github.com/zhangpeihao/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-consumer
- github.com/zhangpeihao/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer
- github.com/zhangpeihao/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/tools/kafka-console-producer
- github.com/zhangpeihao/cadvisor/storage/kafka
- github.com/zhangweiguo/golang/wego/common/client
- github.com/zhangweiii/pholcus/common/kafka
- github.com/zhangweiwhim/kafkas_exporter_zw
- github.com/zhangxi123051/ep_data/controller
- github.com/zhangxiaocong/crypto-exchange-engine
- github.com/zhaoshoucheng/hodgepodge/kafka
- github.com/zhengqz/go-plugins/broker/kafka
- github.com/zhengyscn/golang-doc/kafka/kafka
- github.com/zhenshaw/go-lib/kafka
- github.com/zhigang/kafka-consumer
- github.com/zhiyige/logagent/kafka
- github.com/zhj0811/fabric/common/sdk
- github.com/zhuansuny/go-project/log-agent/kafka
- github.com/zhuansuny/go-project/log-tool-demo/01_kafka
- github.com/zhuansuny/go-project/log-tool-demo/09_kafka_consumer
- github.com/zhuansuny/go-project/log-tool-demo/11_log_transfer
- github.com/zhuansuny/go-project/log-transfer
- github.com/zhuansuny/go-project/logsys/log-agent/kafka
- github.com/zhuansuny/go-project/logsys/log-transfer
- github.com/zhuansuny/go-project/logsys/stu/1.kafkatest
- github.com/zhuansuny/golang/log-agent/kafka
- github.com/zhuansuny/golang/log-tool-demo/01_kafka
- github.com/zhuansuny/golang/log-tool-demo/09_kafka_consumer
- github.com/zhuansuny/golang/log-tool-demo/11_log_transfer
- github.com/zhuansuny/golang/log-transfer
- github.com/zhuansuny/golang/logsys/log-agent/kafka
- github.com/zhuansuny/golang/logsys/log-transfer
- github.com/zhuansuny/golang/logsys/stu/1.kafkatest
- github.com/zhujingfa/go-plugins/broker/kafka
- github.com/zhunh/zookeeper_kfk/go-kafka
- github.com/zhuzhuolong/excharge
- github.com/zibilal/mibroker/kafka
- github.com/zihao-boy/zihao/common/kafka
- github.com/zingp/logagent
- github.com/ziozzang/heka/plugins/kafka
- github.com/ziru/openmock
- github.com/zkanghan/grabvotes/internal/logic
- github.com/zkh-timor/grabvotes/internal/logic
- github.com/zleague/dd-trace-go/contrib/Shopify/sarama
- github.com/znly/bandmaster/services/kafka
- github.com/znyh/middle-end/library/pkg/kafka
- github.com/zolrath/gizmo/pubsub/kafka
- github.com/zongqinghou/selfserver/let-us-go/utils
- github.com/zouchunting/notes/KafkaGo
- github.com/zp857/util/kafka
- github.com/zr-hebo/sniffer-agent/exporter
- github.com/zrhoffman/nonfork/traffic_stats
- github.com/zssky/cadvisor/storage/kafka
- github.com/zxbu/prom2click
- github.com/zxpbenson/timi
- github.com/zyaoyao/kafkahook-logger/logger
- github.com/zyfdegh/cadvisor/storage/kafka
- github.hscsec.cn/grafana/metrictank/cmd/metrictank
- github.hscsec.cn/grafana/metrictank/cmd/mt-fakemetrics/out
- github.hscsec.cn/grafana/metrictank/cmd/mt-fakemetrics/out/kafkamdm
- github.hscsec.cn/grafana/metrictank/input/kafkamdm
- github.hscsec.cn/grafana/metrictank/kafka
- github.hscsec.cn/grafana/metrictank/mdata/notifierKafka
- github.hscsec.cn/grafana/metrictank/publish/kafka
- github.hscsec.cn/k8guard/k8guardlibs/messaging/kafka
- github.mirror.nvdadr.com/grafana/metrictank/cmd/metrictank
- github.mirror.nvdadr.com/grafana/metrictank/cmd/mt-fakemetrics/out
- github.mirror.nvdadr.com/grafana/metrictank/cmd/mt-fakemetrics/out/kafkamdm
- github.mirror.nvdadr.com/grafana/metrictank/input/kafkamdm
- github.mirror.nvdadr.com/grafana/metrictank/kafka
- github.mirror.nvdadr.com/grafana/metrictank/mdata/notifierKafka
- github.mirror.nvdadr.com/grafana/metrictank/publish/kafka
- gitlab.com/FWangZil/go-lib/utils/kafka
- gitlab.com/aahme144/mqtt-broker/plugins/bridge
- gitlab.com/abibino-lab/mobal/common/kafka
- gitlab.com/atrico/kafkaEx
- gitlab.com/bngnha/go-plugins/broker/kafka/v2
- gitlab.com/diycoder/tech-lab/micro-plugins/kafka
- gitlab.com/doniapr-gopkg/logger
- gitlab.com/go-emat/emat-kit/kafka
- gitlab.com/go-jor/jor-kit/kafka
- gitlab.com/gobang/logger
- gitlab.com/golibs-starter/kafka-test-suite
- gitlab.com/golibs/crawler/common/kafka
- gitlab.com/itk.fr/lorhammer/src/orchestrator/checker
- gitlab.com/landru.ker/config/notifier
- gitlab.com/mfahry/go-confluent-avro
- gitlab.com/micro-lab/tech-lab/micro-plugins/kafka
- gitlab.com/otavio3/go-tracer/contrib/Shopify/sarama
- gitlab.com/rovergulf/pkg/mq/kafka
- gitlab.com/sekolahmu-public/cupang-library/logger
- gitlab.com/snarksliveshere/kafka-batch-lib/consumer
- gitlab.com/study652/highload-architect-12-2022/dialog/internal/consumer
- gitlab.com/study652/highload-architect-12-2022/social-network/cmd/api
- gitlab.com/study652/highload-architect-12-2022/social-network/internal/consumer
- gitlab.com/study652/highload-architect-12-2022/social-network/internal/producer/kafka
- gitlab.com/trademarkvision/monitoring/kafka_exporter
- gitlab.com/wkingfly/openbilibili/app/admin/main/apm/service
- gitlab.com/wkingfly/openbilibili/app/infra/canal/service/reader
- gitlab.com/wkingfly/openbilibili/app/infra/databus/tcp
- gitlab.com/wkingfly/openbilibili/app/infra/notify/notify
- gitlab.com/wkingfly/openbilibili/app/interface/openplatform/monitor-end/service
- gitlab.com/wkingfly/openbilibili/app/job/main/app-wall/service/offer
- gitlab.com/wkingfly/openbilibili/app/service/main/dapper/pkg/collect/kafkacollect
- gitlab.com/wongtawan-j/grader-extension-module/kafka
- gitlab.forevernine.net/yison/base_lib
- gitlab.lanhuapp.com/gopkgs/ikafka/sarama
- gitlab.laodianhuang.cn/oaago/component/kafka
- gitlab.ws/base/lib/common/libs/kafkaclient
- gitlab.xinghuolive.com/liujiandong/hairy/kafka
- go.anx.io/go-cloudlog
- go.ligato.io/cn-infra/examples/kafka-lib/consumer
- go.ligato.io/cn-infra/messaging/kafka
- go.ligato.io/cn-infra/messaging/kafka/client
- go.ligato.io/cn-infra/messaging/kafka/mux
- go.ligato.io/cn-infra/v2/examples/kafka-lib/consumer
- go.ligato.io/cn-infra/v2/messaging/kafka
- go.ligato.io/cn-infra/v2/messaging/kafka/client
- go.ligato.io/cn-infra/v2/messaging/kafka/mux
- go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama
- go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/example/consumer
- go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/example/producer
- go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/otelsarama
- go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/otelsarama/example/consumer
- go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/otelsarama/example/producer
- go.staging.k6.io/k6/stats/kafka
- gopkg.in/CodapeWild/dd-trace-go.v1/contrib/Shopify/sarama
- gopkg.in/DataDog/dd-trace-go.v1/contrib/Shopify/sarama
- gopkg.in/Mongey/terraform-provider-kafka.v0/kafka
- gopkg.in/daangn/dd-trace-go.v1/contrib/Shopify/sarama
- gopkg.in/flocasts/dd-trace-go.v1/contrib/Shopify/sarama
- gopkg.in/funkygao/gafka.v0/cmd/actord/executor
- gopkg.in/funkygao/gafka.v0/cmd/gk
- gopkg.in/funkygao/gafka.v0/cmd/gk/command
- gopkg.in/funkygao/gafka.v0/cmd/gk/command/kfs
- gopkg.in/funkygao/gafka.v0/cmd/gk/command/mirror
- gopkg.in/funkygao/gafka.v0/cmd/kateway/bench
- gopkg.in/funkygao/gafka.v0/cmd/kateway/gateway
- gopkg.in/funkygao/gafka.v0/cmd/kateway/store
- gopkg.in/funkygao/gafka.v0/cmd/kateway/store/dummy
- gopkg.in/funkygao/gafka.v0/cmd/kateway/store/kafka
- gopkg.in/funkygao/gafka.v0/cmd/kguard/watchers/influxdb
- gopkg.in/funkygao/gafka.v0/cmd/kguard/watchers/kafka
- gopkg.in/funkygao/gafka.v0/cmd/kguard/watchers/kateway
- gopkg.in/funkygao/gafka.v0/zk
- gopkg.in/gonet2/game.v0/kafka
- gopkg.in/kataras/iris.v11/_examples/tutorial/api-for-apache-kafka/src
- gopkg.in/linkedin/Burrow.v0
- gopkg.in/linkedin/burrow.v0
- gopkg.in/loadimpact/k6.v0/stats/kafka
- gopkg.in/mongey/terraform-provider-kafka.v0/kafka
- gopkg.in/openzipkin-contrib/zipkin-go-opentracing.v0
- gopkg.in/seborama/bevel.v1
- gopkg.in/vmware/dispatch.v0/pkg/events/transport
- knative.dev/eventing-contrib/kafka
- knative.dev/eventing-contrib/kafka/channel/pkg/dispatcher
- knative.dev/eventing-contrib/kafka/channel/pkg/kafka
- knative.dev/eventing-contrib/kafka/channel/pkg/reconciler/controller
- knative.dev/eventing-contrib/kafka/channel/pkg/reconciler/controller/resources
- knative.dev/eventing-contrib/kafka/common/pkg/kafka
- knative.dev/eventing-contrib/kafka/source/pkg/adapter
- knative.dev/eventing-contrib/test/test_images/kafka-publisher
- knative.dev/eventing-contrib/test/test_images/kafka_performance
- knative.dev/eventing-kafka/pkg/common/client
- knative.dev/eventing-kafka/pkg/common/commands/resetoffset/controller/testing
- knative.dev/eventing-kafka/pkg/common/config
- knative.dev/eventing-kafka/pkg/common/config/testing
- knative.dev/eventing-kafka/pkg/common/consumer
- knative.dev/eventing-kafka/pkg/common/kafka/offset
- knative.dev/eventing-kafka/pkg/common/kafka/sarama
- knative.dev/eventing-kafka/pkg/common/kafka/testing
- knative.dev/eventing-kafka/pkg/common/testing
- knative.dev/eventing-kafka/pkg/common/tracing
- knative.dev/eventing-kafka/pkg/source/adapter
- knative.dev/eventing-kafka/pkg/source/client
- knative.dev/eventing-kafka/pkg/source/reconciler/common
- knative.dev/eventing-kafka/pkg/source/reconciler/mtsource
- knative.dev/eventing-kafka/test/test_images/kafka-publisher
- knative.dev/eventing-kafka/test/test_images/kafka_performance
- knative.dev/eventing-kafka/test/upgrade/continual
- open-gitlab.going-link.com/operation-sre/volc-sdk/example/dts/data-subscription-demo
- storj.io/minio/pkg/event/target
- trpc.group/trpc-go/trpc-opentracing-zipkin
- weavelab.xyz/watermill-kafka/pkg/kafka
- xgit.xiaoniangao.cn/xngo/lib/kafka-consumer/kafka