Go to main page
Known importers: 4,085 (displaying 5,798 packages, including internal and invalid packages)
- barney.ci/go-otel
- bitbucket.org/Dartonian/common-bus
- bitbucket.org/InvolvedPanda/notifier
- bitbucket.org/bsdrpst/gopkg/q/kafka
- bitbucket.org/cornjacket/event_processor/client_lib
- bitbucket.org/cornjacket/view_hndlr/client_lib
- bitbucket.org/credmais/kafka/pkg/mensageria/segmentio-kafka
- bitbucket.org/krjura/kafka-tools-golang/mfilters
- bitbucket.org/krupnik_a/logclient
- bitbucket.org/markfwalker/atom
- bitbucket.org/rctiplus/vegapunk/event/kafka
- cnb.cool/ifree/dev/micro/broker/kafka
- codeberg.org/anarproject/anar-logger
- dev.aminer.cn/gopkg/ppl/transformer/ds
- gb.xjqchip.workers.dev/rancher/rancher/pkg/controllers/user/logging/utils
- git.dlx36.com/dlx36/hive/internal/kafka
- git.futuregamestudio.net/be-shared/slot-game-module.git/events/kafka
- git.korputeam.ru/newbackend/adapters/queue/kafka
- 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
- gitea.com/DemoTechJong/HTTP/prod_grad_transaction
- gitea.weitiangame.com/sdk/wt-utils/kafka
- gitee.com/ander888/tools/conn
- gitee.com/easyj-go/settings/middleware/kafka
- gitee.com/eden-framework/plugin-kafka/kafka
- gitee.com/entree/framework/client
- gitee.com/flash520/pusher/pkg/connector
- gitee.com/geek_black_li/ezgo/mq/kafka
- 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/laosan123/common-util-yunjingyou/helper/kafkahelper
- gitee.com/ldx_5/hailride/pkg/platform/infra/mq/kafka
- gitee.com/liu-fudan/devcloud/maudit/client/bus
- gitee.com/monitor_dev/alerts-management/alerts-receiver/drivers/kafka
- gitee.com/night-tc/gobige/kafka
- gitee.com/qyang_1/g0/app/model
- 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/vrv_media/go-micro-framework/pkg/kafka
- gitee.com/wanjimao/common-util-yun/helper/kafkahelper
- gitee.com/wanjimao/common-util-yunjingyou/helper/kafkahelper
- gitee.com/wanjimao/common-util/helper/kafkahelper
- gitee.com/wanjimao/dongli-util/helper/kafkahelper
- gitee.com/wanjimao/main-common-utils/helper/kafkahelper
- gitee.com/wanjimao/platform-gitee/common/mq/kafka/internal
- gitee.com/wshadm/go11/devcloud-mini/maudit/clients/middleware
- gitee.com/wxlao/logger
- gitee.com/zaper/kafka-service/model
- gitee.com/zaper/kafka-service/other/test/consumer_test
- gitee.com/zaper/kafka-service/other/test/producer_test
- gitee.com/zaper/kafka-service/service/connect
- gitee.com/zaper/kafka-service/service/consumer
- gitee.com/zaper/kafka-service/service/consumer/consumer_model
- gitee.com/zaper/kafka-service/service/health
- gitee.com/zaper/kafka-service/service/metadata
- gitee.com/zaper/kafka-service/service/metadata/model
- gitee.com/zaper/kafka-service/service/producer
- gitee.com/zaper/kafka-service/util
- gitee.com/zhejiang-zhijia-information/go-kayn/consumer
- gitee.com/zhoushuyu/devcloud/maudit/client/bus
- gitfin.haiziwang.com/golang/tgo/mq/kafka
- gitflic.ru/project/izenka/receipt-parser-sdk/kafka
- github.1git.de/rancher/rancher/pkg/controllers/user/logging/utils
- github.com/0Bleak/clayjar-jar-service/internal/messaging
- 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/0xarchit/contestsync/internal/queue
- 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/1ef7yy/go-kafka-poc/internal/kafka
- 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/4ubak/cg-shared-libs/kafka
- github.com/4udiwe/big-bob-pizza/order-service/pkg/kafka
- github.com/508284405/leetcode2/kafka
- github.com/510909033/redisx/demo_kafka
- github.com/51xpx/pkgx/pkg/kafkax
- github.com/520aky/common-pkg/amqp/kafka/v1
- github.com/7leven7/xm-company-crud/app/controllers
- github.com/ALexfonSchneider/goplatform/pkg/broker/kafka
- github.com/AMETORY/ametory-erp-modules/thirdparty/kafka
- github.com/AchmadRifai/kafka-go-consumer
- github.com/Adam0120/sdk-utils/kafka
- github.com/AhmadMuj/books-api-go/internal/events
- github.com/Aidin1998/finalex/internal/infrastructure/messaging
- github.com/Aidin1998/finalex/internal/infrastructure/ratelimit
- github.com/Aidin1998/finalex/internal/marketmaking/marketdata
- github.com/Aidin1998/finalex/internal/marketmaking/marketdata/backpressure
- github.com/Aidin1998/finalex/internal/trading/coordination
- github.com/Aidin1998/finalex/internal/trading/messaging
- github.com/Aidin1998/finalex/internal/trading/settlement
- github.com/Aidin1998/finalex/internal/wallet/events
- github.com/AldiRvn/mizu/PubSub
- github.com/Aleph-Alpha/std/v1/kafka
- github.com/AlexEr256/messageService/consumer/cmd
- github.com/AlexHornet76/FastEx/scripts/kafka-consumer
- github.com/Alexx1088/userservice/internal/kafka
- github.com/AlfianVitoAnggoro/study-buddies/pkg/kafka
- github.com/Alibay/go-kit/kafka
- github.com/Alieksieiev0/feed-service/internal/transport/kafka
- github.com/AmanKumar2696/sidekick/outputs
- github.com/Ametion/dyffi/broker
- github.com/Amirhossein2000/RequestTasker/internal/infrastructures/kafka
- github.com/AndreeJait/go-utility/v2/brokerw/kafkaw
- github.com/Aoladiy/go-with-tools/internal/messaging
- github.com/Aounjafri/BookStore/pkg/kafka
- github.com/Apicurio/apicurio-registry-k8s-tests-e2e/testsuite/utils/converters
- github.com/ApollosProject/pgstream-wal2json/pkg/kafka
- github.com/AramLab/LinkBuddy/services/bot-service/kafka
- github.com/ArchitBhonsle/kafka-example/reader
- github.com/AridanWarlock/pinnAutomizer/pkg/kafka/segmentio
- github.com/ArnaudGuiovanna/ouvrier
- github.com/ArnavChoudhary9/sigma-obs/internal/kafka
- github.com/AskaryanKarine/bmstu-ds-3/internal/gateway/retryer
- github.com/Asliddin3/customer-servis/kafka
- github.com/AsrofunNiam/lets-code-micro-service-kafka/repository
- github.com/Asylann/gRPC-server/kafka-local
- github.com/AyanChoudhary/transponster/pkg/kafka
- github.com/BLAgency/BLkafka/kafka
- github.com/BaseMax/KafkaDataProcessingGo/cmd
- github.com/Bendomey/nucleo-go/transit/kafka
- github.com/BernsteinMond/gorecengine/inference/src/pkg/kafkahelp
- github.com/BevisDev/godev/kafkax
- github.com/BigKAA/topologymetrics/sdk-go/dephealth/checks/kafkacheck
- github.com/BinaryArchaism/users-service/users-service/kafka
- github.com/BitofferHub/pkg/middlewares/mq
- github.com/BlockBoyJB/WB_L0/pkg/broker
- github.com/BlurredDev/go-kafka-gateway/internal/kafka
- github.com/BobZombiE69/btcpool-go-modules/chainSwitcher
- github.com/BrobridgeOrg/kabridge/tests
- github.com/BruceChen7/case-study/test-kafka
- 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/BwCloudWeGo/bw-cli/pkg/kafkax
- github.com/CG-SS/right-to-reign-go-backend/libs/ebs
- github.com/Caixetadev/fraud-check-kafka-integration/transaction/pkg/kafka
- github.com/CamilleLange/XM-company/internal/interfaces/events
- 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/CodeSyncr/nimbus/queue
- github.com/Coflnet/ci-notifications
- github.com/D1sordxr/simple-bank/bank-services/internal/presentation/consumer
- github.com/DOs0x12/TeleBot/client/broker
- github.com/DOs0x12/TeleBot/client/v2/broker/consumer
- github.com/DOs0x12/TeleBot/client/v2/broker/producer
- github.com/DOs0x12/TeleBot/client/v2/broker/topic
- github.com/DOs0x12/TeleBot/client/v3/broker/consumer
- github.com/DOs0x12/TeleBot/client/v3/broker/producer
- github.com/DOs0x12/TeleBot/client/v3/broker/topic
- github.com/DOs0x12/TeleBot/server/internal/infrastructure/broker
- github.com/DOs0x12/TeleBot/server/v2/broker_data
- github.com/DOs0x12/TeleBot/server/v2/internal/infrastructure/broker/consumer
- github.com/DOs0x12/TeleBot/server/v2/internal/infrastructure/broker/producer
- github.com/DOs0x12/TeleBot/server/v2/internal/infrastructure/broker/topic
- github.com/DOs0x12/TeleBot/server/v3/internal/infrastructure/broker/consumer
- github.com/DOs0x12/TeleBot/server/v3/internal/infrastructure/broker/producer
- github.com/DOs0x12/TeleBot/server/v3/internal/infrastructure/broker/topic
- github.com/DamirAbd/HLA-HW1/stream
- 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/DeadlyParkour777/code-checker/judge_service/cmd/app
- github.com/DeadlyParkour777/code-checker/judge_service/internal/handler
- github.com/DeadlyParkour777/code-checker/judge_service/internal/service
- github.com/DeadlyParkour777/code-checker/result_service/cmd/app
- github.com/DeadlyParkour777/code-checker/result_service/internal/handler
- github.com/DeadlyParkour777/code-checker/submission_service/cmd/app
- github.com/DeadlyParkour777/code-checker/submission_service/internal/service
- github.com/DearRude/traffic-analysis/data-generator
- github.com/Digital-Creators-Team/slot-game-module/events/kafka
- github.com/DilanHera/mockTP/internal/kafka
- github.com/DimaJoyti/go-coffee/crypto-wallet/pkg/kafka
- github.com/DimaJoyti/go-coffee/internal/ai/messaging
- github.com/DimaJoyti/go-coffee/pkg/messaging
- github.com/DimaJoyti/go-coffee/serverless/functions/ai-agent-coordinator
- github.com/DimaJoyti/go-coffee/serverless/functions/coffee-order-processor
- github.com/DimaJoyti/go-coffee/web3-wallet-backend/pkg/kafka
- github.com/DmitriiDobr/kafkaNotification/pkg
- github.com/DmitriySama/teammate_search/internal/producer
- github.com/DoCongThanhPhuong/go-backend/cmd/cli/kafka
- github.com/Domenick1991/students/internal/consumer/students_Info_upsert_consumer
- github.com/DoodleScheduling/k8skafka-controller/kafka
- github.com/Duke1616/ecmdb/internal/worker/internal/service
- github.com/Dung24-6/go-pay-gate/internal/store/kafka
- github.com/EMCECS/influx/query/functions
- github.com/EdgeCast/vflow/producer
- github.com/Ekstrem/DigiTFactory.Go.Libraries/eventbus/kafka
- github.com/EmreZURNACI/kafka-go-implementation/app
- github.com/Encounter27/eh-outbox/projector
- github.com/EricWorld/eventstream-go-sdk/v3
- github.com/Erwin011895/go-examples/user_service
- github.com/Espina2/event-bus/kafka
- github.com/EvWilson/sqump/exec
- github.com/Evolvra/gofr-evolvra/pkg/gofr/datasource/pubsub/kafka
- github.com/Falokut/accounts_service/internal/events
- 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/email_service/internal/events
- github.com/Falokut/profiles_service/internal/events
- github.com/Fau1con/kafkawrapper
- github.com/FernandoCagale/c4-notify/internal/broker/consumer
- github.com/Ferrany1/system-tools/pkg/pubsub/kafka
- github.com/Flaviogonzalez/e-commerce/contracts/logger
- github.com/ForbiddenR/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/GRMrGecko/freeipa-health-metrics
- github.com/GalievRinat/go-postgres-kafka/handler
- github.com/Genialngash/sasapay-mandate-microservice/kafkaClient
- github.com/GeoDB-Limited/odincore/chain/hooks/emitter
- github.com/GlebPoroshin/geochat-shared/kafka
- github.com/GordieH/open_gov
- github.com/Govorov1705/go-commerce/pkg/kafka/kafkago
- github.com/Gustcat/shared-lib/kafka_common
- github.com/HXSecurity/DongTai-agent-go/core/kafkaGo/kafkaWriter
- github.com/Hai-Che/Go_Ecommerce_Backend_API/cmd/cli/kafka
- github.com/HekapOo-hub/Kafka/producer
- github.com/HelixDevelopment/helix_cluster/pkg/pubsub
- github.com/Hsiangya/logger
- github.com/IDarar/grpc-chat-service/internal/transport/mq
- github.com/ISSHEB/core/kafka
- github.com/ITA-Dnipro/Dp-230-Test-XSS/internal/kafka
- github.com/ITu-CloudWeGo/itu_rpc_auth/rpc/utils
- github.com/IWhitebird/go-leader-board/internal/mq
- github.com/Ilya19871986/hw-test/hw12_13_14_15_16_calendar/internal/mq/kafka
- github.com/IlyaPuzyrev/telegram-nats-bridge
- github.com/InfluxCommunity/flux/stdlib/kafka
- github.com/InspectorVitya/znakvlg-backend/internal/mq
- github.com/Intelladon-LLC/dd-trace-go/contrib/segmentio/kafka.go.v0
- github.com/Iori372552686/GoOne/lib/service/bus
- github.com/JECSand/identity-service/api_gateway_service/identity/commands
- github.com/JECSand/identity-service/command_service/identity/commands
- github.com/JECSand/identity-service/command_service/identity/delivery/kafka
- github.com/JECSand/identity-service/command_service/server
- github.com/JECSand/identity-service/pkg/kafka
- github.com/JECSand/identity-service/pkg/tracing
- github.com/JECSand/identity-service/query_service/identity/delivery/kafka
- github.com/JECSand/identity-service/query_service/server
- github.com/JMURv/e-commerce/gateway/pkg/controllers
- github.com/JanMeckelholt/myaktion-go/src/banktransfer/kafka
- github.com/Jbcampbe/kafka-go/topics
- github.com/JianLoong/robogo/internal/actions
- github.com/JiejingTech/binlog-sink-kafka
- github.com/JitenPalaparthi/mb-go-client/impl/kafka
- github.com/JohnnyKahiu/speedsales_inventory/internal/broker
- github.com/JordyMoos/kafka-disconnect-test
- github.com/JovidYnwa/microCmp/internal/kafka
- github.com/Junjiayy/hamal/pkg/core/readers
- github.com/Kalaganov-Konstantin/eventflow-commerce/shared/libs/events
- github.com/KarmaBeLike/message-processor/internal/kafka
- github.com/Kbusch54/notification-service/stream/kafka
- github.com/Kevinello/kafka-client
- github.com/Khmelov/Distcomp/251003/Nasevich/restbasics/discussion/internal/handler/kafka
- github.com/Khmelov/Distcomp/251004/Sazonov/internal/adapter/kafka/notice
- github.com/Khmelov/Distcomp/251004/Sazonov/notice/internal/handler/kafka
- github.com/Khmelov/Distcomp/251004/Sazonov/notice/internal/handler/kafka/notice
- github.com/Khmelov/Distcomp/251004/Sazonov/notice/pkg/kafka
- github.com/Khmelov/Distcomp/251004/Sazonov/pkg/kafka
- github.com/Kilat-Pet-Delivery/lib-common/kafka
- github.com/Kim-Yukyung/grpc-kafka-chat/internal/kafka
- github.com/KotFed0t/notification_service/data/queue/kafka/notificationConsumer
- github.com/KyKyPy3/clean/internal/infrastructure
- github.com/KyKyPy3/clean/internal/infrastructure/queue
- github.com/KyKyPy3/clean/internal/modules/registration/infrastructure/controller/queue/v1
- github.com/KyKyPy3/clean/internal/modules/registration/infrastructure/gateway/queue
- github.com/KyKyPy3/clean/pkg/kafka
- github.com/LabKiko/kiko-component/kafka
- github.com/Laresto-OU/laresto-go-common/pkg/kafka
- github.com/LavaJover/shvark-order-service/internal/infrastructure/kafka
- github.com/LeHuuHai/server-management/internal/domain/mq
- github.com/LeHuuHai/server-management/internal/infra/kafka
- github.com/LeHuuHai/server-management/internal/infra/runtime/eswriter
- github.com/LeHuuHai/server-management/internal/infra/runtime/gw
- github.com/LeHuuHai/server-management/internal/infra/runtime/master
- github.com/LeHuuHai/server-management/internal/infra/runtime/pgwriter
- github.com/LeHuuHai/server-management/internal/infra/runtime/worker
- github.com/LiangNing7/goutils/pkg/options
- github.com/Lidne/praktika_MAI/pkg/kafka
- github.com/Lord-Y/synker/processing
- github.com/LoveCatdd/util/pkg/lib/core/kafka
- github.com/M-Fisher/companies_api/app/internal/services/events/clients/kafka
- github.com/MajotraderLucky/Kafka-FIO-Listener/apiconfig
- github.com/Maksim646/feedback_analysis/api_gateway_service/internal/feedbacks/commands
- github.com/Maksim646/feedback_analysis/pkg/kafka
- github.com/Maksim646/feedback_analysis/pkg/tracing
- github.com/Maksim646/feedback_analysis/reader_service/internal/feedback/delivery/kafka
- github.com/Maksim646/feedback_analysis/reader_service/internal/server
- github.com/ManyakRus/starter/kafka_connect
- github.com/MatTwix/Ultimate-Metrics-Platform/services/cache-service/pkg/kafka
- github.com/MatejaMaric/kafka-go-cardinality/kafkaio
- github.com/MatthewZholud/CompanyManager-full/CompanyManager-api/internal/kafka
- github.com/MatthewZholud/CompanyManager-full/CompanyManager-company/internal/kafka
- github.com/MatthewZholud/CompanyManager-full/CompanyManager-employee/internal/kafka
- github.com/MatthewZholud/CompanyManager-full/CompanyManager-tgbot/internal/kafka
- github.com/MauricioAntonioMartinez/aws/eventbus
- github.com/Meesho/BharatMLStack/inferflow/handlers/external/kafka
- github.com/MemetBadut/product-service/internal/kafka
- github.com/Micky90-sys/go-gin-postgres-redis-kafka
- github.com/MikL9/observability/logger/handlers/kafka
- github.com/Mikhalevich/tg-coffee-shop-bot/cmd/msgconsumer/internal/app/kafkaconsumer
- github.com/Miklend/lib-CG/client/broker/kafka
- github.com/MrAndreID/goapi/messagebrokers
- github.com/MrXavier/kafka-go-project
- github.com/Mubinabd/modestyMart/internal/usecase/kafka
- github.com/MuhammedAshifVnr/Gig_Space/Chat_Svc/pkg/config
- github.com/MuhammedAshifVnr/Gig_Space/Chat_Svc/pkg/internal/service
- github.com/MuhammedAshifVnr/Gig_Space/Chat_Svc/utils/helper
- github.com/MuhammedAshifVnr/Gig_Space/Gig_Svc/pkg/config
- github.com/MuhammedAshifVnr/Gig_Space/Gig_Svc/pkg/internal/service
- github.com/MuhammedAshifVnr/Gig_Space/Payment_Svc/pkg/config
- github.com/MuhammedAshifVnr/Gig_Space/Payment_Svc/pkg/internal/service
- github.com/MuhammedAshifVnr/Gig_Space/Payment_Svc/utils/notification
- github.com/MuhibNayem/connectify-v2/shared-entity/kafka
- github.com/Mutezebra/tiktok/pkg/kafka
- github.com/Muxi-X/forum-be/model
- github.com/MyCarrier-DevOps/goLibMyCarrier/kafka
- github.com/N0F1X3d/todo/pkg/kafka
- github.com/NARUBROWN/spine/internal/event/infra/kafka
- github.com/NGUYENDINHATK2/gun_core_go_ms/infrastructure/outbox
- github.com/NIROOZbx/notification-engine/engine/notification/queue
- github.com/NOVAPokemon/notifications/kafka
- github.com/NSObjects/ima/internal/pump/pumps
- github.com/Nanhtu187/online-judge/src/apps/backend/runner/internal/adapter
- github.com/Nanhtu187/online-judge/src/apps/backend/runner/internal/cmd
- github.com/Nanhtu187/online-judge/src/apps/backend/runner/internal/handler
- github.com/Nanhtu187/online-judge/src/apps/backend/server/internal/cmd
- github.com/Nanhtu187/online-judge/src/apps/backend/server/internal/handler
- github.com/Nanhtu187/online-judge/src/apps/backend/server/internal/service
- github.com/Neiva07/queue-management-service/services
- github.com/NickTaporuk/gigamock/src/scenarioType
- github.com/Niladri2003/server-monitor/server/consume
- github.com/NishLy/go-kafka-boilerplate/pkg
- github.com/Nixson/kafka
- github.com/Niyko/Athena
- github.com/Nizom98/kafka-mover
- github.com/Novip1906/tasks-grpc/auth/internal/kafka
- github.com/NullHypothesis/tokenizer
- github.com/ODIM-Project/ODIM/lib-messagebus/datacommunicator
- github.com/Oxygenta-Team/FortiKey/pkg/queue/kafka
- github.com/PAWSOME-INDONESIA/paw_kit/messaging/kafka
- github.com/PacktPublishing/Mastering-Go-Second-Edition/ch14
- github.com/PaperMan11/goim/pkg/queue/kafka
- github.com/PickHD/LezPay/customer/internal/application
- github.com/PickHD/LezPay/customer/internal/infrastructure
- github.com/PickHD/LezPay/merchant/internal/application
- github.com/PickHD/LezPay/merchant/internal/infrastructure
- github.com/PickHD/LezPay/wallet/internal/application
- github.com/PickHD/LezPay/wallet/internal/infrastructure
- github.com/PinataCloud/convoy-go/v2
- github.com/PingCAP-QE/ee-apps/cloudevents-server/pkg/events/handler
- github.com/PingCAP-QE/ee-apps/cloudevents-server/pkg/kafka
- github.com/PingCAP-QE/ee-apps/publisher/cmd/worker
- github.com/PingCAP-QE/ee-apps/publisher/internal/service/impl/fileserver
- github.com/PingCAP-QE/ee-apps/publisher/internal/service/impl/image
- github.com/PingCAP-QE/ee-apps/publisher/internal/service/impl/share
- github.com/PingCAP-QE/ee-apps/publisher/internal/service/impl/tiup
- github.com/Podcast-service/Auth-service/internal/infrastructure/kafkapkg
- github.com/Portfolio-Advanced-software/micro-service-communication-prototype/Kafka/streaming
- github.com/Pos1t1veM1ndset/shiny-homework/hw12_13_14_15_calendar/internal/kafkascheduler
- github.com/Praisindo/pkg-library/app/pkg/broker/kafkaservice
- github.com/Prokopevs/mini/server/internal/kafka
- github.com/Quizert/room-reservation-system/BookingSvc/internal/clients/kafka
- github.com/QutaqKicker/ChatParser/Common/myKafka
- github.com/RHEnVision/provisioning-backend/internal/kafka
- github.com/RaindeerMokus/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/RandomEstimate/go_stream/task
- github.com/Ranganaths/minion/core/multiagent
- github.com/RapidCodeLab/ZapLogger
- github.com/RedHatInsights/haberdasher/emitters
- github.com/RedHatInsights/kafka-zerolog/kafkazerolog
- github.com/RedHatInsights/sources-api-go/kafka
- github.com/Redarcher9/Books-Management-System/internal/infrastructure/kafka
- github.com/RehanAthallahAzhar/tokohobby-messaging/kafka
- github.com/RenHuangfu/tools/kafka
- github.com/Rocket-Innovation/mca-engine-sdk/pkg/events
- github.com/RockkleyPushPost/common/kafka
- github.com/RohitIndira/Algo-Treading/pkg/kafka
- github.com/Roma7-7-7/sandbox/messaging/kafka
- github.com/RomanV1/go-sms-email/internal/kafka
- github.com/RonYariv/localflow/shared/kafka
- github.com/RonkyTang/go-queue/kq
- github.com/Rotiez/card-libs/gametimer/kafka/producer
- github.com/Rounak1998/vflow/producer
- github.com/Royal17x/flagr/backend/pkg/kafka
- github.com/RoyceAzure/lab/rj_kafka/pkg/admin
- github.com/RoyceAzure/lab/rj_kafka/pkg/balancer
- github.com/RoyceAzure/lab/rj_kafka/pkg/config
- github.com/RoyceAzure/lab/rj_kafka/pkg/consumer
- github.com/RoyceAzure/lab/rj_kafka/pkg/consumer/mock
- github.com/RoyceAzure/lab/rj_kafka/pkg/errors
- github.com/RoyceAzure/lab/rj_kafka/pkg/model
- github.com/RoyceAzure/lab/rj_kafka/pkg/producer
- github.com/RoyceAzure/lab/rj_kafka/pkg/producer/mock
- github.com/RozmiDan/gameReviewHub/pkg/kafka
- github.com/RumbiaID/pkg-library/app/pkg/broker/kafkaservice
- github.com/S1FFFkA/user-mgz/internal/consumer/chatmessages
- github.com/SENERGY-Platform/device-command/pkg/configuration
- github.com/SENERGY-Platform/live-data-worker/pkg/kafka
- github.com/SENERGY-Platform/moses/lib/config
- github.com/SENERGY-Platform/permission-command/lib
- github.com/SENERGY-Platform/process-fog-deployment/pkg/tests/docker
- github.com/SENERGY-Platform/process-sync/pkg/kafka
- github.com/SENERGY-Platform/smart-service-repository/pkg/tests/docker
- 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/Sh00ty/cloud-nlb/healthcheck/internal/coordinator/targetwatcher
- github.com/Sh1ni-Gami/WB_Tech_L0/kafka
- github.com/Shannon-Labs/driftlock/collector-processor/driftlockcbad/kafka
- github.com/Shoothzj/cli/pkg
- github.com/SimeonAleksov/go-cli/consumer
- github.com/SkySingh04/fractal/integrations
- github.com/Skysolderone/zero_core/kafka
- github.com/SneaX-23/GoServices/auth-service/internal/messaging
- github.com/SoulStalker/kafkaproducer/internal/producer
- github.com/SpeedxPz/pcrd-version-updater/src/repository/version_event_repository
- github.com/SriHemnath/credit_card_processing/streams/kafka
- github.com/StanislavYaroslavtsev/url-shortener/services/url-shortener/internal/producer
- github.com/SteveHNH/go-test-app
- github.com/SubhamMurarka/chat_app/server/kafka
- github.com/Sucsz/banner-rotator/internal/kafka
- github.com/Swiffy12/taskify/internal/clients/mail-notifier/kafka-client
- github.com/SyaibanAhmadRamadhan/event-bus/kafka
- github.com/Synarcs/Data-Exfiltration-Security-Framework/pkg/events/stream
- github.com/T-Prohmpossadhorn/go-core/kafka
- github.com/Tackeyyyyyyyy/kafka_go
- github.com/Tangerg/lynx/stream/binding/kafka
- github.com/TerFear/NeuralProcessingService/internal/kafka
- github.com/Thanhbinh1905/go-training-system/shared/kafka
- github.com/TheDao032/golang-architectures-demo/internal/api/kafka
- github.com/Thoustick/pocket_marketplace/analytic-service/kafka_consumer
- github.com/Thoustick/pocket_marketplace/analytic-service/mocks
- github.com/Thoustick/pocket_marketplace/product-service/kafka_publisher
- github.com/Thoustick/pocket_marketplace/product-service/mocks
- github.com/Thoustick/pocket_marketplace/recommendation-service/kafka_consumer
- github.com/Thoustick/pocket_marketplace/user-service/kafka_publisher
- github.com/Thoustick/pocket_marketplace/user-service/mocks
- github.com/Timofey0880/GoProject2/event-service/internal/producers/event_created_producer
- github.com/TingYunGo/goagent/mq/kafka/kafka-go
- github.com/Tuhis/edge-receiver/pkg/kafkawrapper
- github.com/TykTechnologies/tyk-pump/pumps
- github.com/Utsav-pixel/gosense/internal/publisher
- github.com/Uttamnath64/quixzap/app/appcontext
- github.com/V4T54L/goship/pkg/goship/messaging
- github.com/VadimGossip/kafkaGoExample/kafka
- github.com/ValdemarGr/DM874-go
- github.com/ValerySidorin/mypaypal/internal/messagebus/kafka
- github.com/VanThen60hz/GoShop/cmd/cli/kafka
- github.com/VenzeneCorp/loginSignup/events/producers
- github.com/VikashKulhari/mykafka
- github.com/VincentBoillotDevalliere/kafka-cli/cmd
- github.com/Vladimir220/markerplace/logger_lib
- github.com/Vonage/gosrvlib/pkg/kafka
- github.com/Vovarama1992/go-utils/kafkautil
- github.com/Wafer233/WaferTakeOut/Server/wafer-take-out-server/api-gateway/internal/infrastructure/kafka
- github.com/WenLopes/recent/app/cmd
- github.com/XXXXD-cation/ez-TIP/pkg/messaging
- github.com/YFatMR/go_messenger/sandbox_service/sandbox
- github.com/YagorX/shop-catalog-service/internal/events
- github.com/YanivYehDev/kafka-utils
- github.com/Yeshwanth-Athmakuri/xk6-kafka
- github.com/Yinlerens/audit-sdk/client
- github.com/Yostardev/skuld/mq/xkafka
- github.com/Youknow2509/go-ecommerce/cmd/cli/kafka
- github.com/Youknow2509/go-ecommerce/global
- github.com/Youknow2509/go-ecommerce/internal/initialize
- github.com/Youknow2509/go-ecommerce/internal/utils/sendto/kafka
- github.com/Youknow2509/go-ecommerce/pkg/utils/kafka
- github.com/Youknow2509/go-ecommerce/pkg/utils/kafka/impl
- github.com/ZZZ556755/gzIM/internal/kafka
- github.com/Zardan-Systems-Organization/monitoring-module/pkg/monitor
- github.com/Zeb-D/go-util/mq
- github.com/ZiyadBouazara/bitcoin-pulse/stockservice-go/internal/adapters/kafka
- github.com/ZoneCNH/kafkax/pkg/kafkax/kafkago
- github.com/ZwickyTransientFacility/ztf-go-archivist
- github.com/a-blender/rancher/pkg/controllers/user/logging/utils
- github.com/a-e-lee/factory-runtime/runtime/go/kafka
- github.com/aaabigfish/gopkg/mq/kafka
- github.com/aadheeb/gomiddleware-beagle
- github.com/aalemi-dev/stdlib-lab/kafka
- 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/aarchies/hephaestus/message/kafka
- github.com/aaronrancher/rancher/pkg/controllers/user/logging/utils
- github.com/aarthikrao/timeMachine/utils/kafkaclient
- github.com/abdollahpour/kafka-konsumer/v2
- github.com/abdullahPrasetio/wapgo/pkg/messaging/kafka
- 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/accept-io/midas/internal/kafka
- github.com/acd19ml/TalentRank/apps/user/kafka
- github.com/aceeric/kafka-scale
- github.com/acidonper/jump-app-golang-events/pkg
- github.com/acornpublishing/mastering-go-2e/ch14
- github.com/adifiedio/location-streamer/pkg/queue
- github.com/adimax2953/go-tool/kafkatool
- github.com/adityaeka26/go-pkg/kafka
- github.com/adrianolaselva/dataql/pkg/mqreader/kafka
- github.com/aedobrynin/soa-hw/core/internal/repo/statisticsrepo
- github.com/aeswibon/manga-cdc/scraper/internal/kafka
- 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/agoXQ/QuantLab/pkg/kafka
- github.com/agrpranjal07/Nexus/broker
- github.com/aidahputri/go-transaction/kafka
- github.com/aishwary11/fiber-tut/kafka
- github.com/ajarv/kafgo/cmd
- github.com/ajruckman/vflow/producer
- github.com/akazwz/gin-api/kafka/counter
- github.com/akmadan/throome/pkg/adapters/kafka
- github.com/akmalsyrf/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/akmmp241/topupstore-microservice/shared
- github.com/akshit-git24/vesper-hivemind/vesper/v2
- 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/alekseiapa/go-kafka-examples/advanced/backpressure_handling
- github.com/alekseiapa/go-kafka-examples/advanced/dead_letter_queue
- github.com/alekseiapa/go-kafka-examples/advanced/distributed_tracing
- github.com/alekseiapa/go-kafka-examples/advanced/event_sourcing
- github.com/alekseiapa/go-kafka-examples/advanced/fault_tolerant_consumer
- github.com/alekseiapa/go-kafka-examples/advanced/kafka_streams_api
- github.com/alekseiapa/go-kafka-examples/advanced/large_message_handling
- github.com/alekseiapa/go-kafka-examples/advanced/manual_offset_management
- github.com/alekseiapa/go-kafka-examples/advanced/schema_registry_integration
- github.com/alekseiapa/go-kafka-examples/advanced/windowed_aggregations
- github.com/alekseiapa/go-kafka-examples/basic/consume_json_messages
- github.com/alekseiapa/go-kafka-examples/basic/consume_single_message
- github.com/alekseiapa/go-kafka-examples/basic/consumer_error_handling
- github.com/alekseiapa/go-kafka-examples/basic/consumer_group_config
- github.com/alekseiapa/go-kafka-examples/basic/consumer_setup
- github.com/alekseiapa/go-kafka-examples/basic/produce_json_messages
- github.com/alekseiapa/go-kafka-examples/basic/producer_config
- github.com/alekseiapa/go-kafka-examples/basic/producer_error_handling
- github.com/alekseiapa/go-kafka-examples/basic/producer_setup
- github.com/alekseiapa/go-kafka-examples/basic/send_string_message
- github.com/alekseiapa/go-kafka-examples/intermediate/avro_producer
- github.com/alekseiapa/go-kafka-examples/intermediate/backoff_retries_consumer
- github.com/alekseiapa/go-kafka-examples/intermediate/concurrent_message_processing
- github.com/alekseiapa/go-kafka-examples/intermediate/custom_partitioners
- github.com/alekseiapa/go-kafka-examples/intermediate/kafka_headers
- github.com/alekseiapa/go-kafka-examples/intermediate/message_partitioning
- github.com/alekseiapa/go-kafka-examples/intermediate/producer_retry_logic
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/consumer_benchmarking
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/consumer_mock_testing
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/grafana_integration
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/high_throughput_simulation
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/integration_tests_pipelines
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/lag_monitoring
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/producer_benchmarking
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/producer_mock_testing
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/unit_tests_consumer_logic
- github.com/alekseiapa/go-kafka-examples/streaming/log_processing_pipeline
- github.com/alekseiapa/go-kafka-examples/streaming/message_filtering
- github.com/alekseiapa/go-kafka-examples/streaming/message_to_rest_api
- github.com/alekseiapa/go-kafka-examples/streaming/message_transformation
- github.com/alekseiapa/go-kafka-examples/streaming/metrics_pipeline
- github.com/alekseiapa/go-kafka-examples/streaming/real_time_aggregation
- github.com/alekseiapa/go-kafka-examples/streaming/real_time_chat
- github.com/alekseiapa/go-kafka-examples/streaming/stream_to_database
- github.com/alekseiapa/go-kafka-examples/streaming/topic_joining
- github.com/alekseiapa/go-kafka-examples/streaming/video_metadata_processing
- github.com/alekssum/go-playground/kafka/cmd/producer
- github.com/alenalato/users-service/internal/events/kafka
- github.com/alex-fullstack/event-sourcingo/infrastructure/kafka
- github.com/alex-kuck/apm-kafka-go
- github.com/alex-pyslar/kuznechi-api/pkg/kafka
- github.com/alexander-winters/SENG468-A2/kafka-docker/kafkaService
- github.com/alexanderjulianmartinez/data-watch/internal/cdc/debezium
- github.com/alexandria-oss/streams/driver/kafka
- github.com/alexciechonski/BigTableLite/pkg/server
- github.com/alexermolov/go-kafka-pusher/internal/kafka
- github.com/alexey-dobry/medical-service/internal/pkg/kafka
- github.com/alexjohnkennedy/rickrollrankings/LinkChecker/kafkaconsumerproducer
- github.com/alexsuriano/kafkaGoStudy
- 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/alimikegami/pos-microservices/user-service/internal/infrastructure/message-queue/kafka
- github.com/alirezashaheri/kafka-go/topics
- github.com/alkuwaiti/auth/internal/infra/kafka
- github.com/allen9009/kafka-logger-go
- github.com/alonexy/complug/contrib/queue/kafka
- github.com/alpersimsek1/rabbitmqtokafkagoexample
- github.com/alserov/restate/metrics/internal/async
- github.com/alxandru/client-vehicletracking/pkg/kafka
- github.com/amirasaad/fintech/scripts/kafka_smoketest
- github.com/amirhnajafiz/debezium/connector/internal/kafka
- github.com/amitch-git/test-kafka-event-with-microservice/PunchingSystem
- github.com/amjealousy/chat-utils
- 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/andygeiss/cloud-native-utils/messaging
- 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/anishchenkoivan/hotel-app/booking-service/internal/clients
- github.com/annchain/BlockDB/plugins/server/kafka
- github.com/anooshcnayak/butterfly-go
- github.com/antonpriyma/otus-highload/pkg/clients/dwh
- github.com/antonybholmes/go-mailserver
- github.com/antsrp/fio_service/internal/usecases/broker/kafka
- github.com/apexkit/gamekit/eventbus
- github.com/apoorvprecisely/go-base/base/transport/kafka
- github.com/aravindan-palani/golangtask/KAFKA
- github.com/archmangler/asynchronous-event-handling-using-microservices-and-kafka/microservices/inventory-service
- github.com/archmangler/asynchronous-event-handling-using-microservices-and-kafka/microservices/notification-service
- github.com/archmangler/asynchronous-event-handling-using-microservices-and-kafka/microservices/shipper-service
- github.com/archmangler/asynchronous-event-handling-using-microservices-and-kafka/microservices/warehouse-service
- github.com/arista-netdevops-community/cvp-events-pubsub/pkg
- github.com/aritiaya50217/project_beginner/microservice/contract_management_platform/notification-worker/internal/adapters/queue
- github.com/aritradevelops/billbharat/backend/shared/events
- 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/artie-labs/reader/lib/kafkalib
- github.com/asemyannikov-vi/vp-nano-lib/models/observers/kafka
- github.com/ashleighj/kafkaclient
- github.com/ashwinyue/aura/pkg/options
- github.com/ashwinyue/monster/internal/pump
- github.com/ashwinyue/monster/internal/sms/biz
- github.com/ashwinyue/monster/internal/sms/monitor
- github.com/ashwinyue/monster/internal/sms/mqs
- github.com/ashwinyue/monster/internal/sms/writer
- github.com/ashwinyue/monster/internal/usercenter/biz
- github.com/ashwinyue/monster/pkg/options
- github.com/ashwinyue/monster/pkg/queue
- github.com/ashwinyue/monster/pkg/streams/connector/kafka
- github.com/asians-cloud/crowdsec/pkg/acquisition/modules/kafka
- github.com/aslakjohansen/kafka-receiver
- github.com/aspring/kapacitor/services/kafka
- 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/attains/go-skeleton/kafka
- github.com/attentiontech/walstream-go/streaming/kafka
- github.com/atulanand206/go-kafka
- github.com/av-ugolkov/lingua-evo/internal/infra/kafka
- github.com/ave1995/grpc-chat/connector/kafka
- github.com/avmiki80/golang-diasoft/hw12_13_14_15_16_calendar/internal/events
- github.com/avmiki80/golang-diasoft/hw12_13_14_15_16_calendar/internal/events/consumers
- github.com/avmiki80/golang-diasoft/hw12_13_14_15_16_calendar/internal/events/producers
- github.com/avmiki80/golang-diasoft/hw12_13_14_15_16_calendar/internal/mapper
- github.com/avraam311/order-service/backend/internal/pkg/kafka
- github.com/axdbertuol/goauthx/internal/services/kafka_consumer
- github.com/axmz/go-saga-microservices/lib/adapter/kafka
- github.com/axshaman/sermersystech/utils
- github.com/aykay76/kwatch
- github.com/azarakovskiy/kafka-go/topics
- github.com/azghr/mesh/kafka
- github.com/azizpambayun/ecommerce-micro/handlers
- github.com/babelqueue/babelqueue-go/kafka
- github.com/baetyl/baetyl-remote/baetyl-remote-kafka
- github.com/baibanzz/jdk/core/internal/kafka
- github.com/balabanovds/containers/kafka
- github.com/bangumi/server/canal
- github.com/bangunindo/trap2json/forwarder
- github.com/barshat7/go-advanced/gokafka
- github.com/bds421/rho-kit/infra/messaging/kafkabackend/v2
- github.com/behldevansh/data-streaming-golang-and-kafka
- 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/bervProject/go-microservice-boilerplate/services
- github.com/betacat-co/pkgx/kafkax
- github.com/betacats/go-core/queue/kafkax
- github.com/bharath-b-hpe/odimra/lib-messagebus/datacommunicator
- github.com/bhmt/tittlemanscrest/kafka
- github.com/bhochhi/kafka-guide/go-kafka-consumer/consumer
- github.com/bhorovyi/xk6-kafka
- github.com/bigzhuk/kafka-adapter
- github.com/binary-jerry/glibs/kafkax
- 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/bobstrecansky/HighPerformanceWithGo/14-clustering-and-job-queueing-in-go/jobqueues/kafka
- 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/bruin-data/ingestr/pkg/source/kafka
- github.com/brunodelucasbarbosa/learning-go/api-gochi
- github.com/brunosantosnet/template-consumer-kafka/cmd/server
- github.com/brunownk/fc-pay-gateway/internal/service
- github.com/bryce4651/pkg/kfk
- github.com/bsergik/tough-dev/services/inventory/internal/message-broker/kafka
- github.com/bssth/kafka-batcher/batcher
- github.com/buraktabakoglu/TODO_APP_NOTIFICATION/internal/kafka
- github.com/byx-darwin/go-tools/go-middleware/kafka
- github.com/c2dp/zenutil
- github.com/cago-frame/cago/pkg/broker/kafka
- github.com/candrap89/droneTravelingDistance/kafka
- github.com/carameleon/exchain/x/stream/kafkaclient
- github.com/card-engine/game_common/eventbus
- github.com/cardinalhq/kafka-sync/kafkasync
- 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/cccvno1/goplate/pkg/kafkakit
- 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/chains-lab/cities-svc/internal/events/publisher
- github.com/chakchat/chakchat-backend/live-connection-service
- github.com/chakchat/chakchat-backend/live-connection-service/internal/mq
- github.com/chakchat/chakchat-backend/live-connection-service/internal/services
- github.com/chakchat/chakchat-backend/messaging-service/cmd
- github.com/chakchat/chakchat-backend/messaging-service/internal/infrastructure/kafkamq
- github.com/chakradharkh/rancher/pkg/controllers/user/logging/utils
- github.com/chaos-mesh/chaosd/pkg/server/chaosd
- github.com/charlienet/gadget/plugins/broker/kafka
- github.com/chefcookit/vod-kafka
- github.com/chenbaoding-2818/chanlylog
- github.com/chenjie199234/config/config
- github.com/chenquan/go-queue/kafka
- github.com/chihqiang/dbxgo/output
- 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/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/chrugez/go-api/cmd/cli/kafka
- github.com/chunhui2001/zero4go/pkg/logs
- github.com/ciblele/siemens-energy/Rascunhos
- github.com/cision-prcomms/oip-influencer-commons/kafka
- github.com/clin211/linhub/options
- github.com/cloud01-wu/cgsl/kafkax
- github.com/cloudevops101/go-kafka-consumer
- github.com/clubpay/qlubkit-go/kafka
- 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/codebyaadi/upzy/libs/datastore/kafka
- 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/conex/redpanda
- github.com/conwaychriscosmo/realtime-evaluation-api
- github.com/corneredrat/image-server/api-server/notifier
- github.com/costa92/k8s-ai/pkg/options
- github.com/costa92/micros-service/pkg/options
- github.com/country7/go-lessons-mastering-go/ch14-Machine-learning
- github.com/crazyfrankie/cloudstorage/app/gateway/api
- github.com/cristiano-pacheco/pingo/pkg/kafka
- github.com/croatiangrn/xm_v22/internal/infrastructure/kafka
- 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/cuihairu/croupier/internal/analytics/mq
- github.com/cursed-ninja/go-kafka-producer
- github.com/cybertec-postgresql/debezium2postgres/internal/kafka
- github.com/cylowatt/go-playground-kafka
- github.com/d1rtyloudx/spotiby-pkg/kafka
- github.com/daemtri/begonia/driver/kafka
- github.com/dairongpeng/leona/internal/gstash/gstashs
- github.com/daison12006013/turboscript/internal/server
- 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/darkden-lab/argus/backend/internal/notifications
- github.com/darkinno/jtt-808-go-sdk/publisher/kafka
- github.com/darron/aiven/cmd
- github.com/darth-raijin/challenger/internal/messagers
- 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/dcvii/tiingo/internal/kafka
- github.com/ddvkid/learngo/internal/kafkaBuilder
- github.com/deepshore/xk6-kafka
- github.com/deflect-ca/banjax/internal
- github.com/deimossy/wb-order-service/internal/kafka/consumer
- 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/devashish0812/Ticket_Booking_App/common/kafka
- github.com/developeerz/restorio-reserving/reserving-service/internal/kafka
- github.com/devplayg/kafka/create-topic
- github.com/devyk100/gengou-db/internal/kafka_internal
- github.com/dewidyabagus/monorepo/datasource/messaging
- github.com/dgdts/ts-gobase/kafka
- github.com/dhruv7539/deployiq/internal/streaming
- github.com/diazoxide/easy-kafka
- github.com/diego3/kafka-microservices/lib
- github.com/digitalmonsters/litit-mono/internal/notifications/pkg/kafka
- github.com/diki-haryadi/go-micro-template/internal/article/delivery/kafka/producer
- github.com/diki-haryadi/go-micro-template/internal/article/domain
- github.com/diki-haryadi/go-micro-template/internal/article/usecase
- github.com/diki-haryadi/go-micro-template/internal/health_check/usecase/kafka_health_check
- 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/dimonoff/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/dimpogissou/isengard-server/connectors
- github.com/dimuthuh28/go-api-gateway/internal/kafka
- github.com/dinosoupy/pod
- github.com/diogoasouza/rancher/pkg/controllers/user/logging/utils
- github.com/dip-software/gautocloud-connectors/hsdp
- 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/dmehra2102/learning-platform/shared/pkg/kafka
- github.com/dmitriitimoshenko/hi-a/google-sheets-accessor/internal/app/kafka
- github.com/dmitryshcherbakov/grpc
- github.com/dongfenghulian/log-track/internal/writer
- github.com/dongzhouzhoudz/gotools/pkg
- github.com/dotunj/pvent/producer
- github.com/doubunv/common-pkg/amqp/kafka/v1
- 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/dsperax/management-api-go/internal/infra/kafka
- github.com/dtkmn/go-playground
- github.com/ducnpdev/godev-kit/pkg/kafka
- github.com/dukex/operion/pkg/eventbus/kafka
- 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/e-harsley/osariem/clients
- 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/edamasop/messaging
- github.com/eden-framework/plugin-kafka/kafka
- github.com/edgeprot/xflows/pkg/outputs
- github.com/edynt/go-ecommerce-api/cmd/cli/kafka
- github.com/egustafson/sandbox/go/kafka-segmentio-01
- github.com/ekifel/shop_proto/auth/internal/kafka
- github.com/el10savio/ecommrt/src/kafka
- github.com/elbombardi/go_kafka_producer_demo
- github.com/eltats/message-service/pkg/kafka
- github.com/emcecs/influx/query/functions
- github.com/emortalmc/kurushimi/internal/kafka
- github.com/emortalmc/mono-services/services/game-player-data/internal/kafka
- github.com/emortalmc/mono-services/services/game-player-data/tests/publish_update_game_player_data
- github.com/emortalmc/mono-services/services/game-tracker/internal/kafka
- github.com/emortalmc/mono-services/services/game-tracker/test/game_process
- github.com/emortalmc/mono-services/services/matchmaker/internal/kafka
- github.com/emortalmc/mono-services/services/mc-player-service/internal/kafka/consumer
- github.com/emortalmc/mono-services/services/mc-player-service/internal/kafka/writer
- github.com/emortalmc/mono-services/services/mc-player-service/tests/publish_connection_message
- github.com/emortalmc/mono-services/services/message-handler/cmd/test/consume
- github.com/emortalmc/mono-services/services/message-handler/cmd/test/publishchat
- github.com/emortalmc/mono-services/services/message-handler/internal/kafka
- github.com/emortalmc/mono-services/services/party-manager/internal/kafka/consumer
- github.com/emortalmc/mono-services/services/party-manager/internal/kafka/writer
- github.com/emortalmc/mono-services/services/permission-service/internal/kafka/notifier
- github.com/emortalmc/mono-services/services/relationship-manager/internal/kafka
- github.com/emortalmc/proto-specs/gen/go/nongenerated/kafkautils
- github.com/encounter27/eh-outbox/projector
- github.com/endge-lab/service-kit-go/pkg/redpanda
- github.com/enrichman/rancher/pkg/controllers/user/logging/utils
- github.com/equalitie/banjax-next/internal
- github.com/ercross/payment_gateways/internal/kafka
- github.com/erda-project/erda-infra/providers/kafkav2
- github.com/ericyeungcode/caliber/kafkax
- 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/fabioluciano/tekton-events-relay/internal/notifier/kafka
- github.com/faizan2786/event-driven-cdc-pipeline/cdc-pipeline/cmd/cdcconsumer
- github.com/faizan2786/event-driven-cdc-pipeline/cdc-pipeline/cmd/consumer
- github.com/faizan2786/event-driven-cdc-pipeline/cdc-pipeline/cmd/producer
- github.com/faizan2786/event-driven-cdc-pipeline/cdc-pipeline/internal/kafkautils
- github.com/faizan2786/event-driven-cdc-pipeline/cmd/cdcconsumer
- github.com/faizan2786/event-driven-cdc-pipeline/cmd/consumer
- github.com/faizan2786/event-driven-cdc-pipeline/cmd/producer
- github.com/faizan2786/event-driven-cdc-pipeline/internal/kafkautils
- 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/fidesy/sdk/common/kafka
- github.com/fingertge/public/service/kafka
- github.com/fizzse/gobase/pkg/mq/kafka
- github.com/fjod/go_cart/cart-service/internal/poller
- github.com/flash520/pusher/pkg/connector
- github.com/flashus/msa_big_tech/pkg/kafka
- github.com/flexer2006/orders-api/internal/adapters/kafka
- github.com/flores666/profileshare-lib/eventBus
- 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/frkr-io/frkr-common/gateway
- github.com/gabriel-ross/gofhir
- github.com/gagangoku/kafka-tasker
- github.com/garden-raccoon/notify-pkg
- github.com/gaulzhw/skywalking-go-agent/plugins/segmentio-kafka
- github.com/gauravlad21/book-management-system/external_resources/kafka
- github.com/gbevan/lucygw/handlers
- github.com/gbh007/buttoners/core/kafka
- 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/ggsrc/blueprint-go-toolkits/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/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-suger/hive/internal/kafka
- github.com/goairix/mq/adapters/kafka
- github.com/goal-web/queue/drivers
- github.com/goforj/events/driver/kafkaevents
- github.com/gogo-lib/superlog
- github.com/goinline/agent/mq/kafka/kafka-go
- github.com/gokit/actorkit/pubsubs/kafka/segments
- github.com/golkity/Calc_2.0/service/calc-orchenstrator/internal/kafka
- github.com/gomodul/db/driver/kafka
- github.com/gonotelm-lab/gonotelm/internal/infra/mq/impl/kafka
- github.com/goovo/matching-engine/pkg/mq
- github.com/goshgame/trace
- 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/goxkit/kafka
- github.com/gozelus/gokafka
- github.com/gozero-hub/common/kafka
- github.com/gqls/agentchassis/platform/kafka
- github.com/gscaffold/helpers/kafka
- github.com/guacsec/guac/pkg/handler/collector/s3/messaging
- github.com/guicostaarantes/go-auth/utils/stream
- github.com/gundz204/pglib/infra/kafka
- github.com/gunsluo/go-example/kafka
- github.com/gurodrigues-dev/notifier-app/internal/infra/queue
- 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/h4x4d/go_hsse_hotels/pkg/notification
- github.com/hahaclassic/orpheon/backend/internal/adapters/event-bus/kafka
- github.com/hahahannes/e2e-go-utils/lib/streaming/kafka
- github.com/halilylm/logruskafka
- github.com/hamedkazemi/tinytik/common
- github.com/hamidOyeyiola/kafka-mail-service/service
- 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/handysuherman/clean-arch-payment-service/internal/config
- github.com/handysuherman/clean-arch-payment-service/internal/infra
- github.com/handysuherman/clean-arch-payment-service/internal/payment/delivery/kafka
- github.com/handysuherman/clean-arch-payment-service/internal/payment/worker
- github.com/handysuherman/clean-arch-payment-service/internal/pkg/kafka
- github.com/handysuherman/clean-arch-payment-service/internal/pkg/kafka/mock
- github.com/handysuherman/clean-arch-payment-service/internal/pkg/tracing
- github.com/handysuherman/clean-arch-payment-service/internal/pkg/unierror/tracing
- github.com/hari134/pratilipi/pkg/kafka
- github.com/harishhary/blink/internal/brokers
- github.com/harmol/k8s/pkg/kafka
- github.com/harrisonwaffel/rancher/pkg/controllers/user/logging/utils
- github.com/harunrasyid/sutinah
- github.com/hashir-Zahoor-kh/Havoc/internal/kafka
- github.com/hassiimykyta/life-rpg/pkg/kafka
- 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/hengmyj/dts-kafka-odps
- 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/highdolen/L0/internal/kafka
- github.com/highlight-run/highlight/backend/kafka-queue
- github.com/hl-ticketon/common/connections
- 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/hookdeck/outpost/internal/destregistry/providers/destkafka
- 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/iangregsondev/deblockprocessor/internal/adapters/kafka
- github.com/ice-coldbell/analyze-server/pkg/queue/kafka
- github.com/icemanaf/sensorhttpapi
- github.com/ichbingautam/real-time-log-ingestion-and-anomaly-detection-system/internal/messaging
- 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/iljapavlovs/go-examples/kafka
- github.com/illia-malachyn/food-delivery/shared/kafka
- 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/imadeddine-belkat/tactify-kafka
- github.com/imajinyun/gofly/core/mq/kafka
- github.com/imjiu/go_example/src/gopcp.v2
- github.com/indalyadav56/logify/apps/backend/internal/di
- github.com/indalyadav56/logify/apps/backend/internal/embedder/infrastructure/kafka
- github.com/indalyadav56/logify/apps/backend/internal/ingest/infrastructure/kafka
- github.com/indalyadav56/logify/apps/backend/internal/processor/infrastructure/kafka
- github.com/indalyadav56/logify/apps/backend/pkg/messaging
- github.com/indreshp/mycode
- github.com/influxdata/flux/stdlib/kafka
- 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/inhuman/zap-kafka
- github.com/innoglobe/xmgo/internal/service
- github.com/innolight/goevents/queues/kafka
- github.com/insaanimanav/atlan-lily/atlan-outbound
- github.com/integration-system/isp-event-lib/kafka
- 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/iurikman/cashFlowManager/internal/broker
- github.com/izharishaksa/http-worker
- github.com/jaam8/web_calculator/common-lib/kafka
- 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/janapc/event-tickets/clients/internal/infra/messaging/kafka
- github.com/janmg/blob-to-queue/output
- github.com/jarjar2go/kafka-go-poc
- github.com/jasonlabz/potato/kafkax
- github.com/jatin711-debug/cronos_db_golang/internal/cdc
- github.com/jcabreraSerrao/betting-common/pkg/kafka
- github.com/jdtobe/kafka-chat
- github.com/jdy879526487/tools/queue
- github.com/jeffersonbrasilino/gomes/channel/kafka
- 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/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/joramuns/shop/internal/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/joshqu1985/lego/broker
- 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/justcgh9/discord-clone-kafka
- github.com/justinmoonca/go-queue/kq
- github.com/k13w/go-kafka/infrastructure/kafka/producer
- github.com/k8ika0s/s390x-wheel-refinery/go-control-plane/internal/queue
- github.com/k8shop/go-rest-api/pkg/informer
- github.com/kaasikodes/shop-ease/shared/broker
- github.com/kade-chen/library/ioc/config/kafka
- github.com/kalandramo/lulu-ext/broker/kafka
- 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/karosown/katool-go/mq/kfmq
- github.com/kartikey1188/build-in-progress_01/internal/kafka
- github.com/kaydxh/golang/pkg/mq/kafka
- github.com/kbfu/xk6-kafka
- github.com/kedacore/keda/v2/pkg/scalers
- github.com/kedr891/cs-parser/internal/consumer/price_update_consumer
- 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/kevinu2/ngo/v2/pkgs/Mq/Kafka
- github.com/kevinyjn/gocom/mq/kafka
- github.com/kgugunava/flash_sale_engine/pkg/kafka
- github.com/khadzakos/riskops/pkg/kafka
- github.com/khaicode-xyz/core-shared/kafka
- github.com/khainv198/golang-message-broker/kafka
- github.com/khulnasoft-lab/PacketStreamer/pkg/plugins/kafka
- github.com/khulnasoft/fanal/outputs
- 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/kittichai/core-framework/shared/framework/infrastructure/messaging/kafka
- github.com/kjhch/go-common/pkg/space
- github.com/kkiling/messages/producer/kafka_producer
- github.com/kl7sn/toolkit/kkafka
- github.com/klef99/wb-school-l0/internal/app/adapters/kafka
- github.com/klemen-forstneric/ember/kafka
- 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/kochabx/kit/store/kafka
- github.com/kodsurfer/try-kafka
- github.com/kolllaka/people/internal/kafka
- github.com/konart/kafka-adapter
- github.com/konih/kollect/internal/sink/kafka
- github.com/konstellation-io/kai-processes/kafka-trigger
- github.com/konvoulgaris/kafka-stream-mock
- github.com/kordyd/remember_me-golang/services/event_ingestion/internal/sender
- 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/kruzhok-team/ntikafka
- 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/kust1q/Zapp/backend/pkg/kafka
- github.com/kuzane/alertmesh/internal/ingestion
- 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/larek-tech/storage/kafka
- github.com/lavanet/lava/v5/protocol/metrics
- github.com/lazygophers/lrpc/middleware/storage/queue
- github.com/lcnascimento/go-kit/kafka
- 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/leobip/metrics-libs/libs
- github.com/leojasmim/kafka-producer-go/infrastructure/broker/kafka
- github.com/leonardotomascostadasilva/X9/internal/config
- github.com/leonid-tankov/OTUS_go_final_project/internal/kafka
- github.com/lerenn/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/lgdzz/vingo-utils-v3/kafka
- github.com/lhdhtrc/kafka-go/pkg
- github.com/li1553770945/sheepim-push-worker-service/biz/infra/kafka
- github.com/lianglong/mq-kafka
- 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/liemle3893/go-tryve/internal/adapter
- github.com/lifenglin/micro-library/connect
- github.com/lightstep/opentelemetry-examples/collector/kafka/src/producer
- github.com/limerence-code/goproject/middleware/cdc
- 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/literaen/simple_project/pkg/kafka
- github.com/liukunxin/go-infra/pkg/infra/kafka
- 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/longgggwwww/hrm-ms-hr/internal/kafka
- 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/lopolopen/gap/broker/xkafka/internal
- github.com/lostmyescape/link-shortener/common/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/luckysxx/common/mq/kafkabus
- github.com/ludashi2020/go-plugins/broker/segmentio
- github.com/luebken/todos/cmd/todos
- github.com/luizotavio32/microsservice-go
- github.com/lukeoleson/kafka-quickstart
- github.com/lukwil/project-tools/Kafka-Rest-Bridge
- github.com/luojun96/go-opt/middleware/message/kafka
- github.com/lvdashuaibi/littlevote/internal/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/lynx-go/lynx/contrib/kafka
- 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/magicnana999/im/infra
- github.com/maivankien/go-ecommerce-api/cmd/cli/kafka
- github.com/malwrar/tmp1
- github.com/mammenj/go-health/queues
- github.com/mani-s-tiwari/gopipe/pkg/broker
- 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/marifsulaksono/golang-event-broker/kafka
- github.com/marijnkoesen/mirrormaker-offset-checker
- 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/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/mattfiocca/comqtt/plugin/bridge/kafka
- github.com/matusvla/go-kafka
- github.com/matutetandil/mycel/internal/connector/mq/kafka
- github.com/mauriciomartinezc/real-estate-mc-common/messaging
- 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/mcpany/core/server/pkg/bus/kafka
- github.com/md-shadhin-mia/gomed-shared/messaging/kafka
- github.com/medeiros-dev/notification-service/go-producer/internal/infrastructure/broker
- github.com/megaease/easeprobe/probe/client/kafka
- github.com/mehmetolgundev/golibtest/utils
- github.com/mei-rune/delayed_job
- github.com/meidada2464/gostudy/KafkaTest
- github.com/meinanzilinzhengying/cloudflow/services/shared/kafka
- github.com/merkio/worker-operator/internal/kafka
- github.com/mertenvg/pubsub/providers/kafka
- github.com/meshplus/gosdk/rpc
- github.com/metacode-dream-team/MetaCode/pkg/messaging
- github.com/metalbear-co/playground/apps/ip-visit/ip-visit-counter
- github.com/mft-labs/amf_kafka
- github.com/mganta/epat-outputter/kafka
- github.com/mheers/kafka-gh-actions-trigger
- github.com/mhope-2/log-analytics/log-reader/messaging/kafka
- github.com/mhthrh/BlueBank/KafkaBroker
- github.com/mibrahim2344/identity-service/internal/infrastructure/events/kafka
- github.com/micro-easy/go-queue/kq
- github.com/miebyte/goutils/logging/writer
- github.com/mike-sirs/go-kfk-transfer/cmd
- github.com/mikeasnyder/demomcm/pkg/controllers/user/logging/utils
- github.com/mikhailbolshakov/kit/kafka
- github.com/mikhailshtv/notification-service/internal/consumer
- github.com/miladystack/miladystack/pkg/options
- github.com/milan604/core-lab/pkg/audit
- 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/courses/concurrency/7_kafka_consumer/dev/produce
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/1_panic_send/problem
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/1_panic_send/solution
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/2_eternal_block/problem
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/2_eternal_block/solution
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/3_double_stop/problem
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/3_double_stop/solution
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/4_critical_error_block/problem
- github.com/minitauros/go-concurrency-training/courses/concurrency/9_challenges/4_critical_error_block/solution
- github.com/mirjalilova/MemoryService/kafka
- github.com/mirjalilova/api-gateway/pkg/kafka/producer
- github.com/mirjalilova/api_gateway/kafka
- github.com/mirjalilova/med-track/pkg/kafka/consumer
- 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/mjmichael73/library-microservice/userservice/internal/server
- github.com/mjura/rancher/pkg/controllers/user/logging/utils
- github.com/mkhalegaonkar3/product-service-go/shipping
- github.com/mmkader85/learn-kafka-golang/kafka
- 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/morezwer/ecommerce-platform/shared/pkg/messaging
- 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/mousavisam/streaming-event-processor/internal/kafka
- github.com/movie-recommendation-v1/geteway/pkg/kafka
- github.com/moweilong/milady/pkg/options
- 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/murphy-hc/h-im/pkg/kafka
- github.com/mushroomyuan/dev-clould-mini/maudit/apps/event
- github.com/musobarlab/kafka-cli
- github.com/mutezebra/tiktok/pkg/kafka
- github.com/mvbrock/clusterizer/cmd
- github.com/mwantia/asynk/internal/kafka
- github.com/mwsbkru/broker-bridge/internal/kafka
- github.com/mxngoc2104/KTPM-CS2/api
- github.com/myosotix/rancher/pkg/controllers/user/logging/utils
- github.com/mysunshines/gocommon/kafka
- github.com/nachogiljaldo/otel-messaging/pkg/propagation/segmentio/kafkago
- github.com/nais/dataproduct-topics/pkg/collector
- github.com/najmialifah/Dealan/auth-service/pkg/kafka
- github.com/namanag97/call_in_go/call-processor/internal/event
- github.com/nambrosini/kcp/kafka
- github.com/nasparria/GetData
- github.com/nataliefyi/rancher/pkg/controllers/user/logging/utils
- github.com/natuleadan/sdk-api/events
- github.com/navikt/go-leesah
- github.com/nduni/correlation/common/messaging
- github.com/nduyhai/xcore/pubsub/segmentio
- github.com/nebucloud/pkg/logger
- github.com/nei7/ntube/app/user/internal/service
- github.com/neiln3121/user-service/kafka
- github.com/nepeta70/ride-hailing/internal/pkg/adapters/pubsub
- github.com/nephilimboy/rcd-fullmonitoring-agent/topology/probes/flow
- github.com/netbill/evtypes/headers
- github.com/netcracker/qubership-core-lib-go-maas-bg-segmentio/v3
- github.com/netcracker/qubership-core-lib-go-maas-segmentio/v3
- github.com/nghiatk54/go-ecommerce-backend-api/cmd/cli/kafka
- github.com/ngochuyk812/building_block/infrastructure/eventbus/kafka
- 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/nicholaskh/opendts
- 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/nimburion/nimburion/pkg/eventbus/kafka
- 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/nomiram/kafka-submodule
- github.com/noom1009/appcore/messagequeue
- github.com/notickets/datamining
- 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/nuhmanudheent/hosp-connect-appointment-service/internal/di
- github.com/nuhmanudheent/hosp-connect-payment-service/internal/utils
- 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/oatsmoke/warehouse_backend/internal/lib/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/oeservices/open-kafka-connector/global
- 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/ogulcanaydogan/vaol/pkg/ingest
- github.com/ol1mov-dev/shared/kafka
- 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/onemgvv/notificationserver/internal/transport/kafka
- github.com/onno-vos-dev/await
- github.com/open-micro/plugins/v5/broker/segmentio
- github.com/open4go/p7/kf
- github.com/openbkn-ai/bkn-comm-go/mq
- github.com/opencloud-eu/reva/v2/pkg/storage/fs/posix/tree
- github.com/opencode-sig/runtime-sdk/infra/kafka
- 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/osamikoyo/book-market/app/servieses/auth/src/talking
- github.com/osiaeg/buffered_request/internal/services
- github.com/oslet/erda-infra/providers/kafkav2
- github.com/overtonx/outbox
- github.com/owen97779/Pachamama-MQTT-Kafka-Producer/pkg/kafka
- github.com/owncloud/reva/v2/pkg/storage/fs/posix/tree
- github.com/p2p-org/mbelt-cosmos-streamer/datastore
- github.com/paaavkata/go-logger
- github.com/pachirode/pkg/options
- github.com/pachyderm/pachyderm/etc/testing/kafka
- github.com/packtpublishing/mastering-go-second-edition/ch14
- github.com/paigeman/r1-BDVA/cmd/server
- github.com/paixram/fastfa
- github.com/paraglade/drone-smoke-tests/pkg/controllers/user/logging/utils
- github.com/paranoiachains/loyalty-api/pkg/messaging
- 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/pdrhp/ms-voto-receiver-go/internal/infrastructure/kafka
- github.com/pennyscissors/rancher/pkg/controllers/user/logging/utils
- github.com/perbu/bufferedKafka/kafkabuffer
- github.com/pereiragm/go-examples/notifier_test
- github.com/performance92/rancher/pkg/controllers/user/logging/utils
- github.com/pershin-daniil/kafka-notify/cmd
- github.com/pershin-daniil/ninja-chat-bank/internal/logger
- github.com/pershin-daniil/ninja-chat-bank/internal/services/afc-verdicts-processor
- github.com/pershin-daniil/ninja-chat-bank/internal/services/afc-verdicts-processor/mocks
- github.com/pershin-daniil/ninja-chat-bank/internal/services/msg-producer
- github.com/peter-stratton/gofr/pkg/gofr/datasource/pubsub/kafka
- github.com/petretiandrea/outbox-go/internal/infrastructure/kafka
- github.com/petrostrak/xm-companies/internal/adapters/kafka/consumer
- github.com/phamdinhha/go-event-sourcing/pkg/kafka
- github.com/phamtrung99/todo-app-microservice/pkg
- 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/pingxin403/cuckoo/apps/im-gateway-service/service
- 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/pmh-only/the-biggie
- github.com/poin4003/eCommerce_golang_api/cmd/cli/kafka
- github.com/poin4003/eCommerce_golang_api/cmd/cli/kafka/consumer
- github.com/poin4003/eCommerce_golang_api/cmd/cli/kafka/producer
- github.com/poin4003/eCommerce_golang_api/cmd/cli/websocket
- github.com/poin4003/eCommerce_golang_api/global
- github.com/poin4003/eCommerce_golang_api/internal/initalize
- github.com/polsumeet3666/code-snippet-go/kafka
- github.com/poly-workshop/go-webmods/kafkaclient
- 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/pozedorum/wbf/kafka
- github.com/pppestto/crypto-fetcher/internal/adapters/kafka
- github.com/pqt2p1/go-ecommerce-backend-api/cmd/cli/kafka
- github.com/prb112/fhir-kafka-go
- github.com/pristupaanastasia/test1/serv
- github.com/project-pncp/private-kit/kafka
- github.com/pure-golang/adapters/queue/kafka
- 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/quackdiscord/events-api/services
- github.com/quanghung97/kafka-go
- github.com/quangtran88/anifni-base/libs/services
- github.com/quiby-ai/common/pkg/events
- github.com/quincy0/temproal-workflows/mq
- github.com/quiqupltd/quiqupgo/kafka
- github.com/qvcloud/broker/brokers/kafka
- 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/rafaelmaestro/gopportunities/src/providers/akafka
- github.com/rafaelsanzio/go-flashscore/pkg/kafka
- github.com/rafaribe/otelkafkago
- github.com/raft-tech/df-kafka-go
- github.com/rakrisi/flowtest/internal/driver
- github.com/ralvescosta/gokit/kafka
- github.com/rammtw/order-management-system/apps/order/internal/kafka
- github.com/ramusaaa/goscraper/pkg/queue
- 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/redhatinsights/platform-go-shared/queue
- github.com/redsuperbat/kafka-commander/src/producing
- github.com/reecerussell/open-social/eventing/kafka
- github.com/renatoaguimaraes/ecommerce-pim/internal/driver
- github.com/rendau/hps/internal/app/middleware/log_kafka/producer
- github.com/rendieroot/kafka-couch
- github.com/rendyfutsuy/base-go/utils/services/queue
- 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/rezmoss/go-at-scale/chapter12
- 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/rk-the-dev/golib-core/pkg/kafka
- github.com/rkochar/wsdm/src/shared
- github.com/rl404/fairy/pubsub/kafka
- github.com/rluders/gofsm/messaging/kafka
- github.com/roackb2/lucid/internal/pkg/pubsub
- github.com/robertobadjio/tgtime-aggregator/internal/kafka
- github.com/robertobadjio/tgtime-notifier/internal/service/kafka
- github.com/rodolfodiazr/booking-system/app/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/romanv1/go-sms-email/internal/kafka
- github.com/romariotrain/media-platform/cmd/ingest
- github.com/romariotrain/media-platform/cmd/orchestrator
- github.com/romariotrain/media-platform/cmd/processing
- github.com/romariotrain/media-platform/cmd/publish
- github.com/romariotrain/media-platform/cmd/quota
- github.com/romariotrain/media-platform/internal/ingest/kafka
- github.com/romariotrain/media-platform/internal/ingest/outbox
- github.com/romariotrain/media-platform/internal/media/kafka
- github.com/romariotrain/media-platform/internal/orchestrator/kafka
- github.com/romariotrain/media-platform/internal/orchestrator/outbox
- github.com/romariotrain/media-platform/internal/processing/kafka
- github.com/romariotrain/media-platform/internal/processing/outbox
- github.com/romariotrain/media-platform/internal/publish/kafka
- github.com/romariotrain/media-platform/internal/publish/outbox
- github.com/romariotrain/media-platform/internal/quota/kafka
- 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/rsi2m/xk6-kafka-fixed
- github.com/rsiegfanz/home-control/backend/seeder/pkg/seeds/kafkaSeeds
- github.com/rumis/storage/skafka
- github.com/runner-mei/delayed_job
- github.com/rusinov-artem/testutils/kafka
- github.com/rustomax/observe-kafka-go
- github.com/rwoj/go-kafka-go/seg
- github.com/rzaripov1990/multiwriter/ext/kafka
- github.com/rzpsarthak13/shock-absorber/internal/writeback
- 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/sajoniks/GoShort/internal/mq
- github.com/salahfarzin/utils/kafka
- 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/sautmanurung2/nanopony
- github.com/sawoklybimecpubliki/FLS-events/events
- github.com/schoolaid/schoolaid-go-notifications
- 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/seaweedfs/seaweedfs/test/kafka/internal/testutil
- 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/sejin-P/kafkapractice/consumer
- 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/serchemach/wb-tech-level-0/infra/kafka
- github.com/sergiolucena1/kafka_golang
- github.com/serjbibox/api-gateway/pkg/storage/_kafka
- github.com/setcreed/onexstack/pkg/options
- github.com/severuykhin/kafkaproxy
- github.com/seyedmo30/kafka-wrapper
- github.com/seymac/xk6-kafka
- github.com/shahar3/trip-planning-service/pkg/kafka
- github.com/shaiksadikjanu-cmd/orchkit/nodes
- github.com/shanewxy/rancher/pkg/controllers/user/logging/utils
- github.com/shanexu/sillytools/cmd/kafka_consumer
- github.com/shani34/book-management-system/pkg/kafka
- github.com/shanluzhineng/fwpkg/queuex/kafkaqueue
- 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/shirr9/order-api/internal/kafka
- github.com/shivendrasingh07/pubsub
- github.com/shokHorizon/go_tester/internals/repos
- github.com/shortcut/cloud-native-templates/server/golang-kafka
- github.com/shrey209/Like-Counter/queue-service
- github.com/shrimpsizemoose/trekker/infra
- github.com/shrishyam02/banking-ledger/common/kafka
- github.com/shriyanshagnihotri/collectorservice
- github.com/sigmaott/gest/package/extension/kafkafx
- github.com/silen/nuwa/pkg/kafka
- github.com/silentd0g/ffsf/bus
- github.com/sing3demons/go-common-kp/kp/pkg/kafka
- 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/skolldire/go-engine/messaging/pkg/integration/kafka
- github.com/skolzkyi/hwOTUS_YIA/hw12_13_14_15_calendar/kafka
- github.com/skrolikov/vira-kafka
- github.com/skylee424/blue-bell/dao/kafka
- github.com/skyrocket-qy/gox/service
- github.com/skyterra/elastic-embedding-searcher/messages
- github.com/sld880311/influxdata/kapacitor/services/kafka
- github.com/slimloans/kafka
- github.com/slinkydeveloper/kafka-go-clients-benchmarks/kafka-go
- github.com/sllt/kite/pkg/kite/datasource/pubsub/kafka
- github.com/sm0kernone/crm-common/pkg/kafka
- github.com/smallfish-root/eventhorizon/eventbus/kafka
- github.com/smallnest/exp/kafkamock
- github.com/smallnest/gofer/mq/mka
- github.com/smartwalle/mx/kafkax
- github.com/smarty/messaging-kafka
- github.com/smirankat/messaggio-test
- github.com/sns45/anyq/go/kafka
- 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/sonni-a/wb-service/internal/kafka
- github.com/sonntuet1997/medical-chain-utils/messaging
- github.com/sosadtsia/bike-parts-finder/pkg/kafka
- github.com/souz9/kafka-topic
- github.com/spark-lence/tiga
- github.com/spirit-labs/tektite/kafka
- github.com/spiritedvari/trap2json/forwarder
- github.com/spy16/fusion/reactor/stream
- github.com/srxstack/srxstack/pkg/options
- 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/stepan-pokladov/csw/worker/internal/consumer
- 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/sumitDon47/payment-system/payment-service/outbox
- github.com/sumup-go/lessons/advanced/13
- github.com/sunshineOfficial/golib/gokafka
- 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/susesgartner/rancher/pkg/controllers/user/logging/utils
- github.com/sushkomihail/metric-aggregation-service/internal/broker/kafka
- github.com/suyash-hc/my-kafka-uploader/internal/kafka
- github.com/svansig/g_mash_testbed
- github.com/sviviani/go-micro-framework/messaging
- 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/sxd0/go_url-shortener/pkg/kafka
- github.com/sxerox007/gamezop/kafka
- github.com/syedazeez337/golang-to-do/services
- github.com/syklinux/golib/kafka
- github.com/synthao/notifier
- github.com/taekwondodev/push-notification-service/internal/service
- github.com/tainj/distributed_calculator2/pkg/messaging/kafka
- github.com/takmatsu/rancher/pkg/controllers/user/logging/utils
- github.com/tam-code/image-upload/src/kafka
- github.com/tandy9527/js-util/kafka
- github.com/tanqiuqiang/go-queue/kq
- github.com/tarekbadrshalaan/GoKafka/kafka-go
- github.com/tarent/kafkaadmin
- github.com/tarmalonchik/kafkawrapper
- 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/teamcubation/test_TC/pkg/brokers/kafka
- github.com/tecnickcom/gogen/pkg/kafka
- github.com/teenkwn/basic-kafka-consumer/kafka
- github.com/teja-246/Token-Optimization-for-LLMs/go/analytics
- github.com/telepenin/website-checker/checker/listener
- github.com/telkomdev/tob/services/kafka
- github.com/temesgen-abebayehu/bidflow/backend/common/kafka
- github.com/teng231/kafclient/v2
- github.com/tetafro/kafka-dump
- github.com/thankala/diploma-thesis/common/network
- github.com/thedadams/rancher/pkg/controllers/user/logging/utils
- github.com/thingio/kapacitor/services/kafka
- github.com/things-kit/things-kit-kafka
- github.com/thinxz/go_lang/config
- github.com/thirteenths/message-processing-microservice/internal/storage/kafka
- github.com/thisisthemurph/beerbux/auth-service
- github.com/thisisthemurph/beerbux/auth-service/internal/producer
- github.com/thisisthemurph/beerbux/session-service/internal/handler
- github.com/thisisthemurph/beerbux/session-service/internal/kafka
- github.com/thisisthemurph/beerbux/session-service/internal/publisher
- github.com/thisisthemurph/beerbux/shared/kafkatopic
- github.com/thisisthemurph/beerbux/transaction-service
- github.com/thisisthemurph/beerbux/transaction-service/internal/publisher
- github.com/thisisthemurph/beerbux/user-service/internal/handler
- github.com/thisisthemurph/beerbux/user-service/internal/kafka
- github.com/thisisthemurph/beerbux/user-service/internal/publisher
- github.com/thk-im/thk-im-base-server/mq
- github.com/tiamxu/kit/kafka
- github.com/tianet/ditto/pkg/adapters/producer
- github.com/tidepool-org/kafka-data-import/api
- github.com/tillkuhn/letitgo/stream
- github.com/timmyjinks/distributed-system/queue
- github.com/tkaewplik/go-microservices/pkg/messaging
- github.com/tmtriet200800/test-go-utils/eventbus
- github.com/todaynowy/go_work/20211024_graduateProject/iam_study/internal/pump/pumps
- github.com/tomsanbear/dnslogging
- github.com/tonica-go/tonica/pkg/tonica/storage/pubsub/kafka
- 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/toolsascode/bfm/api/internal/queue/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/topcms/kratos-infra/kafka
- github.com/toventang/debezium-client/internal/consumer
- github.com/trakkie-id/kafka-zipkin-interceptor
- github.com/trantrongquy/mastering-go-second-edition/ch14
- github.com/travigo/travigo/pkg/realtime/nationalrail/linxconsist
- github.com/trb1maker/gobannercircle/internal/notify/kafka
- github.com/trendyol/stove/go/stove-kafka/segmentio
- github.com/tripconnect/go-common-utils/common
- github.com/trstoyan/Alertify/kafka
- github.com/truexf/kafkac
- github.com/tryy3/cozytemp-service-helper/kafka
- github.com/tsmweb/go-helper-api/kafka
- github.com/ttxj0mh9/portwatch/internal/alert
- github.com/turngeek/myaktion-go-2023/src/banktransfer/kafka
- github.com/tuyy/kafkaWriter-go/pkg/kafka
- github.com/txbao/common-go/component/mq/kafka
- github.com/txn2/kwatch
- github.com/tyler-pritchard/blockhouse/kafka
- github.com/tymbaca/spin/internal/kafka
- github.com/uditkarth/liveaiproject/matching
- github.com/udugong/gobox/kafka-gox
- github.com/udugong/kafka-gox/handler
- github.com/uncorde/uncorde/internal/integration/kafka
- github.com/underthetreee/fsync/internal/kafka
- github.com/unistack-org/micro-broker-segmentio
- github.com/unmei211/notifyme/internal/pkg/kafka
- github.com/vadgun/gotrelloclone/task-service/kafka
- github.com/vaibhavahuja/short-video-analytics-aggregator/internal/external/queue/kafka
- github.com/vani-rf/jojonomic-test/buyback-service/cmd
- github.com/vedrankolka/donation-server/pkg/notifier/kafka
- github.com/vela-ssoc/vela-kfk
- github.com/venon2fork/bundlecoursevidyouprojet/ch14
- github.com/venture-technology/venture/internal/entity
- github.com/venture-technology/vtx-account-manager/internal/repository
- github.com/veotani/kafka-log-processor/pkg/kafka
- github.com/vercly/eventhorizon/eventbus/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/verygoodsoftwarenotvirus/platform/v5/messagequeue/kafka
- github.com/viacheslavcolt/ts-go-lib/kafka
- github.com/viant/endly/service/testing/msg
- github.com/victordenisov/kafka_tests
- github.com/victorzhou123/vicblog/common/infrastructure/kafkaimpl
- 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/vishalss1/argus/cmd/benchmark
- 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/vitelabs/vite-portal/shared/pkg/kafka
- github.com/vizvasrj/l
- github.com/vkuksa/twatter/internal/storage/bpkafka
- github.com/vkuznet/kafka-app
- github.com/vladopadikk/order-delivery-app/kafka
- github.com/vlasashk/websocket-chat/pkg/kakafka
- github.com/vlla-test-organization/qubership-core-lib-go-maas-segmentio/v3
- github.com/voltento/trkaf/internal/kf
- github.com/vontikov/kafka-test-tool/cmd
- github.com/vsjadeja/metric/segkafka
- github.com/vumanhcuongit/scan/pkg/kafka
- github.com/vuvanthanhtb/go-ecommerce-backend-api/cmd/cli/kafka
- github.com/wafumoon/gw-notification/internal/broker/kafka
- github.com/wahidx/kafkax/xkafka
- github.com/walkerfunction/tikr/pkg/output
- github.com/wangxuancheng-dev/goravel-kafka
- 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/wfusion/easeprobe/probe/client/kafka
- github.com/wilbyang/redirect-service/kafka
- github.com/willh-simpson/pantry-wizard/libs/go/common/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/wond4/proton-mq-go
- github.com/workindia/goadapter/pubsub/producer
- github.com/worming004/top10tick/produce-tick
- github.com/wosai/havok/dispatcher
- github.com/wplbyx/modular/packages/transport/pubsub/kafka
- github.com/ws6/klib
- github.com/wtkeqrf0/restService/internal/kafka
- github.com/wuhuZhao/feature_streaming/internal/producer
- github.com/wurt83ow/gophstream/internal/kafka
- github.com/wuttinanhi/code-judge-system/services
- github.com/wyfcoding/ecommerce/cmd/inventory
- github.com/wyfcoding/ecommerce/cmd/search
- github.com/wyfcoding/ecommerce/internal/admin/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/aftersales/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/aimodel/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/analytics/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/audit/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/cart/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/contentmoderation/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/coupon/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/flashsale/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/fulfillment/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/groupbuy/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/inventory/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/logistics/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/loyalty/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/marketing/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/multichannel/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/notification/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/order/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/orderoptimization/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/payment/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/pointsmall/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/pricing/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/product/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/recommendation/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/review/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/risk/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/search/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/settlement/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/subscription/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/support/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/warehouse/interfaces/consumer
- github.com/wyfcoding/ecommerce/internal/wishlist/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/account/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/clearing/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/execution/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/marketdata/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/marketmaking/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/matchingengine/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/order/interfaces/events
- github.com/wyfcoding/financialtrading/internal/referencedata/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/risk/interfaces/consumer
- github.com/wyfcoding/financialtrading/internal/settlement/interfaces/consumer
- github.com/x3a-tech/kafkus
- github.com/xBlaz3kx/event-processing-challenge/internal/pkg/kafka
- github.com/xaleel/maniflex/events/kafka
- github.com/xanderxampp-be/franco/kafka/segmentio
- github.com/xataio/pgstream/pkg/kafka
- github.com/xavesen/search-api/internal/queue
- github.com/xhanio/framingo/pkg/services/pubsub/driver
- 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/xiongwp/payment-util/audit/kafkago
- github.com/xiongxiubo/go-kit/mq/kafkamq
- github.com/xm-utils/tools/kafka
- github.com/xoctopus/confx/pkg/confkafka
- github.com/xoxoist/oni
- github.com/xsbs1996/go-zero-core/xdata/xkafka
- github.com/xuexiangyou/thor/queue/kq
- github.com/xulei324/spiderlab-go-sdk/database
- github.com/xuzhijvn/ht-apm/apmcore
- github.com/xxzhwl/gaia/components/kafka
- github.com/y7ut/logtransfer/source
- github.com/yahoo/panoptes-stream/producer/mqueue/kafka
- github.com/yangkushu/rum-go/messagequeue
- github.com/ydcloud-dy/publicPkg/pkg/options
- github.com/ydssx/kratos-kit/pkg/client/kafka
- github.com/yhyzgn/goat/kafka
- github.com/yigithankarabulut/wirekit/kafka
- github.com/ynwd/kafka-example
- github.com/yogayulanda/go-core/messaging
- github.com/yongxiaodong/golibs/kafkaDB
- github.com/yorkershi/golib
- github.com/yorkie-team/yorkie/server/backend/messaging
- 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/yzletter/go-postery/agent/infra/kafka
- github.com/yzletter/go-postery/agent/service
- github.com/yzletter/go-postery/outbox/infra/kafka
- github.com/yzletter/go-postery/outbox/infra/mysql
- github.com/yzletter/go-postery/search/infra/kafka
- github.com/yzletter/go-postery/search/service
- github.com/yzletter/go-postery/session/infra/kafka
- github.com/yzletter/go-postery/session/service
- github.com/yzletter/go-postery/user/service
- github.com/zackarysantana/velocity/internal/service/kafka
- github.com/zahartd/social-network/src/services/user-service/internal/infrastructure/kafka
- github.com/zatrasz75/Service/pkg/service
- github.com/zeedware/kafkapro
- github.com/zenchainprotocol/zenchain-node/x/stream/kafkaclient
- github.com/zentic-org/go-admin-core/sdk/config
- github.com/zeromicro/cds/pkg/tube
- github.com/zhangsq-ax/aws-msk-helper-go
- github.com/zhenianik/grpcApiTest/internal/kafka
- github.com/zikwall/app_metrica/internal/infrastructure/kafka
- github.com/zikwall/app_metrica/internal/services/consumer/eventbus
- github.com/zikwall/app_metrica/internal/services/consumer/handlers/mediavitrina
- github.com/zikwall/app_metrica/internal/services/consumer/handlers/own
- github.com/zikwall/app_metrica/pkg/kfk
- github.com/zikwall/grower/internal/services/kafkalog
- github.com/zilliztech/milvus-operator/pkg/external
- 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/zloevil/jet/kafka
- github.com/zmon-deploy/zmon-common-go/pubsub
- github.com/znas-io/asyncapi-codegen/pkg/extensions/brokers/kafka
- github.com/znsio/specmatic-order-bff-go/internal/com/store/order/bff/services
- github.com/zuishabi/zinx/utils
- github.com/zuodazuoqianggame/game_common/eventbus
- 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
- github.yzzshmily.us.kg/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/acumen5524834/shop-service/internal/usecase/kafka
- gitlab.com/andrey.solomenniy/casino-transaction-management-system/internal/infrastructure/kafka
- gitlab.com/argi.garnadi/go-common/kafka
- gitlab.com/bahodirova/api-gateway/kafka
- gitlab.com/bds4430521/backend/building_block/infrastructure/eventbus/kafka
- gitlab.com/bensivo/kcli/internal/client
- gitlab.com/bngnha/go-plugins/broker/segmentio/v2
- gitlab.com/bobr-lord-messenger/message/internal/kafka
- gitlab.com/common-libs-payberus/logger/services/kafka
- gitlab.com/data-custodian/custodian-go/connectors/mq
- gitlab.com/falaleev-go/kafkamux
- gitlab.com/flake-chat/broker
- gitlab.com/go_k8s_template/go_common_tools/kafka
- gitlab.com/golang-libs/mosk.git/interfaces/kafka/kafkago
- gitlab.com/jc88/jager/messagebroker/kafkax
- gitlab.com/js-serve/js-util/kafka
- gitlab.com/lingualeap/auth/kafka
- gitlab.com/m7165/go-service
- gitlab.com/mage-repo/template-utils/kafka-service
- gitlab.com/maksous-team/forum/grpc-users/internal/producer
- gitlab.com/money_log/platform-backend/kafka
- gitlab.com/offzoneworks/everest/event/kafka
- gitlab.com/phntm-app/phntm-shared/kafka
- gitlab.com/quantumquest3/learning_service/kafka
- gitlab.com/ramisoul/dating-auth/internal/events
- gitlab.com/sipkyjayaptra/benchmarking-message-broker/broker/kafka
- gitlab.com/spydotech-group/shared-entity/kafka
- gitlab.com/swarajd/homelab_services/longmath
- gitlab.com/tirage/libs/mq/kafka
- gitlab.com/wangzhuan/xlog
- gitlab.com/zynero/shared/transport/kafka
- gitlab.qobserve.com/teamq/flux/stdlib/kafka
- gitlab.roman-davydov.ru/util/kafka-logger
- gitlab.st-payup.com/ecom/back/lib-logger/writer
- gitlab.subwayexit.space/cardbox/backend/libs/core/kafka/config
- gitlab.subwayexit.space/cardbox/backend/libs/core/kafka/consumer
- gitlab.subwayexit.space/cardbox/backend/libs/core/kafka/header/extractor
- gitlab.subwayexit.space/cardbox/backend/libs/core/kafka/header/provider
- gitlab.subwayexit.space/cardbox/backend/libs/core/kafka/producer
- 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
- gitverse.ru/aleksandr-bebyakov/event-sourcingo/infrastructure/kafka
- 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
- lab.ybbapp.com/go/pkg/log
- libx.net/eventstream
- shylinux.com/x/redis-story/src/kafka
- try.meta-gogs.cn/try-gogs/xdb/xkafka
- wait4x.dev/v3/checker/kafka
- xgit.xiaoniangao.cn/xngo/lib/xlog