Go to main page
Known importers: 2,865 (displaying 3,657 packages, including internal and invalid packages)
- bitbucket.org/Dartonian/common-bus
- bitbucket.org/InvolvedPanda/notifier
- bitbucket.org/cornjacket/event_processor/client_lib
- bitbucket.org/cornjacket/view_hndlr/client_lib
- bitbucket.org/krjura/kafka-tools-golang/mfilters
- bitbucket.org/krupnik_a/logclient
- bitbucket.org/markfwalker/atom
- bitbucket.org/rctiplus/vegapunk/event/kafka
- dev.aminer.cn/gopkg/ppl/transformer/ds
- e.coding.net/nimrc/micro/go-plugins/broker/segmentio
- git.logicamp.top/Logucation/base/messageBroker
- git.lowcodeplatform.net/packages/logger
- git.pinjamwinwin.com/aidc/framework/v2/kafka
- git.proto.group/protoobp/pobp-trace-go/contrib/segmentio/kafka.go.v0
- git.qvant.ru/go-libs/kafka
- git.qvant.ru/go-libs/kafka/mocks
- git.qvant.ru/go-libs/kafka/reader
- git.qvant.ru/go-libs/kafka/reader/mocks
- git.qvant.ru/go-libs/kafka/v2
- git.qvant.ru/go-libs/kafka/v2/mocks
- git.qvant.ru/go-libs/kafka/v2/reader
- git.qvant.ru/go-libs/kafka/v2/reader/mocks
- git.qvant.ru/go-libs/kafka/v2/writer
- git.qvant.ru/go-libs/kafka/v2/writer/mocks
- git.qvant.ru/go-libs/kafka/writer
- git.qvant.ru/go-libs/kafka/writer/mocks
- gitee.com/flash520/pusher/pkg/connector
- gitee.com/go-course/go8/projects/devcloud/maudit/client/bus
- gitee.com/go-kade/mcube/ioc/config/kafka
- gitee.com/jingyixiusheng/common-until/helper/kafkahelper
- gitee.com/liu-fudan/devcloud/maudit/client/bus
- gitee.com/monitor_dev/alerts-management/alerts-receiver/drivers/kafka
- gitee.com/rancher/rancher/pkg/controllers/user/logging/utils
- gitee.com/sasukebo/go-micro/plugins/broker/segmentio/v4
- gitee.com/shijingzhao/go-frame/zkafka
- gitee.com/tylf2018/go-micro-framework/pkg/kafka
- gitee.com/uucode/golib
- gitee.com/wshadm/go11/devcloud-mini/maudit/clients/middleware
- gitee.com/wxlao/logger
- gitee.com/zhoushuyu/devcloud/maudit/client/bus
- gitfin.haiziwang.com/golang/tgo/mq/kafka
- github.1git.de/rancher/rancher/pkg/controllers/user/logging/utils
- github.com/0angelic0/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/0x5w4/kredit-plus/api-gateway-service/internal/kredit/commands
- github.com/0x5w4/kredit-plus/pkg/kafka
- github.com/0x5w4/kredit-plus/reader-service/internal/kredit/delivery/kafka
- github.com/0x5w4/kredit-plus/reader-service/internal/server
- github.com/0x5w4/kredit-plus/writer-service/internal/kredit/commands
- github.com/0x5w4/kredit-plus/writer-service/internal/kredit/delivery/kafka
- github.com/0x5w4/kredit-plus/writer-service/internal/server
- github.com/0xcregis/easynode/blockchain/service
- github.com/0xcregis/easynode/collect
- github.com/0xcregis/easynode/collect/service/cmd
- github.com/0xcregis/easynode/collect/service/db
- github.com/0xcregis/easynode/collect/service/monitor
- github.com/0xcregis/easynode/common/kafka
- github.com/0xcregis/easynode/store/chain
- github.com/0xcregis/easynode/store/service
- github.com/0xcregis/easynode/task
- github.com/0xcregis/easynode/task/service/taskcreate
- github.com/0xcregis/easynode/task/service/taskcreate/db
- github.com/0xcregis/easynode/taskapi/service
- github.com/0xrawsec/golang-evtx/output
- github.com/108356037/common-lib/mq
- github.com/1pkg/gohalt
- github.com/2276282419/gocore/gokafka
- github.com/2908755265/eventhorizon/eventbus/kafka
- github.com/2997215859/gomdsdk/consumer
- github.com/4ND3R50N/testsetup/container
- github.com/508284405/leetcode2/kafka
- github.com/510909033/redisx/demo_kafka
- github.com/51xpx/pkgx/pkg/kafkax
- github.com/7leven7/xm-company-crud/app/controllers
- github.com/AbdulRahimOM/gov-services-app/user-api-gateway/internal/handler/kseb-handler
- github.com/AlexEr256/messageService/consumer/cmd
- github.com/Alibay/go-kit/kafka
- github.com/AmanKumar2696/sidekick/outputs
- github.com/Amirhossein2000/RequestTasker/internal/infrastructures/kafka
- github.com/Apicurio/apicurio-registry-k8s-tests-e2e/testsuite/utils/converters
- github.com/ApollosProject/pgstream-wal2json/pkg/kafka
- github.com/Bendomey/nucleo-go/transit/kafka
- github.com/BitofferHub/pkg/middlewares/mq
- github.com/Bitummit/go_auth/internal/api/kafka
- github.com/BobZombiE69/btcpool-go-modules/chainSwitcher
- github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/api
- github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/http_handlers
- github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/kafka_handlers
- github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/nats_handlers
- github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/scheduler_handlers
- github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/infrastructure
- github.com/CG-SS/right-to-reign-go-backend/libs/ebs
- github.com/Caixetadev/fraud-check-kafka-integration/transaction/pkg/kafka
- github.com/Clarilab/eventhorizon/eventbus/kafka
- github.com/CloudyCity/cpkg/db
- github.com/Cobalt0s/creme-brulee/pkg/tech/kmanager
- github.com/Code-Pundits/go-logger
- github.com/DarkJediDJ/support-chat/reciever-service/cmd/reciever-service
- github.com/DarkJediDJ/support-chat/reciever-service/internal
- github.com/DarkJediDJ/support-chat/sender-serice/api
- github.com/DarkJediDJ/support-chat/sender-serice/api/sender
- github.com/DarkJediDJ/support-chat/sender-serice/cmd/sender-service
- github.com/DeBankDeFi/nodex/pkg/kafka
- github.com/DmitriiDobr/kafkaNotification/pkg
- github.com/DoodleScheduling/k8skafka-controller/kafka
- github.com/EdgeCast/vflow/producer
- github.com/Encounter27/eh-outbox/projector
- github.com/EricWorld/eventstream-go-sdk/v3
- github.com/Espina2/event-bus/kafka
- github.com/EvWilson/sqump/exec
- github.com/Evertras/events-demo/shared/stream
- github.com/Evolvra/gofr-evolvra/pkg/gofr/datasource/pubsub/kafka
- github.com/Falokut/admin_casts_service/internal/events
- github.com/Falokut/admin_genres_service/internal/events
- github.com/Falokut/admin_geo_service/internal/events
- github.com/Falokut/admin_movies_persons_service/internal/events
- github.com/Falokut/admin_movies_service/internal/events
- github.com/Falokut/cinema_orders_service/internal/events
- github.com/Falokut/profiles_service/internal/events
- github.com/Ferrany1/system-tools/pkg/pubsub/kafka
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/publish
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/publish/testing
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/subscribe
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/subscribe/testing
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/volume/messagequeue
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/volume/messagequeue/publish
- github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/volume/messagequeue/subscribe
- github.com/GeoDB-Limited/odincore/chain/hooks/emitter
- github.com/Guise322/TeleBot/client/pkg/broker
- github.com/HXSecurity/DongTai-agent-go/core/kafkaGo/kafkaWriter
- github.com/HekapOo-hub/Kafka/producer
- github.com/Hsiangya/logger
- github.com/InfluxCommunity/flux/stdlib/kafka
- github.com/InspectorVitya/znakvlg-backend/internal/mq
- github.com/JMURv/e-commerce/gateway/pkg/controllers
- github.com/JailtonJunior94/devkit-go/pkg/messaging/kafka
- github.com/JakubDaleki/transfer-app/shared-dependencies/kafka
- github.com/JanMeckelholt/myaktion-go/src/banktransfer/kafka
- github.com/Junjiayy/hamal/pkg/core/readers
- github.com/Katherine-988/tools
- github.com/Kevinello/kafka-client
- github.com/KotFed0t/notification_service/data/queue/kafka/notificationConsumer
- github.com/Leila-Codes/events-io/plugins/kafka
- github.com/LoneWolf38/kafka-go/topics
- github.com/M-Fisher/companies_api/app/internal/services/events/clients/kafka
- github.com/MajotraderLucky/Kafka-FIO-Listener/apiconfig
- github.com/ManyakRus/starter/kafka_connect
- github.com/Mario-Jimenez/datapub/broker/kafka
- github.com/Mutezebra/tiktok/pkg/kafka
- github.com/Muxi-X/forum-be/model
- github.com/NOVAPokemon/notifications/kafka
- github.com/NSObjects/ima/internal/pump/pumps
- github.com/NickTaporuk/gigamock/src/scenarioType
- github.com/Nixson/kafka
- github.com/ODIM-Project/ODIM/lib-messagebus/datacommunicator
- github.com/PAWSOME-INDONESIA/paw_kit/messaging/kafka
- github.com/PacktPublishing/Mastering-Go-Second-Edition/ch14
- github.com/Peshowe/issue-tracker/tracker-service/event-publisher/kafka
- github.com/PinataCloud/convoy-go/v2
- github.com/Pos1t1veM1ndset/shiny-homework/hw12_13_14_15_calendar/internal/kafkascheduler
- github.com/RHEnVision/provisioning-backend/internal/kafka
- github.com/RapidCodeLab/ZapLogger
- github.com/RedHatInsights/haberdasher/emitters
- github.com/RedHatInsights/kafka-zerolog/kafkazerolog
- github.com/RedHatInsights/sources-api-go/kafka
- github.com/RonkyTang/go-queue/kq
- github.com/RumbiaID/pkg-library/app/pkg/broker/kafkaservice
- github.com/SENERGY-Platform/device-command/pkg/configuration
- github.com/SENERGY-Platform/moses/lib/config
- github.com/SENERGY-Platform/mqtt-platform-connector/lib/configuration
- github.com/SENERGY-Platform/process-deployment/lib/kafka
- github.com/SENERGY-Platform/process-sync/pkg/kafka
- github.com/Sabyradinov/go-prometheus-kafka
- github.com/Samuelfaure/go-tracker/messenger
- github.com/ServiceNow/kafka-go/topics
- github.com/Sh-Fang/kfkp
- github.com/Shoothzj/cli/pkg
- github.com/SteveHNH/go-test-app
- github.com/SyaibanAhmadRamadhan/event-bus/kafka
- github.com/Tangerg/lynx/core/broker
- github.com/TheDao032/golang-architectures-demo/internal/api/kafka
- github.com/TingYunGo/goagent/mq/kafka/kafka-go
- github.com/Tuhis/edge-receiver/pkg/kafkawrapper
- github.com/TykTechnologies/tyk-pump/pumps
- github.com/Vonage/gosrvlib/pkg/kafka
- github.com/Yostardev/skuld/mq/xkafka
- github.com/Zeb-D/go-util/mq
- github.com/a-blender/rancher/pkg/controllers/user/logging/utils
- github.com/aaabigfish/gopkg/mq/kafka
- github.com/aadheeb/gomiddleware-beagle
- github.com/aanthord/temporalio_poc/create_jobposting
- github.com/aanthord/temporalio_poc/create_orgwallet
- github.com/aanthord/temporalio_poc/create_wallet
- github.com/aanthord/temporalio_poc/kfka
- github.com/aanthord/temporalio_poc/validate_wallet
- github.com/aanthord/temporalio_poc/validate_wallet/worker
- github.com/aaronrancher/rancher/pkg/controllers/user/logging/utils
- github.com/ability-sh/abi-micro/mq
- github.com/abo-yes/go-kafka/listener
- github.com/abstructs/newsfeed/adapters
- github.com/abulo/ratel/kafka
- github.com/aceeric/kafka-scale
- github.com/acidonper/jump-app-golang-events/pkg
- github.com/acornpublishing/mastering-go-2e/ch14
- github.com/adimax2953/go-tool/kafkatool
- github.com/adityaeka26/go-pkg/kafka
- github.com/aedobrynin/soa-hw/core/internal/repo/statisticsrepo
- github.com/agclqq/prow-framework/queue
- github.com/agem-io/agem/pkg/util/kafka_receiver
- github.com/agitdevcenter/gopkg/transport/example/kafka/service
- github.com/ajarv/kafgo/cmd
- github.com/ajruckman/vflow/producer
- github.com/akazwz/gin-api/kafka/counter
- github.com/akshitIsFuture/Parking-lot-Service/messanger
- github.com/akshitisfuture/parking-lot-service/messanger
- github.com/al-soft/testkafkabenchmark/internal/kafkag
- github.com/aleksbgs/projectf/server
- github.com/alekssum/go-playground/kafka/cmd/producer
- github.com/alex-kuck/apm-kafka-go
- github.com/alexandria-oss/streams/driver/kafka
- github.com/alexjohnkennedy/rickrollrankings/LinkChecker/kafkaconsumerproducer
- github.com/alextanhongpin/go-kafka
- github.com/alextanhongpin/go-kafka/01-partition-hash
- github.com/alextanhongpin/go-kafka/02-producer-consumer
- github.com/alextanhongpin/go-kafka/03-list-topics
- github.com/alextanhongpin/go-kafka/04-reader
- github.com/alextanhongpin/go-kafka/05-add-partition-to-topic
- github.com/alextanhongpin/go-kafka/06-consumer-groups-autocommit
- github.com/alextanhongpin/go-kafka/07-consumer-groups-manualack
- github.com/alextanhongpin/go-kafka/08-writer
- github.com/alextanhongpin/go-kafka/09-poison-pill
- github.com/alfex4936/golang-studies/kafka/basic_producer
- github.com/alirezashaheri/kafka-go/topics
- github.com/allen9009/kafka-logger-go
- github.com/alpersimsek1/rabbitmqtokafkagoexample
- github.com/alserov/restate/metrics/internal/async
- github.com/alxandru/client-vehicletracking/pkg/kafka
- github.com/amirhnajafiz/debezium/connector/internal/kafka
- github.com/amitch-git/test-kafka-event-with-microservice/PunchingSystem
- github.com/amyglan/kafka-go-fork/topics
- github.com/andibalo/ramein/commons/kafka
- github.com/andrewmeissner/terraform-provider-kafka/kafka
- github.com/andrewwormald/workflow/adapters/kafkastreamer
- github.com/andser91/otel-kafka-go
- github.com/andy-ua/kafkaservice/service
- github.com/andyVB2012/referral-service/kafka
- github.com/anexia-it/tyk-pump/pumps
- github.com/angel-one/amx-margin/utils/kafka
- github.com/angelo-chan/eventstream-go-sdk/v3
- github.com/annchain/BlockDB/plugins/server/kafka
- github.com/anooshcnayak/butterfly-go
- github.com/antonpriyma/otus-highload/pkg/clients/dwh
- github.com/apache/skywalking-go/plugins/segmentio-kafka
- github.com/apoorvprecisely/go-base/base/transport/kafka
- github.com/aravindan-palani/golangtask/KAFKA
- github.com/arista-netdevops-community/cvp-events-pubsub/pkg
- github.com/arjun-1/kafkagosaur/src/kafkagosaur
- github.com/arkangle/tennisscore/scorer/cmd/kafkanated
- github.com/armnerd/go-skeleton/pkg/kafka
- github.com/arquivei/goduck/impl/implstream/kafkasegmentio
- github.com/arsfox/xk6-kafka
- github.com/arshabbir/kafkaprodconsumer/clients
- github.com/art-es/blog/internal/auth/infra/databus_kafka
- github.com/asemyannikov-vi/vp-nano-lib/models/observers/kafka
- github.com/ashleighj/kafkaclient
- github.com/asians-cloud/crowdsec/pkg/acquisition/modules/kafka
- github.com/aslakjohansen/kafka-receiver
- github.com/aspring/kapacitor/services/kafka
- github.com/assist-by/absignal
- github.com/assylzhan-a/company-task/internal/kafka
- github.com/astromechza/score-eg-kafka-provisioner
- github.com/astrviktor/banner-rotation/internal/storage/sql
- github.com/atulanand206/go-kafka
- github.com/auho/go-toolkit/kafka/describes
- github.com/av-ugolkov/lingua-evo/internal/delivery/kafka
- github.com/axdbertuol/goauthx/internal/services/kafka_consumer
- github.com/aykay76/kwatch
- github.com/azarakovskiy/kafka-go/topics
- github.com/baetyl/baetyl-remote/baetyl-remote-kafka
- github.com/balabanovds/containers/kafka
- github.com/bangumi/server/canal
- github.com/bangunindo/trap2json/forwarder
- github.com/barshat7/go-advanced/gokafka
- github.com/baxromumarov/my-services/user-service/events
- github.com/beihai0xff/pudding/pkg/mq/kafka
- github.com/benesch/kafkagen
- github.com/benmeehan/mqtt-relay/queue
- github.com/bernardtsai/solar/src/tsai.eu/solar/msg
- github.com/betacat-co/pkgx/kafkax
- github.com/bharath-b-hpe/odimra/lib-messagebus/datacommunicator
- github.com/bhochhi/kafka-guide/go-kafka-consumer/consumer
- github.com/bhorovyi/xk6-kafka
- github.com/bigzhuk/kafka-adapter
- github.com/bingxindan/bxd_queue/kafka
- github.com/blacklane/tahiti-utils/pkg/messengers
- github.com/blink-io/x/kafka/segmentio/registrar
- github.com/blippp/golang-kafka
- github.com/blu3blaze/kafka-http-bridge
- github.com/blueai2022/vtmicrosvc
- github.com/bluexlab/emitter
- github.com/bobzombie69/btcpool-go-modules/chainSwitcher
- github.com/boomerlang/volgre_flow_processor/servers
- github.com/brandoshmando/backfill
- github.com/brave-intl/challenge-bypass-server/kafka
- github.com/brave/tokenizer
- github.com/brilliant-monkey/go-kafka-client
- github.com/brunodelucasbarbosa/learning-go/api-gochi
- github.com/brunosantosnet/template-consumer-kafka/cmd/server
- github.com/bryce4651/pkg/kfk
- github.com/bsergik/tough-dev/services/inventory/internal/message-broker/kafka
- github.com/c2dp/zenutil
- github.com/carameleon/exchain/x/stream/kafkaclient
- github.com/cattlebot/test-mirror/pkg/controllers/user/logging/utils
- github.com/cblomart/vsphere-graphite/backend
- github.com/ccamel/go-graphql-subscription-example/server
- github.com/ce-final-project/backend_game_server/account/internal/account/delivery/kafka
- github.com/ce-final-project/backend_game_server/account/internal/server
- github.com/ce-final-project/backend_game_server/authentication/internal/server
- github.com/ce-final-project/backend_game_server/gateway/internal/auth/commands
- github.com/ce-final-project/backend_game_server/pkg/kafka
- github.com/ce-final-project/backend_game_server/pkg/tracing
- github.com/ce-final-project/backend_rest_api/account_service/internal/account/commands
- github.com/ce-final-project/backend_rest_api/account_service/internal/account/delivery/kafka
- github.com/ce-final-project/backend_rest_api/account_service/internal/server
- github.com/ce-final-project/backend_rest_api/pkg/kafka
- github.com/ce-final-project/backend_rest_api/pkg/tracing
- github.com/celer-network/goutils/kaf
- github.com/celerway/metamorphosis/bridge/kafka
- github.com/cemayan/url-shortener/managers/mq
- github.com/chakradharkh/rancher/pkg/controllers/user/logging/utils
- github.com/chaos-mesh/chaosd/pkg/server/chaosd
- github.com/chefcookit/vod-kafka
- github.com/chenjie199234/config/config
- github.com/chenquan/go-queue/kafka
- github.com/chinalongxia/rancher/pkg/controllers/user/logging/utils
- github.com/chipong/template/common/mvlog
- github.com/chiukapoor/rancher/pkg/controllers/user/logging/utils
- github.com/chnmk/vue-go-playground/main/transport/kafka
- github.com/chojy/indexer
- github.com/chrismarsilva/cms-golang/cms.golang.teste.messageria/cms.golang.teste.kafka.segmentio
- github.com/chrismoos/caddy-events-kafka
- github.com/chrono2002/tmp/code/monomach/monomach-go
- github.com/ciblele/siemens-energy/Rascunhos
- github.com/cision-prcomms/oip-influencer-commons/kafka
- github.com/cloud01-wu/cgsl/kafkax
- github.com/cloudevops101/go-kafka-consumer
- github.com/cmiwjaeger/edot-user-service/internal/config
- github.com/cmurphy/rancher/pkg/controllers/user/logging/utils
- github.com/cntechpower/utils/log
- github.com/co60ca/kafkapublish
- github.com/coccyx/gogen/outputter
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/business_transactions/after
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/cdc
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/etl/after
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/etl/before/services/consumer
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/etl/before/services/etl
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/polling_clients/after
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/queue_coherence/after
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/queue_coherence/before
- github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/queue_coherence/before/errors
- github.com/cockroachdb/architectural-simplification/002_hyper_specialized_dbs/data_fragmentation/before/services/indexer
- github.com/codeuniversity/smag-mvp/api/grpcserver
- github.com/codeuniversity/smag-mvp/api/grpcserver/main
- github.com/codeuniversity/smag-mvp/cli/main
- github.com/codeuniversity/smag-mvp/elastic/indexer
- github.com/codeuniversity/smag-mvp/face-recognition
- github.com/codeuniversity/smag-mvp/insta/filter/post_face-recon
- github.com/codeuniversity/smag-mvp/insta/filter/post_pictures
- github.com/codeuniversity/smag-mvp/insta/filter/user_names
- github.com/codeuniversity/smag-mvp/insta/inserter/comments
- github.com/codeuniversity/smag-mvp/insta/inserter/likes
- github.com/codeuniversity/smag-mvp/insta/inserter/postgres
- github.com/codeuniversity/smag-mvp/insta/inserter/posts
- github.com/codeuniversity/smag-mvp/insta/inserter/posts_face
- github.com/codeuniversity/smag-mvp/insta/pics-downloader
- github.com/codeuniversity/smag-mvp/insta/posts_face-detection
- github.com/codeuniversity/smag-mvp/insta/scraper/comments
- github.com/codeuniversity/smag-mvp/insta/scraper/likes
- github.com/codeuniversity/smag-mvp/insta/scraper/posts
- github.com/codeuniversity/smag-mvp/insta/scraper/user
- github.com/codeuniversity/smag-mvp/kafka
- github.com/codeuniversity/smag-mvp/kafka/changestream
- github.com/codeuniversity/smag-mvp/neo4j/create-import-user-json
- github.com/codeuniversity/smag-mvp/neo4j/inserter
- github.com/codeuniversity/smag-mvp/twitter/filter/user_names
- github.com/codeuniversity/smag-mvp/twitter/inserter/posts
- github.com/codeuniversity/smag-mvp/twitter/inserter/users
- github.com/cody0704/kafka-go/topics
- github.com/coming-chat/go-sui-indexer/customer
- github.com/conwaychriscosmo/realtime-evaluation-api
- github.com/corneredrat/image-server/api-server/notifier
- github.com/country7/go-lessons-mastering-go/ch14-Machine-learning
- github.com/crawlab-team/crawlab-go-sdk/database
- github.com/crobby/rancher/pkg/controllers/user/logging/utils
- github.com/crowdsecurity/crowdsec/pkg/acquisition/modules/kafka
- github.com/crwnl3ss/watchdoge/pkg/check
- github.com/cs3org/reva/v2/pkg/storage/fs/posix/tree
- github.com/cursed-ninja/go-kafka-producer
- github.com/cybertec-postgresql/debezium2postgres/internal/kafka
- github.com/cylowatt/go-playground-kafka
- github.com/daemtri/begonia/driver/kafka
- github.com/dairongpeng/leona/internal/gstash/gstashs
- github.com/damonbenson/go-kafka/main
- github.com/danial2026/file-sharing-go/controllers/kafka
- github.com/danielpilon/go-kafka-poc
- github.com/danielunderwood/feed-ingress
- github.com/danilomarques1/gafka
- github.com/darccio/dd-trace-go/v2/contrib/segmentio/kafka.go.v0
- github.com/darron/aiven/cmd
- github.com/darth-raijin/challenger/internal/messagers
- github.com/databendcloud/bend-ingest-kafka
- github.com/dauren10/kafka_docker
- github.com/davidtrse/graceful/kafkas
- github.com/daylikon/xk6-kafka
- github.com/daymenu/study/go/examples/kafka
- github.com/dbgjerez/workshop-keda/apps/camera-api/src/services
- github.com/ddvkid/learngo/internal/kafkaBuilder
- github.com/deflect-ca/banjax/internal
- github.com/delanri/commonutil/messaging/kafka
- github.com/dell/iDRAC-Telemetry-Reference-Tools/internal/messagebus/kafka
- github.com/demonoid81/dsp/events/kafkaMessage
- github.com/denlipov/com-request-facade/internal/consumer
- github.com/designerasun/golang/MasteringGo/ch14
- github.com/desnia/eventstream-go-sdk/v3
- github.com/destrex271/pgwatch3_rpc_server/cmd/kafka_prod_receiver
- github.com/detohm/go-study/kafka/basic
- github.com/dev-ansh-r/dcalpwan-server/internal/integration/kafka
- github.com/dev-mockingbird/events
- github.com/devansh42/kafka-poc
- github.com/devicechain-io/dc-event-sources
- github.com/devplayg/kafka/create-topic
- github.com/devyk100/gengou-db/internal/kafka_internal
- github.com/dewidyabagus/monorepo/datasource/messaging
- github.com/diazoxide/easy-kafka
- github.com/diego3/kafka-microservices/lib
- github.com/diki-haryadi/govega/event/kafka
- github.com/diliprenkila/go-dss/kafka
- github.com/dilshodforever/4-oyimtixon-auth-service/kafka
- github.com/dilyara4949/email-push-service/internal/kafka
- github.com/dimaglushkov/epam-xm-test-assignment/internal/events
- github.com/dimaspriyo/golib/kafka
- github.com/dimonk33/kdv_hw_otus/hw12_13_14_15_calendar/internal/queue/kafka
- github.com/dimonleksin/kurl/pkg/kfk
- github.com/dimpogissou/isengard-server/connectors
- github.com/dinosoupy/pod
- github.com/diogoasouza/rancher/pkg/controllers/user/logging/utils
- github.com/diy-cloud/log-silo
- github.com/djbanodkar/ranchertesting/pkg/controllers/user/logging/utils
- github.com/djkazic/kafka-go/topics
- github.com/dm874-devops-2019-group-2/dm874-auto-reply/test
- github.com/dmachard/go-dnscollector/workers
- github.com/dmitryshcherbakov/grpc
- github.com/dongzhouzhoudz/gotools/pkg
- github.com/dotunj/pvent/producer
- github.com/dr-dro/jkafka-go
- github.com/dragtor/k8s-events-hub
- github.com/dreamsofcode-io/testcontainers/pubsub
- github.com/drio/go-lambda-kafka/handler/producer
- github.com/dsi-icl/acacia/packages/acacia-user-service/msgBroker
- github.com/dtkmn/go-playground
- github.com/duy-ly/nomios-go/publisher/kafka
- github.com/duythinht/tg/lib/store/kafka
- github.com/dwprz/prasorganic-notification-service/src/core/broker/delivery
- github.com/dylanjfeehan/conf-agenda
- github.com/dzonint/go-notify/kafka
- github.com/ea67/gocore/gokafka
- github.com/easonchen147/foundation/kafka
- github.com/ebar-go/ego/component/kafka
- github.com/ecoderat/go-kafka-hook/cmd
- github.com/eden-framework/plugin-kafka/kafka
- github.com/egustafson/sandbox/go/kafka-segmentio-01
- github.com/ekifel/shop_proto/auth/internal/kafka
- github.com/elbombardi/go_kafka_producer_demo
- github.com/eltats/message-service/pkg/kafka
- github.com/encounter27/eh-outbox/projector
- github.com/enrichman/rancher/pkg/controllers/user/logging/utils
- github.com/equalitie/banjax-next/internal
- github.com/erda-project/erda-infra/providers/kafkav2
- github.com/ericyeungcode/caliber
- github.com/erupshis/effective_mobile/internal/msgbroker
- github.com/esequielvirtuoso/go_kafka_sample/src/internal/infrastructure/kafka
- github.com/estebmaister/go_practice/queues
- github.com/estuary/dekaf/_examples/hello-world
- github.com/etecs-ru/gnomock/preset/kafka
- github.com/evanzhang87/evans-tools/cmd/kafka-go/consumer
- github.com/everFinance/arseeding
- github.com/everbslab/rabbit_vs_kafka/kafka/producer/go
- github.com/explicitnull/kafkacommon
- github.com/ezhdanovskiy/companies/internal/kafka
- github.com/faozimipa/go-cqrs-es/internal/app
- github.com/faozimipa/go-cqrs-es/internal/bankAccount/delivery/kafka/elasticsearch_subscription
- github.com/faozimipa/go-cqrs-es/internal/bankAccount/delivery/kafka/mongo_subscription
- github.com/faozimipa/go-cqrs-es/pkg/es
- github.com/faozimipa/go-cqrs-es/pkg/kafka
- github.com/faozimipa/go-cqrs-es/pkg/tracing
- github.com/farhann1124/rancher/pkg/controllers/user/logging/utils
- github.com/fastbpmn/go-study/kafka
- github.com/fastock/fastock-chain/x/stream/kafkaclient
- github.com/fcristovao/await
- github.com/fdamador/kapacitor/services/kafka
- github.com/feggah/kpub
- github.com/felipefbs/testcontainers/connections/queue
- github.com/feliperyan/drone-tracking-simulator
- github.com/felixa1996/go-plate/infrastructure/broker
- github.com/ferras777/xk6-kafka
- github.com/festum/gopkg/kafka
- github.com/fingertge/public/service/kafka
- github.com/fizzse/gobase/pkg/mq/kafka
- github.com/flash520/pusher/pkg/connector
- github.com/flyznex/klog-plugin
- github.com/fmo/football-data
- github.com/fnunezzz/kong-kafka-request-logger-plugin
- github.com/fonluc/bluesoft-bank/internal/messaging
- github.com/foursking/ztgo/core/log
- github.com/fourstring/sheetfs/common_journal
- github.com/fpytloun/alertmanager2kafka
- github.com/franciscosbf/free-market-common/pkg/clients/kafka
- github.com/freetsdb/freetsdb/services/flux/functions/outputs
- github.com/freundallein/resender/producers
- github.com/gabriel-ross/gofhir
- github.com/gagangoku/kafka-tasker
- github.com/gbevan/lucygw/handlers
- github.com/gdfragoso/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/gditsec/crawlab-go-sdk/database
- github.com/geiqin/go-plugins/broker/segmentio/v2
- github.com/georgeyord/go-url-shortener/api/actions
- github.com/georgeyord/go-url-shortener/cli/commands
- github.com/georgeyord/go-url-shortener/pkg/config
- github.com/georgeyord/go-url-shortener/pkg/kafka
- github.com/georgeyord/go-url-shortener/pkg/kafka/readers
- github.com/georgeyord/go-url-shortener/pkg/test/common
- github.com/gerhardardon/so1_1s2024__202004796/PROYECTO2/code/goClient
- github.com/gestgo/gest/package/extension/kafkafx
- github.com/gfa-inc/gfa/common/mq/kafkax
- github.com/ggerrietts/leadpipe-go/pkg/kafka
- github.com/gguridi/benchmark-kafka-go-clients/kafkago
- github.com/ggxxll/core-processor-demo/handler
- github.com/ghenoo/microservices-go/cmd/producer
- github.com/gig/orion-go-sdk/transport/kafka
- github.com/gihyunk/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/gingfrederik/eventhorizon/eventbus/kafka
- github.com/giovani-sirbu/mercury/messagebroker
- github.com/git-ival/rancher/pkg/controllers/user/logging/utils
- github.com/gkganesh126/nokia-interview/controllers
- github.com/glean-go/kafkaclient
- github.com/glebpepega/proj/internal/server
- github.com/gmlalfjr/go-service-kit/kafka
- github.com/gnaydenova/notification-system/app/notifications
- github.com/go-alive/go-plugins/broker/segmentio
- github.com/go-gotop/kit/broker/kafka
- github.com/goal-web/queue/drivers
- github.com/gogo-lib/superlog
- github.com/goinline/agent/mq/kafka/kafka-go
- github.com/gokit/actorkit/pubsubs/kafka/segments
- github.com/golly-go/plugins/kafka
- github.com/gotomicro/cetus/xkafka
- github.com/gotomicro/ego-component/ekafka
- github.com/gotomicro/ego-component/ekafka/consumerserver
- github.com/gotomicro/ego-component/ekafka/examples
- github.com/gotomicro/ego-component/ekafka/examples/consumerserver
- github.com/gotomicro/ego-component/ekafka/examples/consumerservertrace
- github.com/gotomicro/ego-component/ekafka/examples/trace
- github.com/gozelus/gokafka
- github.com/guacsec/guac/pkg/handler/collector/s3/messaging
- github.com/guicostaarantes/go-auth/utils/stream
- github.com/gunsluo/go-example/kafka
- github.com/gusarow4321/TinyChat/messenger/internal/pkg/kafka
- github.com/gustavobertoi/realtime/pkg/pubsub
- github.com/guylaor/go_playground/kafka
- github.com/gvencadze/hezzl_gRPC/pkg/logger
- github.com/gw123/gutils/kafka
- github.com/gzorm/common/core/go-queue/kq
- github.com/hahahannes/e2e-go-utils/lib/streaming/kafka
- github.com/halilylm/logruskafka
- github.com/hamedkazemi/tinytik/common
- github.com/hanapedia/the-bench/service-unit/internal/infrastructure/egress/producer_adapter/kafka
- github.com/hanapedia/the-bench/service-unit/internal/infrastructure/ingress/consumer_adapter/kafka
- github.com/hanapedia/the-bench/service-unit/stateless/internal/infrastructure/egress/producer_adapter/kafka
- github.com/hanapedia/the-bench/service-unit/stateless/internal/infrastructure/ingress/consumer_adapter/kafka
- github.com/hanapedia/the-bench/service-unit/stateless/internal/infrastructure/telemetry/tracing/kafka
- github.com/hari134/pratilipi/pkg/kafka
- github.com/harmol/k8s/pkg/kafka
- github.com/harrisonwaffel/rancher/pkg/controllers/user/logging/utils
- github.com/harunrasyid/sutinah
- github.com/hawkj/my_iot/common/pkg/queue
- github.com/hbouvier/function-simple-kafka-consumer/kafka-message
- github.com/hchek/kafkaHelper
- github.com/hd-li/lord/pkg/controllers/user/logging/utils
- github.com/heffcodex/kafka-go-example
- github.com/hegeng1212/skywalking-go/plugins/segmentio-kafka
- github.com/hekapoo-hub/kafka/producer
- github.com/henryhcheung1/twitter-kafka-elasticsearch/src/helper/kafkaHelper
- github.com/herhu/Microservices-PR/api_gateway_service/internal/products/commands
- github.com/herhu/Microservices-PR/pkg/kafka
- github.com/herhu/Microservices-PR/pkg/tracing
- github.com/herhu/Microservices-PR/reader_service/internal/product/delivery/kafka
- github.com/herhu/Microservices-PR/reader_service/internal/server
- github.com/herhu/Microservices-PR/writer_service/internal/product/commands
- github.com/herhu/Microservices-PR/writer_service/internal/product/delivery/kafka
- github.com/herhu/Microservices-PR/writer_service/internal/server
- github.com/heshaofeng1991/core/middlewares/kafka
- github.com/highlight-run/highlight/backend/kafka-queue
- github.com/hlsana/golang-course/hw18/internal/kafka
- github.com/hoangxt/go-ecommerce-ba-api/cmd/cli/kafka
- github.com/hojongs/kafka-go-server-pilot/src
- github.com/horoshi10v/grpc-experiment/server/pubsub
- github.com/hound672/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/housepower/clickhouse_sinker/input
- github.com/hrapovd1/msg-proc/internal/msgbus
- github.com/hrittikhere/kafka-demo
- github.com/hrojas2021/go-kafka-mongodb/pkg/kafka/segmentio
- github.com/htol/skp
- github.com/htquangg/microservices-poc/internal/kafka
- github.com/httpoz/kafka-go-kata
- github.com/hugoatease/garfunkel
- github.com/hurricane1988/harbor-webhook/pkg/sources/kafka
- github.com/hurx/coverser/util/kafka
- github.com/hyo2005/kafka-demo
- github.com/i-sevostyanov/k8s-playground/internal/infrastructure/kafka
- github.com/iaai315313/gocore/gokafka
- github.com/iacuity/datastore-connector/kafka
- github.com/icemanaf/sensorhttpapi
- github.com/iddqdeika/kafka-adapter
- github.com/iftechio/go-coco/infra
- github.com/igenexxx/mastering_go_2nd/ch14
- github.com/ignalina/thund/bundledImpl
- github.com/igomez06/rancher/pkg/controllers/user/logging/utils
- github.com/ihezebin/promisys/component/pubsub
- github.com/ilolss/outbox-pattern/internal/kafka
- github.com/ilyatos/aac-task-tracker/auth/internal/app/command/change_role
- github.com/ilyatos/aac-task-tracker/auth/internal/app/command/singup
- github.com/ilyatos/aac-task-tracker/auth/internal/broker
- github.com/ilyatos/aac-task-tracker/tracker/internal/app/command/complete_task
- github.com/ilyatos/aac-task-tracker/tracker/internal/app/command/create_task
- github.com/ilyatos/aac-task-tracker/tracker/internal/app/command/reassign_tasks
- github.com/ilyatos/aac-task-tracker/tracker/internal/broker
- github.com/ilyatos/aac-task-tracker/tracker/internal/consumer/users_stream
- github.com/imjiu/go_example/src/gopcp.v2
- github.com/indigowar/food_out/services/accounts/internal/infra/events/kafka
- github.com/indreshp/mycode
- github.com/influxdata/flux/stdlib/kafka
- github.com/infraboard/maudit/apps/event/impl
- github.com/infranyx/go-microservice-template/internal/article/delivery/kafka/producer
- github.com/infranyx/go-microservice-template/internal/article/domain
- github.com/infranyx/go-microservice-template/internal/article/usecase
- github.com/infranyx/go-microservice-template/internal/health_check/usecase/kafka_health_check
- github.com/infranyx/go-microservice-template/pkg/infra_container
- github.com/infranyx/go-microservice-template/pkg/kafka/consumer
- github.com/infranyx/go-microservice-template/pkg/kafka/producer
- github.com/innolight/goevents/queues/kafka
- github.com/integration-system/isp-event-lib/kafka
- github.com/inverse-inc/packetfence/go/cron
- github.com/ionos-cloud/streams/examples/producer
- github.com/ionos-cloud/streams/examples/simple
- github.com/ionos-cloud/streams/examples/worker
- github.com/ionos-cloud/streams/kafka/reader
- github.com/ionos-cloud/streams/kafka/reader/mock
- github.com/ionos-cloud/streams/kafka/sink
- github.com/ionos-cloud/streams/kafka/source
- github.com/ionos-cloud/streams/kafka/table
- github.com/ionos-cloud/streams/kafka/utils
- github.com/ionos-cloud/streams/kafka/writer
- github.com/ionos-cloud/streams/kafka/writer/mocks
- github.com/ir0njaw/falcosidekick/outputs
- github.com/ironpark/kafka-zerolog
- github.com/ishanjain28/vflow/producer
- github.com/iskanderbs/kafka-seg-lib
- github.com/izharishaksa/http-worker
- github.com/jackycsl/catalog/pkg/event/kafka
- github.com/jackzing/gosdk/rpc
- github.com/jaimera/poc-services/broker
- github.com/jakefhyde/rancher/pkg/controllers/user/logging/utils
- github.com/jakopako/dnstap-sensor/tests
- github.com/jamieaitken/promred/kafka
- github.com/jarjar2go/kafka-go-poc
- github.com/jasurbekibnxusniddin/api-gateway-template-with-go-kafka/event
- github.com/jasurxaydarov/api_getway_todo_ap_go_kafka/event
- github.com/jdtobe/kafka-chat
- github.com/jdy879526487/tools/queue
- github.com/jefflinse/eh-kafka-eventbus/eventbus/kafka
- github.com/jiaqiluo/rancher/pkg/controllers/user/logging/utils
- github.com/jidancong/geo/pkg/kafka
- github.com/jim02468/rancher/pkg/controllers/user/logging/utils
- github.com/jinleibill/message-go/kafka
- github.com/jinsem/egtskafkaproducer/pkg/common
- github.com/jinvei/microservice/base/framework/kafka
- github.com/jkkkls/logtail
- github.com/jkratz55/shiva
- github.com/jmlero/operator-kafka/controllers
- github.com/joe-kunzler/market-data-aggregator/pkg/kafka
- github.com/joelsonrocha/pkg
- github.com/johanhugg/gnomock/preset/kafka
- github.com/johnnyeven/libtools/task/kafka
- github.com/johnvicke/snuber/apps/graphql-api/pkg/kafka
- github.com/jonathanlareau/kafka-chat/chat
- github.com/jonreesman/watch-dog-kafka/kafka
- github.com/josedelrio85/faceit_technical_test/server/pkg
- github.com/joseph-v/mc-demo
- github.com/josh-diamond/rancher/pkg/controllers/user/logging/utils
- github.com/joshmeranda/rancher/pkg/controllers/user/logging/utils
- github.com/jpvolt/secomp-golang
- github.com/jrosinsk/rancher/pkg/controllers/user/logging/utils
- github.com/jummyliu/pkg/db/kafkabuilder
- github.com/juniordevil/rancher/pkg/controllers/user/logging/utils
- github.com/justinmoonca/go-queue/kq
- github.com/justtrackio/gosoline/pkg/kafka/connection
- github.com/justtrackio/gosoline/pkg/kafka/consumer
- github.com/justtrackio/gosoline/pkg/kafka/consumer/mocks
- github.com/justtrackio/gosoline/pkg/kafka/producer
- github.com/justtrackio/gosoline/pkg/kafka/producer/mocks
- github.com/justtrackio/gosoline/pkg/stream
- github.com/k13w/go-kafka/infrastructure/kafka/producer
- github.com/k8shop/go-rest-api/pkg/informer
- github.com/kalyan1998/real-time-analytics-dashboard
- github.com/kamicuu/chirpstack-application-server/internal/integration/kafka
- github.com/kanatovnurzhas/test-task-2/pkg/kafka
- github.com/kaplanmaxe/maxwell-kafka-go/consumer
- github.com/katallaxie/streams/examples/producer
- github.com/katallaxie/streams/examples/simple
- github.com/katallaxie/streams/examples/worker
- github.com/katallaxie/streams/kafka/reader
- github.com/katallaxie/streams/kafka/reader/mock
- github.com/katallaxie/streams/kafka/sink
- github.com/katallaxie/streams/kafka/source
- github.com/katallaxie/streams/kafka/table
- github.com/katallaxie/streams/kafka/utils
- github.com/katallaxie/streams/kafka/writer
- github.com/katallaxie/streams/kafka/writer/mocks
- github.com/kaydxh/golang/pkg/mq/kafka
- github.com/kedacore/keda/v2/pkg/scalers
- github.com/kenSevLeb/go-framework/component/kafka
- github.com/kentik/ktranslate/pkg/sinks/kafka
- github.com/kevinjoiner/rancher/pkg/controllers/user/logging/utils
- github.com/kevinyjn/gocom/mq/kafka
- github.com/kinarashah/rancher/pkg/controllers/user/logging/utils
- github.com/kingsd041/pandaria-vip/pkg/controllers/user/logging/utils
- github.com/kinsprite/usertest
- github.com/kirillkumma/kafka
- github.com/kkiling/messages/producer/kafka_producer
- github.com/kl7sn/toolkit/kkafka
- github.com/kloudfuse/kafka-go/topics
- github.com/kneu-messenger-pigeon/authorizer
- github.com/kneu-messenger-pigeon/client-framework
- github.com/knhn1004/hackathon-tiktok-shop-recommendation-engine/api-node/internal/services/kafka
- github.com/kochabonline/kit/store/kafka
- github.com/kodsurfer/try-kafka
- github.com/kolllaka/people/internal/kafka
- github.com/konart/kafka-adapter
- github.com/konstellation-io/kai-processes/kafka-trigger
- github.com/konvoulgaris/kafka-stream-mock
- github.com/koustubh25/fluidity-devops-challenge/lib
- github.com/kravcneger/mygrpc/server
- github.com/krdganesh/queuelib
- github.com/krizons/rest-api-golang/internal/messages/kafak
- github.com/ksooo091/kafka-go
- github.com/ksysoev/kafka-cli/cmd
- github.com/kubearmor/sidekick/outputs
- github.com/kukkar/common-golang/pkg/factory/kafka
- github.com/kurdilesmana/go-account-api/apps/account/cmd
- github.com/kwanlowe/digitalhermit_website/linux/kafka_reader
- github.com/kylin-ops/slog/kafka
- github.com/l-lin/fizzbuzz/stats/kafka
- github.com/lannguyen-c0x12c/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/leizor/kafka-util/internal/cmds/ongoing
- github.com/leizor/kafka-util/internal/cmds/reassign
- github.com/leizor/kafka-util/internal/cmds/stage
- github.com/leizor/kafka-util/internal/cmds/topics
- github.com/leizor/kafka-util/internal/errorcheck
- github.com/leizor/kafka-util/internal/integration
- github.com/leojasmim/kafka-producer-go/infrastructure/broker/kafka
- github.com/lerenn/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/lhdhtrc/kafka-go/pkg
- github.com/libpub/golib/mq/kafka
- github.com/libsv/go-bdd-common/godog
- github.com/lidaboo/go-queue/kq
- github.com/lidofinance/dc4bc/storage/kafka_storage
- github.com/lifenglin/micro-library/connect
- github.com/liftoffio/skafka/topics
- github.com/lightstep/opentelemetry-examples/collector/kafka/src/producer
- github.com/lindgrenj6/kafka_crap
- github.com/linkingthing/clxone-dhcp/pkg/dhcp/services
- github.com/linkingthing/clxone-utils/alarm
- github.com/liquidm/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/lisa-sum/segmentio-kafka-go
- github.com/litegravity-developer/apm-agent
- github.com/liushuojia/go-sdk/kafka
- github.com/liuzw3018/basedemo
- github.com/liy/vk-go
- github.com/lkumarjain/benchmark/kafka-client/segmentio
- github.com/long250038728/web/tool/mq
- github.com/lonng/tidb-demo-leaderboard/internal/consumer
- github.com/loomi-labs/star-scope/indexers/base/kafka
- github.com/looplab/eventhorizon/eventbus/kafka
- github.com/lsamu/ago/store/kafka
- github.com/lsgndln/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/luanrjjj/test_kafka_python_golang/consumer
- github.com/lubit/berg/models
- github.com/lucazpinheiro/data-connector/app
- github.com/luckyshmo/gateway/pkg/repository/kafkaQueue
- github.com/ludashi2020/go-plugins/broker/segmentio
- github.com/luizotavio32/microsservice-go
- github.com/lukeoleson/kafka-quickstart
- github.com/lukwil/project-tools/Kafka-Rest-Bridge
- github.com/luno/workflow/adapters/kafkastreamer
- github.com/luojun96/go-opt/middleware/message/kafka
- github.com/lyckety/async_arch/popug_jira/services/accounting/internal/app/events/consumer
- github.com/lyckety/async_arch/popug_jira/services/accounting/internal/app/events/producer
- github.com/lyckety/async_arch/popug_jira/services/accounting/internal/mb/consumer
- github.com/lyckety/async_arch/popug_jira/services/accounting/internal/mb/producer
- github.com/lyckety/async_arch/popug_jira/services/analytics/internal/app/events/consumer
- github.com/lyckety/async_arch/popug_jira/services/analytics/internal/mb/consumer
- github.com/lyckety/async_arch/popug_jira/services/auth/internal/app/users/events
- github.com/lyckety/async_arch/popug_jira/services/auth/internal/mb/producer
- github.com/lyckety/async_arch/popug_jira/services/task-tracker/internal/app/events/tasks
- github.com/lyckety/async_arch/popug_jira/services/task-tracker/internal/app/events/users
- github.com/lyckety/async_arch/popug_jira/services/task-tracker/internal/mb/consumer
- github.com/lyckety/async_arch/popug_jira/services/task-tracker/internal/mb/producer
- github.com/mactynow/commonutil/messaging/kafka
- github.com/madbiceps/iu-dlbingdabd01/src/sensor-data-producer
- github.com/madridwan/kafka/kafka/segmentio
- github.com/maestre3d/coinlog/messaging/kafka
- github.com/mahmud3253/Project/User_Service/events
- github.com/malwrar/tmp1
- github.com/mammenj/go-health/queues
- github.com/manishshahi1/golang-resumeable
- github.com/mannanmcc/kafka-consumer/internal/kafka
- github.com/manoj-gupta/cloud/kafkapc
- github.com/mapgoo-lab/atreus/pkg/log
- github.com/maqroll/gocode/kafka
- github.com/marcellof23/vfs-TA/pkg/producer
- github.com/marcozov/golang-kafka-consumer
- github.com/marcusbello/paydistro/pkg/kafka
- github.com/margostino/anfield/kafka
- github.com/mariomac/flplite/pkg/pipe/ingest
- github.com/mariusmagureanu/burlan/src/web/apigw
- github.com/marktran77/go-ecomerce-backend-api/cmd/cli/kafka
- github.com/marmotedu/iam/internal/pump/pumps
- github.com/maskarb/sources-integration-go/listener
- github.com/massigerardi/trader-slack-notifier-go/kafka
- github.com/mateeullahmalik/kafka-schema-reg/kafka_event_bus
- github.com/mateuszmidor/GoStudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/hw
- github.com/mateuszmidor/GoStudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/tuner
- github.com/mateuszmidor/GoStudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/ui
- github.com/mateuszmidor/gostudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/hw
- github.com/mateuszmidor/gostudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/tuner
- github.com/mateuszmidor/gostudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/ui
- github.com/mathiasscroccaro/event-driven-go-query/internal/adapter/kafka
- github.com/matster07/user-balance-service/internal/app/controller/broker
- github.com/matt-abi/abi-micro/mq
- github.com/matusvla/go-kafka
- github.com/mauricioromagnollo/kafrest/external/controllers
- github.com/maximus335/utm_postback_middle/internal/pkg/consumer
- github.com/maykonmori1993/estudo_kafka/producer-random
- github.com/mazeboard/storage/kafkaWriter
- github.com/mbolotsuse/rancher/pkg/controllers/user/logging/utils
- github.com/megaease/easeprobe/probe/client/kafka
- github.com/meidada2464/gostudy/KafkaTest
- github.com/merkio/worker-operator/internal/kafka
- github.com/meshplus/gosdk/rpc
- github.com/metinagaoglu/go-network-packet-listener/stream
- github.com/mft-labs/amf_kafka
- github.com/mganta/epat-outputter/kafka
- github.com/mhope-2/log-analytics/log-reader/messaging/kafka
- github.com/micro-easy/go-queue/kq
- github.com/mike-sirs/go-kfk-transfer/cmd
- github.com/mikeasnyder/demomcm/pkg/controllers/user/logging/utils
- github.com/milktea736/cassandra-sink-connector/kafkaconsumer
- github.com/milvus-io/milvus-operator/pkg/external
- github.com/minicloudsky/golang-in-action/kafka-demo
- github.com/minitauros/go-concurrency-training/course/7_kafka_consumer/dev/produce
- github.com/minitauros/go-concurrency-training/course/7_kafka_consumer/solution
- github.com/minitauros/go-concurrency-training/course/9_challenges/1_panic_send/problem
- github.com/minitauros/go-concurrency-training/course/9_challenges/1_panic_send/solution
- github.com/minitauros/go-concurrency-training/course/9_challenges/2_eternal_block/problem
- github.com/minitauros/go-concurrency-training/course/9_challenges/2_eternal_block/solution
- github.com/minitauros/go-concurrency-training/course/9_challenges/3_double_stop/problem
- github.com/minitauros/go-concurrency-training/course/9_challenges/3_double_stop/solution
- github.com/minitauros/go-concurrency-training/course/9_challenges/4_critical_error_block/problem
- github.com/minitauros/go-concurrency-training/course/9_challenges/4_critical_error_block/solution
- github.com/mirjalilova/MemoryService/kafka
- github.com/mirjalilova/api_gateway/kafka
- github.com/misha2017/demo-go-techs/kafka-go-demo
- github.com/mishnit/cqrs-microservices/api_gateway_service/internal/products/commands
- github.com/mishnit/cqrs-microservices/pkg/kafka
- github.com/mishnit/cqrs-microservices/pkg/tracing
- github.com/mishnit/cqrs-microservices/reader_service/internal/product/delivery/kafka
- github.com/mishnit/cqrs-microservices/reader_service/internal/server
- github.com/mishnit/cqrs-microservices/writer_service/internal/product/commands
- github.com/mishnit/cqrs-microservices/writer_service/internal/product/delivery/kafka
- github.com/mishnit/cqrs-microservices/writer_service/internal/server
- github.com/mix-plus/go-queue/kq
- github.com/mjura/rancher/pkg/controllers/user/logging/utils
- github.com/mkhalegaonkar3/product-service-go/shipping
- github.com/mo3et/itv-learn-24/kafka/kratos-event/kafka
- github.com/mobile-directing-system/mds-server/services/go/shared/kafkautil
- github.com/mogw/micro-company/internal/kafka
- github.com/mohamadkhani/sample-go/messageBroker
- github.com/moleculer-go/moleculer/transit/kafka
- github.com/momeaking/rancher/pkg/controllers/user/logging/utils
- github.com/mooijtech/goforensics-core/pkg
- github.com/moooll/cat-service-mongo
- github.com/morzhanov/go-realworld/internal/analytics/events
- github.com/morzhanov/go-realworld/internal/auth/events
- github.com/morzhanov/go-realworld/internal/common/events/eventscontroller
- github.com/morzhanov/go-realworld/internal/common/events/eventslistener
- github.com/morzhanov/go-realworld/internal/common/mq
- github.com/morzhanov/go-realworld/internal/common/mq/mq_test
- github.com/morzhanov/go-realworld/internal/common/sender
- github.com/morzhanov/go-realworld/internal/common/tracing
- github.com/morzhanov/go-realworld/internal/pictures/events
- github.com/morzhanov/go-realworld/internal/users/events
- github.com/mostafa/xk6-kafka
- github.com/mostwelcome/go-kafka
- github.com/movie-recommendation-v1/geteway/pkg/kafka
- github.com/mrehanabbasi/company-inc/msq
- github.com/mspiez/gnmi-gateway/gateway/exporters/kafka
- github.com/mss-boot-io/mss-boot-admin/compose/kafka
- github.com/mubaiedj/go-clean-sample/app/shared/utils/kafka
- github.com/mudkipme/inazuma/server
- github.com/muhammadali07/service-grap-go-api/services/kafka-server
- github.com/muratdemir0/faceit-task/pkg/event
- github.com/musobarlab/kafka-cli
- github.com/mutezebra/tiktok/pkg/kafka
- github.com/mvbrock/clusterizer/cmd
- github.com/mwsbkru/broker-bridge/internal/kafka
- github.com/myosotix/rancher/pkg/controllers/user/logging/utils
- github.com/nachogiljaldo/otel-messaging/pkg/propagation/segmentio/kafkago
- github.com/nais/dataproduct-topics/pkg/collector
- github.com/nambrosini/kcp/kafka
- github.com/nataliefyi/rancher/pkg/controllers/user/logging/utils
- github.com/navikt/go-leesah
- github.com/nduni/correlation/common/messaging
- github.com/nebucloud/pkg/logger
- github.com/nei7/ntube/app/user/internal/service
- github.com/neiln3121/user-service/kafka
- github.com/nephilimboy/rcd-fullmonitoring-agent/topology/probes/flow
- github.com/ngohoa211/kapacitor/services/kafka
- github.com/nguyentrunghieu15/be-beehome-prj/authorize-service/internal/comunitication
- github.com/nguyentrunghieu15/be-beehome-prj/internal/kafkax
- github.com/nguyentrunghieu15/be-beehome-prj/pro-manager-service/internal/comunitication
- github.com/nguyentrunghieu15/be-beehome-prj/pro-manager-service/internal/groupservice-manager
- github.com/nguyentrunghieu15/be-beehome-prj/pro-manager-service/internal/hireservice
- github.com/nguyentrunghieu15/be-beehome-prj/pro-manager-service/internal/provider
- github.com/nguyentrunghieu15/be-beehome-prj/pro-manager-service/internal/service-manager
- github.com/nguyentrunghieu15/be-beehome-prj/user-manager-service/internal/auth
- github.com/nguyentrunghieu15/be-beehome-prj/user-manager-service/internal/comunitication
- github.com/nguyentrunghieu15/be-beehome-prj/user-manager-service/internal/profiles
- github.com/nguyentrunghieu15/be-beehome-prj/user-manager-service/internal/user
- github.com/nguyentrunghieu15/vcs-be-prj/pkg/server
- github.com/ngyugive/goat_kit/pkg/event/kafka
- github.com/nhanhoangtrong/kafka-go-test/lib
- github.com/nickolation/grpc-task-hezzl/clicklogs/producer
- github.com/nickstrad/streamer/cmd
- github.com/nightsilvertech/oni
- github.com/nikandpro/kafka-fio-server/pkg/kafka
- github.com/nikgalushko/kafka-drivers-competition/segmentio
- github.com/nikmy/chatty/internal
- github.com/nilangekarss/trykafka
- github.com/nilerajput91/kafaconsumerproduction
- github.com/nimaghaedsharafi/producer-consumer
- github.com/ninglg/golang-example/kafka/consumer3
- github.com/nioliu/commons/log
- github.com/nitiprabhu/forest-mock-data-generator
- github.com/nkhine/playground/go/GoStudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/hw
- github.com/nkhine/playground/go/GoStudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/tuner
- github.com/nkhine/playground/go/GoStudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/ui
- github.com/nkr24/go-message-service/internal/kafka
- github.com/nlecoy/kafka-mirror
- github.com/nlnwa/gowarcserver/index
- github.com/nomiram/kafka-submodule
- github.com/nowfred/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/nsobjects/ima/internal/pump/pumps
- github.com/nstankov-bg/oaievals-collector/pkg/kafka
- github.com/nugrohosam/gosampleapi/services/infrastructure
- github.com/nwpc-oper/nmc-monitor-client-go/cmd
- github.com/nxnus25/go/_courses/Mastering-Go-Second-Edition/ch14
- github.com/o-aloqaily/go-project-starter/internal/kafka
- github.com/obouchet/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/oddbit-project/blueprint/provider/kafka
- github.com/odilonjk/golang-kafka-producer-example
- github.com/odpf/predator/publisher
- github.com/ofavor/ddd-go/pkg/event/kafka
- github.com/ofey404/experiments/microservices/kafka
- github.com/ogibayashi/sample-app-golang/service/kafka
- github.com/ogniloud/madr/internal/wordmaster
- github.com/olegf314/web2022/hw5
- github.com/oliverdding/clickhouse-bit-operation-bench/cmd
- github.com/omexapp/omexchain/x/stream/kafkaclient
- github.com/onbyzerollc/pubsub/providers/kafka
- github.com/onecombine/onecombine-msg-validator/src/utils
- github.com/onemgvv/notificationserver/internal/transport/kafka
- github.com/onno-vos-dev/await
- github.com/open-micro/plugins/v5/broker/segmentio
- github.com/openconfig/gnmi-gateway/gateway/exporters/kafka
- github.com/openshift-telco/netconf-operator/controllers
- github.com/opensibyl/sibyl2/pkg/server/queue
- github.com/openware/kafka-benchmark/pkg/example
- github.com/orlangure/gnomock/preset/kafka
- github.com/osiaeg/buffered_request/internal/services
- github.com/owen97779/Pachamama-MQTT-Kafka-Producer/pkg/kafka
- github.com/p2p-org/mbelt-cosmos-streamer/datastore
- github.com/pachyderm/pachyderm/etc/testing/kafka
- github.com/packtpublishing/mastering-go-second-edition/ch14
- github.com/paraglade/drone-smoke-tests/pkg/controllers/user/logging/utils
- github.com/pauluswi/rhine/internal/trxhistory
- github.com/pawzio/arda/rivendell/kafka
- github.com/pbudner/argosminer/sources
- github.com/pcasaretto/go-block-web-kafka
- github.com/peizhong/codeplay/pkg/event
- github.com/pennyscissors/rancher/pkg/controllers/user/logging/utils
- github.com/peter-stratton/gofr/pkg/gofr/datasource/pubsub/kafka
- github.com/petrostrak/xm-companies/internal/adapters/kafka/consumer
- github.com/phamdinhha/go-event-sourcing/pkg/kafka
- github.com/phenixrizen/topicctl/cmd/topicctl/subcmd
- github.com/phenixrizen/topicctl/pkg/admin
- github.com/phenixrizen/topicctl/pkg/apply
- github.com/phenixrizen/topicctl/pkg/cli
- github.com/phenixrizen/topicctl/pkg/config
- github.com/phenixrizen/topicctl/pkg/groups
- github.com/phenixrizen/topicctl/pkg/messages
- github.com/phenixrizen/topicctl/pkg/util
- github.com/philips-software/gautocloud-connectors/hsdp
- github.com/phonghaido/log-ingestor/kafka
- github.com/phthom/asset-tools-aiops-roks/src
- github.com/pietroaragona/golang-kafka-segmentio-poc
- github.com/ping-cloudnative/moonlight-utils/providers/kafkav2
- github.com/pinpoint-apm/go-aop-agent/libs/kafkago
- github.com/planetrio/planetr-compose
- github.com/playkids/rancher/pkg/controllers/user/logging/utils
- github.com/plexifyTech/kaplex
- github.com/pmatseykanets/rancher/pkg/controllers/user/logging/utils
- github.com/polsumeet3666/code-snippet-go/kafka
- github.com/ponyjackal/eventual-consistency-blog/services
- github.com/poornima1603/kafka-consumer-using-golang/cmd/kafka_consumer
- github.com/popoffvg/async-arch/src/accounting/internal/adapters/kafka
- github.com/popsu/go-website-watcher/internal/kafka
- github.com/poscard/nussknacker-practice/cmd
- github.com/potaesm/go-kafka-simple
- github.com/prb112/fhir-kafka-go
- github.com/pristupaanastasia/test1/serv
- github.com/pushwoosh/infra/kafka
- github.com/pyama86/isaka/isaka
- github.com/qa-tools-family/iam/internal/pump/pumps
- github.com/qida/gohp/mqtt
- github.com/qiulin/watermill-kafkago/pkg/kafkago
- github.com/qiuzhanghua/qraft_go
- github.com/qosimmax/pubsub/pkg/kafka
- github.com/quanghung97/kafka-go
- github.com/quangtran88/anifni-base/libs/services
- github.com/quincy0/temproal-workflows/mq
- github.com/r14152/datastore-connector/kafka
- github.com/rabarbra/accounts_service/logg
- github.com/radyatamaa/go-cqrs-microservices/api_gateway_service/internal/article/repository
- github.com/radyatamaa/go-cqrs-microservices/pkg/kafka
- github.com/radyatamaa/go-cqrs-microservices/reader_service/internal/article/delivery/kafka
- github.com/radyatamaa/go-cqrs-microservices/reader_service/internal/server
- github.com/radyatamaa/go-cqrs-microservices/write_service/internal/article/delivery/kafka
- github.com/radyatamaa/go-cqrs-microservices/write_service/internal/article/repository
- github.com/radyatamaa/go-cqrs-microservices/write_service/internal/server
- github.com/rafadc/waitfor/cmd
- github.com/rafaelsanzio/go-flashscore/pkg/kafka
- github.com/rafaribe/otelkafkago
- github.com/raft-tech/df-kafka-go
- github.com/rancher/rancher/pkg/controllers/user/logging/utils
- github.com/random-char/kapacitor/services/kafka
- github.com/rashiraffi/streamease/internal/kafka
- github.com/raulcabello/rancher/pkg/controllers/user/logging/utils
- github.com/raven-scanner/assets
- github.com/rbaderts/kapacitor/services/kafka
- github.com/redsuperbat/kafka-commander/src/producing
- github.com/reecerussell/open-social/eventing/kafka
- github.com/renatoaguimaraes/ecommerce-pim/internal/driver
- github.com/rendieroot/kafka-couch
- github.com/rezaAmiri123/edat/kafka
- github.com/rezaAmiri123/microservice/pkg/kafka
- github.com/rezaAmiri123/microservice/pkg/kafka/kafkastream
- github.com/rezaAmiri123/microservice/pkg/kafka/mock
- github.com/rezaAmiri123/microservice/pkg/tracing
- github.com/rezaAmiri123/microservice/service_message/internal/ports/kafka
- github.com/rezaAmiri123/microservice/service_user/internal/app/command
- github.com/rezaAmiri123/test-microservice/api_service/app/command
- github.com/rezaAmiri123/test-microservice/library_service/ports/kafka
- github.com/rezaAmiri123/test-microservice/message_service/ports/kafka
- github.com/rezaAmiri123/test-microservice/pkg/kafka
- github.com/rezaAmiri123/test-microservice/pkg/kafka/mock
- github.com/rezaAmiri123/test-microservice/pkg/tracing
- github.com/rezaAmiri123/test-microservice/test/kafka1
- github.com/rezaAmiri123/test-microservice/test/message_example
- github.com/rezaAmiri123/test-microservice/user_service/app/command
- github.com/rezaAmiri123/test-microservice/user_service/ports/kafka
- github.com/rfancn/hdget-sdk/lib/mq/provider/kafkago
- github.com/rickylin614/common/ckafka
- github.com/ridge/limestone/kafka/kafkago
- github.com/rjshrjndrn/golang/kafka
- github.com/rkochar/wsdm/src/shared
- github.com/rl404/fairy/pubsub/kafka
- github.com/robertobadjio/tgtime-aggregator/internal/kafka
- github.com/rohilsurana/kafka-offset/kafka
- github.com/rohitsakala/rancher/pkg/controllers/user/logging/utils
- github.com/roman-munteanu/kafka-go-demo/segmentio
- github.com/romaxa83/mst-app/gateway/internal/author/commands
- github.com/romaxa83/mst-app/gateway/internal/products/commands
- github.com/romaxa83/mst-app/pkg/kafka
- github.com/romaxa83/mst-app/pkg/tracing
- github.com/romaxa83/mst-app/reader_service/internal/product/delivery/kafka
- github.com/romaxa83/mst-app/reader_service/internal/server
- github.com/romaxa83/mst-app/writer_service/internal/product/commands
- github.com/romaxa83/mst-app/writer_service/internal/product/delivery/kafka
- github.com/romaxa83/mst-app/writer_service/internal/server
- github.com/ronappleton/gk-kafka
- github.com/rosas99/monster/internal/pump
- github.com/rosas99/monster/internal/sms/biz
- github.com/rosas99/monster/internal/sms/monitor
- github.com/rosas99/monster/internal/sms/mqs
- github.com/rosas99/monster/internal/sms/writer
- github.com/rosas99/monster/internal/usercenter/biz
- github.com/rosas99/monster/pkg/options
- github.com/rosas99/monster/pkg/queue
- github.com/rosas99/monster/pkg/streams/connector/kafka
- github.com/rsiegfanz/home-control/backend/seeder/pkg/seeds/kafkaSeeds
- github.com/rumis/storage/skafka
- github.com/rustomax/observe-kafka-go
- github.com/rwoj/go-kafka-go/seg
- github.com/rzaripov1990/multiwriter/ext/kafka
- github.com/s21platform/kafka-lib
- github.com/sQUARys/TestTaskHezzl/kafka
- github.com/sabariramc/goserverbase/v3/app/server/kafkaconsumer
- github.com/sabariramc/goserverbase/v3/kafka
- github.com/sabariramc/goserverbase/v3/kafka/api
- github.com/sabariramc/goserverbase/v4/app/server/kafkaconsumer
- github.com/sabariramc/goserverbase/v4/kafka
- github.com/sabariramc/goserverbase/v4/kafka/api
- github.com/sabariramc/goserverbase/v5/app/server/kafkaconsumer
- github.com/sabariramc/goserverbase/v5/instrumentation/contrib/ddtrace
- github.com/sabariramc/goserverbase/v5/instrumentation/contrib/otel
- github.com/sabariramc/goserverbase/v5/kafka
- github.com/sabariramc/goserverbase/v5/kafka/api
- github.com/sabariramc/goserverbase/v6/app/server/kafkaclient
- github.com/sabariramc/goserverbase/v6/instrumentation/contrib/ddtrace
- github.com/sabariramc/goserverbase/v6/instrumentation/contrib/otel
- github.com/sabariramc/goserverbase/v6/kafka
- github.com/saeed903/fileprocessing/internal/app
- github.com/saeed903/fileprocessing/internal/fileprocessing/delivery/kafka/elasticsearch_subscription
- github.com/saeed903/fileprocessing/internal/fileprocessing/delivery/kafka/mongo_subscription
- github.com/saeed903/fileprocessing/pkg/es
- github.com/saeed903/fileprocessing/pkg/kafka
- github.com/saeed903/fileprocessing/pkg/tracing
- github.com/safetyculture/kafka_client
- github.com/sahalazain/kafpro/service
- github.com/said-saifi/kafka-go-clients/segmentio-kafka-go
- github.com/sajidzepto/zeptorepocommons
- github.com/samlet/petrel/fixtures/events
- github.com/samuskitchen/go-kafka-example/pkg/kafka
- github.com/san-services/kafkaclient/v2
- github.com/sandwich-go/gnomock/preset/kafka
- github.com/sansmoraxz/any-scrape-go/queue
- github.com/saperliu/common-tool/middleware/kafka_client
- github.com/sarkarshuvojit/kfk/util/kfkconn
- github.com/scilive/scibase/kafkas
- github.com/scott-the-programmer/test-kg-msk
- github.com/scul0405/saga-orchestration/internal/orchestrator/app
- github.com/scul0405/saga-orchestration/internal/orchestrator/eventhandler
- github.com/scul0405/saga-orchestration/internal/order/eventhandler
- github.com/scul0405/saga-orchestration/internal/payment/eventhandler
- github.com/scul0405/saga-orchestration/internal/product/eventhandler
- github.com/scul0405/saga-orchestration/internal/purchase/eventhandler
- github.com/scul0405/saga-orchestration/pkg/kafka
- github.com/sdomino/kapacitor/services/kafka
- github.com/seadiaz/kafka-to-websocket/kafka
- github.com/seanrmurphy/keda-test/kafka-consumer
- github.com/segmentio/topicctl/cmd/topicctl/subcmd
- github.com/segmentio/topicctl/pkg/acl
- github.com/segmentio/topicctl/pkg/admin
- github.com/segmentio/topicctl/pkg/apply
- github.com/segmentio/topicctl/pkg/cli
- github.com/segmentio/topicctl/pkg/config
- github.com/segmentio/topicctl/pkg/create
- github.com/segmentio/topicctl/pkg/groups
- github.com/segmentio/topicctl/pkg/messages
- github.com/segmentio/topicctl/pkg/util
- github.com/sensu/sensu-kafka-handler
- github.com/seosite/gcore/pkg/core/kafkax
- github.com/septemhill/mq/kafka
- github.com/serbanmunteanu/xm-golang-task/kafka
- github.com/sergiolucena1/kafka_golang
- github.com/serjbibox/api-gateway/pkg/storage/_kafka
- github.com/severuykhin/kafkaproxy
- github.com/seyedmo30/kafka-wrapper
- github.com/seymac/xk6-kafka
- github.com/shandysiswandi/learn-golang/kafka/segmentio-kafka-go
- github.com/shanewxy/rancher/pkg/controllers/user/logging/utils
- github.com/shanexu/sillytools/cmd/kafka_consumer
- github.com/shaozi17/go-queue/kq
- github.com/shapito27/kafka-tutorial
- github.com/shawnfeng/sutil/mq
- github.com/shawnkoong/mta-email-sender
- github.com/shbov/hse-go_final/cmd/mock
- github.com/shbov/hse-go_final/internal/driver/message_queue
- github.com/shbov/hse-go_final/internal/driver/message_queue/drivermq
- github.com/shbov/hse-go_final/internal/driver/message_queue/kafkamock
- github.com/shbov/hse-go_final/internal/driver/service
- github.com/shbov/hse-go_final/internal/driver/service/kafkalistenersvc
- github.com/shbov/hse-go_final/internal/driver/service/kafkasvc
- github.com/shchiv/notifier-service/pkg/kafka
- github.com/shinomontaz/numbooking/internal/feeder
- github.com/ship-os/ship-micro/plugins/broker/segmentio/v2
- github.com/shivendrasingh07/pubsub
- github.com/shortcut/cloud-native-templates/server/golang-kafka
- github.com/shrimpsizemoose/trekker/infra
- github.com/shriyanshagnihotri/collectorservice
- github.com/sigmaott/gest/package/extension/kafkafx
- github.com/sivaone/go-kafka-websocket2
- github.com/skapfer/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/skeleton1231/go-iam-ecommerce-microservice/internal/pump/pumps
- github.com/sklrsn/elk/bootstrap
- github.com/sko00o/benchmark-kafka-go-clients
- github.com/skylee424/blue-bell/dao/kafka
- github.com/sld880311/influxdata/kapacitor/services/kafka
- github.com/slimloans/kafka
- github.com/slinkydeveloper/kafka-go-clients-benchmarks/kafka-go
- github.com/sm0kernone/crm-common/pkg/kafka
- github.com/smallfish-root/eventhorizon/eventbus/kafka
- github.com/smallnest/gofer/mq/mka
- github.com/smartwalle/mx/kafkax
- github.com/smarty/messaging-kafka
- github.com/smirankat/messaggio-test
- github.com/sodafoundation/controller/pkg/controller/metrics/adapters
- github.com/soedev/soego-component/ekafka
- github.com/soedev/soego-component/ekafka/consumerserver
- github.com/soedev/soego-component/ekafka/examples
- github.com/soedev/soego-component/ekafka/examples/consumerserver
- github.com/soedev/soego-component/ekafka/examples/consumerservertrace
- github.com/soedev/soego-component/ekafka/examples/trace
- github.com/sohaibomr/apm-kafkago
- github.com/sohamkamani/golang-kafka-example
- github.com/solival/kafka-go-node/go
- github.com/songshubing/vflow/producer
- github.com/sonntuet1997/medical-chain-utils/messaging
- github.com/souz9/kafka-topic
- github.com/spark-lence/tiga
- github.com/spirit-labs/tektite/kafka
- github.com/spy16/fusion/reactor/stream
- github.com/sswastioyono18/vaccination-demo/cmd
- github.com/stackus/edat-kafka-go
- github.com/starnuik/golang_messagio/internal/stream
- github.com/steadfastie/gokube/data/brocker
- github.com/steel-archer/go-flattener
- github.com/stellar/stellar-disbursement-platform-backend/internal/events
- github.com/stevehnh/go-test-app
- github.com/stevestotter/assignment-server/event
- github.com/stratg5/pubsub/kafka
- github.com/streamdal/segmentio-kafka-go/topics
- github.com/stundzia/hermann/kafka
- github.com/sturn/go-queue/kq
- github.com/sukmin/texumer
- github.com/sumup-go/lessons/advanced/13
- github.com/superhero-match/consumer-delete-media/internal/consumer
- github.com/superhero-match/consumer-delete-messages/internal/consumer
- github.com/superhero-match/consumer-firebase-token/internal/consumer
- github.com/superhero-match/consumer-match-delete/internal/consumer
- github.com/superhero-match/consumer-report-user/internal/consumer
- github.com/superhero-match/consumer-superhero-chat/internal/consumer
- github.com/superhero-match/consumer-superhero-choice/internal/consumer
- github.com/superhero-match/consumer-superhero-delete/internal/consumer
- github.com/superhero-match/consumer-superhero-match/internal/consumer
- github.com/superhero-match/consumer-superhero-register/internal/consumer
- github.com/superhero-match/consumer-superhero-update/internal/consumer
- github.com/superhero-match/consumer-update-media/internal/consumer
- github.com/superhero-match/firebase-token/internal/producer
- github.com/superhero-match/superhero-chat/internal/producer
- github.com/superhero-match/superhero-choice/internal/producer
- github.com/superhero-match/superhero-delete-media/internal/producer
- github.com/superhero-match/superhero-delete-messages/internal/producer
- github.com/superhero-match/superhero-delete/internal/producer
- github.com/superhero-match/superhero-match-delete/internal/producer
- github.com/superhero-match/superhero-match/internal/producer
- github.com/superhero-match/superhero-register/internal/producer
- github.com/superhero-match/superhero-report-user/internal/producer
- github.com/superhero-match/superhero-update-media/internal/producer
- github.com/superhero-match/superhero-update/internal/producer
- github.com/superj80820/system-design/kit/mq
- github.com/superj80820/system-design/kit/mq/kafka
- github.com/superj80820/system-design/kit/mq/kafka/readermanager
- github.com/superj80820/system-design/kit/mq/kafka/readermanager/mocks
- github.com/superj80820/system-design/kit/mq/kafka/writermanager
- github.com/superj80820/system-design/kit/mq/reader_manager
- github.com/superj80820/system-design/kit/mq/reader_manager/mocks
- github.com/superj80820/system-design/kit/mq/writer_manager
- github.com/supersstone/interviewcode/go-code/internal/mqs
- github.com/superwhys/superGo/superKafka/consumer
- github.com/svansig/g_mash_testbed
- github.com/swiggy-2022-bootcamp/cdp-team4/Product_Admin/infra/gokafka
- github.com/swiggy-2022-bootcamp/cdp-team4/cart/infra/gokafka
- github.com/swiggy-2022-bootcamp/cdp-team4/order/infra/gokafka
- github.com/swiggy-2022-bootcamp/cdp-team4/payment/infra/gokafka
- github.com/swiggy-2022-bootcamp/cdp-team4/reward/infra/gokafka
- github.com/swiggy-2022-bootcamp/cdp-team4/transaction/infra/gokafka
- github.com/swiggy-2022-bootcamp/training-i-plus-plus/ashwin/training/kafka
- github.com/swiggy-2022-bootcamp/training-i-plus-plus/nishant/mini-project/doctor_service/producer
- github.com/swiggy-2022-bootcamp/training-i-plus-plus/nishant/mini-project/kafka_notification_service/consumer
- github.com/swiggy-2022-bootcamp/training-i-plus-plus/nishant/mini-project/user_service/producer
- github.com/swiggy-2022-bootcamp/training-i-plus-plus/nishant/training/W9/kafka
- github.com/swiggy-2022-bootcamp/training-i-plus-plus/rishabh/training/kafka
- github.com/swiggy-2022-bootcamp/training-i-plus-plus/syed/training/kafka
- github.com/sxerox007/gamezop/kafka
- github.com/syklinux/golib/kafka
- github.com/synthao/notifier
- github.com/takmatsu/rancher/pkg/controllers/user/logging/utils
- github.com/tam-code/image-upload/src/kafka
- github.com/tanqiuqiang/go-queue/kq
- github.com/tarekbadrshalaan/GoKafka/kafka-go
- github.com/tarent/kafkaadmin
- github.com/tashima42/rancher/pkg/controllers/user/logging/utils
- github.com/taudelta/ksqlite/pkg
- github.com/tavvfiq/driver-loc-iot/pkg/kafka
- github.com/tayron/golang-estudos/apache-kafka
- github.com/team-cymru/vflow/producer
- github.com/teenkwn/basic-kafka-consumer/kafka
- github.com/telepenin/website-checker/checker/listener
- github.com/telkomdev/tob/services/kafka
- github.com/teng231/kafclient/v2
- github.com/tetafro/kafka-dump
- github.com/thankala/diploma-thesis/common/network
- github.com/the-great-checkout/transactions-crud/internal/service
- github.com/thedadams/rancher/pkg/controllers/user/logging/utils
- github.com/thingio/kapacitor/services/kafka
- github.com/thinxz/go_lang/config
- github.com/thirteenths/message-processing-microservice/internal/storage/kafka
- github.com/thk-im/thk-im-base-server/mq
- github.com/tianet/ditto/pkg/adapters/producer
- github.com/tidepool-org/kafka-data-import/api
- github.com/tillkuhn/letitgo/stream
- github.com/tmtriet200800/test-go-utils/eventbus
- github.com/tomsanbear/dnslogging
- github.com/toniz/gosuit/queue/kafka
- github.com/tony-spark/recipetor-backend/ingredient-service/internal/controller/kafka
- github.com/tony-spark/recipetor-backend/nutrition-facts-service/internal/controller/kafka
- github.com/tony-spark/recipetor-backend/recipe-service/internal/controller/kafka
- github.com/tony-spark/recipetor-backend/user-service/internal/controller/kafka
- github.com/toomanysource/atreus/app/comment/service/internal/data
- github.com/toomanysource/atreus/app/favorite/service/internal/data
- github.com/toomanysource/atreus/app/message/service/internal/data
- github.com/toomanysource/atreus/app/publish/service/internal/data
- github.com/toomanysource/atreus/app/relation/service/internal/data
- github.com/toomanysource/atreus/app/user/service/internal/data
- github.com/toomanysource/atreus/pkg/kafkaX
- github.com/toventang/debezium-client/internal/consumer
- github.com/trakkie-id/kafka-zipkin-interceptor
- github.com/trantrongquy/mastering-go-second-edition/ch14
- github.com/trb1maker/gobannercircle/internal/notify/kafka
- github.com/trstoyan/Alertify/kafka
- github.com/truexf/kafkac
- github.com/tsmweb/go-helper-api/kafka
- github.com/turngeek/myaktion-go-2023/src/banktransfer/kafka
- github.com/tx7do/go-kafka-example/segmentio
- github.com/txbao/common-go/component/mq/kafka
- github.com/uditkarth/liveaiproject/matching
- github.com/uncorde/uncorde/internal/integration/kafka
- github.com/underthetreee/fsync/internal/kafka
- github.com/unistack-org/micro-broker-segmentio
- github.com/unkeyed/unkey/apps/api/pkg/kafka
- github.com/vani-rf/jojonomic-test/buyback-service/cmd
- github.com/ve-weiyi/ve-blog-golang/kit/infra/mq/kafkax
- github.com/vedrankolka/donation-server/pkg/notifier/kafka
- github.com/vela-ssoc/vela-kfk
- github.com/venon2fork/bundlecoursevidyouprojet/ch14
- github.com/venture-technology/vtx-account-manager/internal/repository
- github.com/veotani/kafka-log-processor/pkg/kafka
- github.com/veritone/go-messaging-lib/kafka
- github.com/verrazzano/rancher/pkg/controllers/user/logging/utils
- github.com/versity/versitygw/s3event
- github.com/vert-capital/vertc-go-admin/admin
- github.com/viacheslavcolt/ts-go-lib/kafka
- github.com/viant/endly/service/testing/msg
- github.com/victordenisov/kafka_tests
- github.com/vikas1028/go_day-1
- github.com/viktorcitaku/kafka-sandbox
- github.com/vincentconace/chat-kafka-golang/pkg/kafka
- github.com/vinicius-gregorio/kafka_go
- github.com/viru-tech/clickhouse_sinker/input
- github.com/visitskyworld/dia-data/cmd/exchange-scrapers/collector
- github.com/visitskyworld/dia-data/cmd/services/filtersBlockService
- github.com/visitskyworld/dia-data/cmd/services/tradesBlockService
- github.com/visitskyworld/dia-data/cmd/supplyConnector
- github.com/visitskyworld/dia-data/pkg/dia/helpers/kafkaHelper
- github.com/visitskyworld/dia-data/pkg/http/restServer/kafkaApi
- github.com/vizvasrj/l
- github.com/vkuksa/twatter/internal/storage/bpkafka
- github.com/vkuznet/kafka-app
- github.com/vlasashk/websocket-chat/pkg/kakafka
- github.com/voltento/trkaf/internal/kf
- github.com/vontikov/kafka-test-tool/cmd
- github.com/vsjadeja/metric/segkafka
- github.com/vuvanthanhtb/go-ecommerce-backend-api/cmd/cli/kafka
- github.com/vynovikov/highLoadParser/internal/transmitters
- github.com/wahidx/kafkax/xkafka
- github.com/wangzhen94/iam/internal/pump/pumps
- github.com/wardab0104/eventstream-go-sdk/v3
- github.com/wcygan/counter/rng
- github.com/weblazy/gocore/gokafka
- github.com/weblfe/queue-proxy/kq
- github.com/wendylau87/warungpintar2021/inventorysvc/infrastructure/kafkahandler
- github.com/wenlaizhou/middleware
- github.com/west2-online/fzuhelper-server/pkg/base/client
- github.com/wfusion/easeprobe/probe/client/kafka
- github.com/wilbyang/redirect-service/kafka
- github.com/willjrcom/kafka-golang/internal/consumer_producer_segmentio
- github.com/wind-c/comqtt/v2/plugin/bridge/kafka
- github.com/windvalley/gf2-demo/internal/pkg/kafka
- github.com/wolffcm/flux/stdlib/kafka
- github.com/workindia/goadapter/pubsub/producer
- github.com/worming004/top10tick/produce-tick
- github.com/wosai/havok/dispatcher
- github.com/ws6/klib
- github.com/wurt83ow/gophstream/internal/kafka
- github.com/wuttinanhi/code-judge-system/services
- github.com/xataio/pgstream/pkg/kafka
- github.com/xhyonline/xutil/kmq
- github.com/xiao4er/kapacitor/services/kafka
- github.com/xiaocok/go-tools/pkg/kafka
- github.com/xigang/kapacitor/services/kafka
- github.com/xiongdi9456/go-queue/kq
- github.com/xoxoist/oni
- github.com/xpoh/otus-work/pkg/api
- github.com/xuexiangyou/thor/queue/kq
- github.com/xulei324/spiderlab-go-sdk/database
- github.com/xuzhijvn/ht-apm/apmcore
- github.com/y7ut/logtransfer/source
- github.com/yahoo/panoptes-stream/producer/mqueue/kafka
- github.com/yhyzgn/goat/kafka
- github.com/ynwd/kafka-example
- github.com/yorkershi/golib
- github.com/youcankeepsilence/gowebserver/services/kafka
- github.com/yoyo-inc/yoyo/services
- github.com/ysmood/kafka-notifier
- github.com/ytunhen/newproject
- github.com/yudhapratama10/search-consumer/infrastructure/kafka
- github.com/yusufpapurcu/wait-for-kafka
- github.com/yvvlee/delay-kafka/internal/core
- github.com/yyydiebian007/gocore/gokafka
- github.com/zackarysantana/velocity/internal/service/kafka
- github.com/zeedware/kafkapro
- github.com/zenchainprotocol/zenchain-node/x/stream/kafkaclient
- github.com/zeromicro/cds/pkg/tube
- github.com/zhangsq-ax/aws-msk-helper-go
- github.com/zhenianik/grpcApiTest/internal/kafka
- github.com/zhuud/go-library/svc/kafka
- github.com/zikwall/grower/internal/services/kafkalog
- github.com/zizaimengzhongyue/go-demo/kafka-go
- github.com/zjzjzjzj1874/gorm-study/pkg/helper
- github.com/zleague/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/zmon-deploy/zmon-common-go/pubsub
- github.com/znas-io/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/zusux/gokit/kafka
- github.com/zutim/ego/component/kafka
- github.com/zxlzhd/temporal_md_a/kafka
- github.com/zzm219/freetsdb/services/flux/functions/outputs
- github.com/zzsds/go-tools/event/kafka
- github.phpd.cn/rancher/rancher/pkg/controllers/user/logging/utils
- github.xiaoq7.com/rancher/rancher/pkg/controllers/user/logging/utils
- gitlab.alpha-safety.kz/mine-pass/kafka-helper/lib/kafka
- gitlab.bookiech.com/payways-golang-libs/microservices-config/tools/kafka/consumer_worker
- gitlab.bookiech.com/payways-golang-libs/microservices-config/tools/kafka/producer_worker
- gitlab.bookiech.com/payways-golang-libs/microservices-config/tools/telemetry
- gitlab.bookiech.com/payways-golang-libs/microservices-config/tools/telemetry/kafka
- gitlab.com/PONCtech/meander/pkg/carriers/kafka
- gitlab.com/bahodirova/api-gateway/kafka
- gitlab.com/bensivo/kcli/internal/client
- gitlab.com/bngnha/go-plugins/broker/segmentio/v2
- gitlab.com/data-custodian/custodian-go/connectors/mq
- gitlab.com/flake-chat/broker
- gitlab.com/golang-libs/mosk.git/interfaces/kafka/kafkago
- gitlab.com/jc88/jager/messagebroker/kafkax
- gitlab.com/lingualeap/auth/kafka
- gitlab.com/m7165/go-service
- gitlab.com/mage-repo/template-utils/kafka-service
- gitlab.com/offzoneworks/everest/event/kafka
- gitlab.com/quantumquest3/learning_service/kafka
- gitlab.com/swarajd/homelab_services/longmath
- gitlab.com/wangzhuan/xlog
- gitlab.qobserve.com/teamq/flux/stdlib/kafka
- gitlab.roman-davydov.ru/util/kafka-logger
- gitlab.systems-fd.com/packages/golang/async-constistency/edispatcher-kafka/v3
- gitlab.turtlecoding.de/turtlecoding/common/server-common
- gitlab.u-jy.cn/xiaoyang/go-queue/kq
- gitlab.ws/zeromicro/go-queue/kq
- go.ntppool.org/common/kafka
- go.unistack.org/micro-broker-segmentio/v3
- gofr.dev/pkg/gofr/datasource/pubsub/kafka
- gopkg.in/DataDog/dd-trace-go.v1/contrib/segmentio/kafka.go.v0
- gopkg.in/pachyderm/pachyderm.v1/etc/testing/kafka
- lab.evlic.cn/go/pkg/log
- shylinux.com/x/redis-story/src/kafka
- xgit.xiaoniangao.cn/xngo/lib/xlog