Go to main page
Known importers: 2,696 (displaying 3,812 packages, including internal and invalid packages)
- bitbucket.org/axbannaz/sizetest/go/kafka/common
- bitbucket.org/axbannaz/sizetest/go/kafka/nkbigpub
- bitbucket.org/axbannaz/sizetest/go/kafka/nkpub
- bitbucket.org/axbannaz/sizetest/go/kafka/nksub
- bitbucket.org/axbannaz/sizetest/go/kafka/nksub1
- bitbucket.org/axbannaz/sizetest/go/kafka/pubsub
- bitbucket.org/axbannaz/sizetest/go/kafka/regexp
- bitbucket.org/bsdrpst/gopkg/q/sarama
- bitbucket.org/credmais/kafka/pkg/mensageria/sarama-kafka
- bitbucket.org/nwt-nevada/diamonds-backend-service/pkg/telemetrywriter
- git.hlsq.asia/mmorpg/service-common/db/kafka
- git.lanniu.top/nebula-cloud/go-scaffold/skq
- git.zabbix.com/ZT/kafka-connector/kafka
- git.zd.zone/opensource/golang/components/kafka
- git.zhangdeman.cn/zhangdeman/kafka
- gitea.anxinyun.cn/container/common_utils/kafkaHelper
- gitea.com/logicamp/lc
- gitee.com/amuluze/amutool/kafka
- gitee.com/appplugin/tools/mq/kafka
- gitee.com/chejiangyi/bsfgo/kafka2
- gitee.com/csingo/cKafka
- gitee.com/finejoint/gotools/kafka
- gitee.com/ge-changwei/rainge-dao/kafka
- gitee.com/go-libs/log/logger/kafka_plugin
- gitee.com/guoting520/mycommon.git/kafka
- gitee.com/hgg_test/pkg_tool/v2/DBx/mysqlX/gormx/dbMovex/myMovex/messageQueue/consumerx
- gitee.com/hgg_test/pkg_tool/v2/channelx/messageQueuex/saramax/saramaConsumerx
- gitee.com/hgg_test/pkg_tool/v2/channelx/messageQueuex/saramax/saramaConsumerx/ConsumerGroupHandlerx
- gitee.com/hgg_test/pkg_tool/v2/channelx/messageQueuex/saramax/saramaConsumerx/serviceLogic
- gitee.com/hgg_test/pkg_tool/v2/channelx/messageQueuex/saramax/saramaProducerx
- gitee.com/hgg_test/pkg_tool/v2/channelx/mqX/kafkaX/saramaX/consumerX
- gitee.com/hgg_test/pkg_tool/v2/channelx/mqX/kafkaX/saramaX/producerX
- gitee.com/hioaf/opentelemetry/common/kafka
- gitee.com/kang_honglei/go_pkg/kafka
- gitee.com/laotie999/guardian/app/sys_service
- gitee.com/lishanfeng/gframe/core/scheduled/kafka
- gitee.com/matkurban/openimsdk-tools/mq/kafka
- gitee.com/minguo_li/mgo/common/msgqueue/kafka
- gitee.com/penbox/basic-go/homework12/events/article
- gitee.com/penbox/basic-go/homework18/events
- gitee.com/penbox/basic-go/homework18/ioc
- gitee.com/penbox/basic-go/homework19/follow/event
- gitee.com/penbox/basic-go/homework20/feed/events
- gitee.com/penbox/basic-go/homework20/feed/ioc
- gitee.com/penbox/basic-go/homework9/pkg/saramax
- gitee.com/penbox/basic-go/webook/pkg/migrator/events
- gitee.com/penbox/basic-go/webook/pkg/migrator/events/fixer
- gitee.com/penbox/basic-go/webook/pkg/migrator/integration/startup
- gitee.com/penbox/basic-go/webook/pkg/saramax
- gitee.com/qt-wu/glog/hooks
- gitee.com/the_sun_light/pkg/kafka
- gitee.com/weixuehao/kratos-bootloader/plugins/broker/saka
- gitee.com/wkRonin/wkRonin-basic-go/webook/article/events/article
- gitee.com/wkRonin/wkRonin-basic-go/webook/article/intergration/startup
- gitee.com/wkRonin/wkRonin-basic-go/webook/article/ioc
- gitee.com/wkRonin/wkRonin-basic-go/webook/interactive/events/article
- gitee.com/wkRonin/wkRonin-basic-go/webook/interactive/intergration/startup
- gitee.com/wkRonin/wkRonin-basic-go/webook/interactive/ioc
- gitee.com/xiao_hange/go-admin-pkg/pkg/saramax
- gitee.com/xuh-code/go-pkg/kafka
- gitee.com/yangwood/novacore/src/transportCore/kafka
- github.com/0angelic0/dd-trace-go/contrib/IBM/sarama.v1
- github.com/0oMarko0/authula/internal/events
- github.com/0xAFz/storm/internal/producer
- github.com/0xDevvvvv/kafka-redis-webserver/kafka
- github.com/0xsj/overwatch-pkg/stream/kafka
- github.com/12ilya12/go-proj-mng/middlewares
- github.com/18721889353/sunshine/pkg/kafka
- github.com/1ocknight/mess/shared/adapter/subjectdeletereader
- github.com/2JYK2/go-lib/common/msk
- github.com/2group/2sales.core-service/pkg/kafka
- github.com/3169a7e4c0eb100/go-simple-template/kafka
- github.com/3th1nk/easygo/mq/kafka
- github.com/4ont/kit/go/kratostune
- github.com/4thel00z/task-manager/pkg
- github.com/84hero/evm-scanner/pkg/sink
- github.com/8xmx8/easier/pkg/amqp/kafka
- github.com/ARGOeu/argo-messaging/brokers
- github.com/AbnerEarl/goutils/kafkas
- github.com/AchmadRifai/sarama-consumer-go
- github.com/Ajinx1/go-storage-config/src/db/kafka
- github.com/Ali127Dev/xoutbox/kafka
- github.com/Andr-07/rate-limiter/pkg/kafka
- github.com/Andrew-M-C/trpc-go-demo/app/mq/service
- github.com/AndrivA89/kafkadesk/infrastructure
- github.com/AndroSaal/RecommendationsForUsers/app/services/product/internal/transport/kafka/producer
- github.com/AndroSaal/RecommendationsForUsers/app/services/recommendation/internal/service
- github.com/AndroSaal/RecommendationsForUsers/app/services/recommendation/internal/transport/kafka/consumer
- github.com/AndroSaal/RecommendationsForUsers/app/services/user/internal/transport/kafka/producer
- github.com/Ansmeee/kafka-worker-pool
- github.com/Anton-Kraev/ozon-route256-homeworks/internal/kafka
- github.com/ArdiSasongko/Ecommerce-order/internal/external
- github.com/Ashwin7867/go-kafka-retrier/retrier
- github.com/Authula/authula/internal/events
- github.com/Autodoc-Technology/streaming-based-config/sbctransport
- github.com/Benny93/kafui/pkg/datasource/kafds
- github.com/BhavaniNBL/ecommerce-backend/services/inventory-service/service
- github.com/BhavaniNBL/ecommerce-backend/services/notification-service
- github.com/BhavaniNBL/ecommerce-backend/services/payment-service
- github.com/BhavaniNBL/ecommerce-backend/shared/KafkaConsumerUtil
- github.com/BhavaniNBL/ecommerce-backend/shared/kafkautil
- github.com/Borislavv/go-kafka/pkg/kafka/consumer
- github.com/Borislavv/go-kafka/pkg/kafka/consumer/message/handler
- github.com/Borislavv/go-kafka/pkg/kafka/consumer/message/handler/interface
- github.com/Borislavv/go-kafka/pkg/kafka/producer/async
- github.com/Borislavv/go-kafka/pkg/kafka/producer/async/handler
- github.com/Borislavv/go-kafka/pkg/kafka/producer/sync
- github.com/Borislavv/go-kafka/pkg/kafka/sarama/config
- github.com/CTO2BPublic/passage-server/pkg/kafkadriver
- github.com/CantDefeatAirmanx/space-engeneering/platform/pkg/kafka
- github.com/CantDefeatAirmanx/space-engeneering/platform/pkg/kafka/client
- github.com/CantDefeatAirmanx/space-engeneering/platform/pkg/kafka/consumer
- github.com/CantDefeatAirmanx/space-engeneering/platform/pkg/kafka/converter
- github.com/CantDefeatAirmanx/space-engeneering/platform/pkg/kafka/producer
- github.com/Causely/chaosmania/pkg/actions
- github.com/Cc360428/HelpPackage/kafkac
- github.com/Coderovshik/kafka-demo/api-gateway/internal/service
- github.com/Conty111/SuperCalculator/back-end/agent/internal/app/initializers
- github.com/Conty111/SuperCalculator/back-end/agent/internal/config
- github.com/Conty111/SuperCalculator/back-end/agent/internal/transport/kafka-broker
- github.com/Conty111/SuperCalculator/back-end/orkestrator/internal/app/initializers
- github.com/Conty111/SuperCalculator/back-end/orkestrator/internal/config
- github.com/Conty111/SuperCalculator/back-end/orkestrator/internal/transport/kafka-broker
- github.com/Corray333/keep_it/parsers/telegram/internal/repository
- github.com/CppUser/kafka
- github.com/Cray-HPE/hms-hmcollector/cmd/kafka_tool
- github.com/Cuebiq/sarama-easy/kafka
- github.com/DEEPAKK-T/livekafkafeeder
- github.com/DIMO-Network/credit-tracker/internal/events
- github.com/DIMO-Network/devices-api/cmd/devices-api
- github.com/DIMO-Network/devices-api/internal/controllers
- github.com/DIMO-Network/devices-api/internal/kafka
- github.com/DIMO-Network/devices-api/internal/rpc
- github.com/DIMO-Network/devices-api/internal/services
- github.com/DIMO-Network/devices-api/internal/services/registry
- github.com/DIMO-Network/privacy-processor/cmd/privacy-processor
- github.com/DIMO-Network/shared/pkg/kafka
- github.com/Daniil-Sakharov/RocketFactory/notification/internal/app
- github.com/Daniil-Sakharov/RocketFactory/notification/internal/config
- github.com/Daniil-Sakharov/RocketFactory/notification/internal/config/env
- github.com/Daniil-Sakharov/RocketFactory/order/internal/app
- github.com/Daniil-Sakharov/RocketFactory/order/internal/config
- github.com/Daniil-Sakharov/RocketFactory/order/internal/config/env
- github.com/Daniil-Sakharov/RocketFactory/order/internal/config/mocks
- github.com/Daniil-Sakharov/RocketFactory/platform/pkg/kafka/consumer
- github.com/Daniil-Sakharov/RocketFactory/platform/pkg/kafka/producer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/01_sarama/01_kafka_producer/01_syncProducer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/01_sarama/01_kafka_producer/02_asyncProducer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/01_sarama/02_kafka_consumer/01_consumer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/01_sarama/02_kafka_consumer/02_consumer_group
- github.com/Danny5487401/go_package_example/18_log_collect/logAgent/kafka
- github.com/Darker-D/ddbase/queue/kafka
- github.com/Ddarli/utils/kafka
- github.com/Denrogh/GCA-Cowrie-Honeypots/pkg/kafka
- github.com/DianGeIM/tools/mq/kafka
- github.com/Dmitrij-bot/marketserv/internal/usecase
- github.com/EchoMessenger/router
- github.com/EfimoffN/beholder/kfkapi
- github.com/Egor-Pomidor-pdf/ImageProcessor/imageProcessor/internal/infrastructure
- github.com/EladLeev/kafka-config-metrics/pkg/kafka
- github.com/Eomaxl/EventDriven-Programming/producer
- github.com/EricKim65/abango
- github.com/Etozheraf/PickupPointManager/internal/kafka
- github.com/Eyup-Devop/logtor/creators
- github.com/FiberApps/common-library/kafka
- github.com/Financial-Times/kafka-client-go/v4
- github.com/FireManXiong/origin/v2/sysmodule/kafkamodule
- github.com/Flake-chat/Flake-Auth/internal/broker
- github.com/FluorescentTouch/testosteron
- github.com/FluorescentTouch/testosteron/kafka
- github.com/FluorescentTouch/testosteron/kafka/producer
- github.com/FluorescentTouch/testosteron/kafka/reader
- github.com/FluorescentTouch/testosteron/v2
- github.com/FluorescentTouch/testosteron/v2/kafka/client
- github.com/FluorescentTouch/testosteron/v2/kafka/producer
- github.com/FluorescentTouch/testosteron/v2/kafka/reader
- github.com/ForbiddenR/kafka/v2
- github.com/Foxtrot1388/MessaggioTask/internal/storage/kafka
- github.com/Fu-XDU/mingfu_go_common/kafka
- github.com/Genvekt/cli-chat/libraries/kafka/pkg/kafka/consumer
- github.com/Genvekt/cli-chat/libraries/kafka/pkg/kafka/producer
- github.com/Genvekt/cli-chat/services/auth/internal/app
- github.com/Genvekt/cli-chat/services/auth/internal/config
- github.com/Genvekt/cli-chat/services/auth/internal/config/env
- github.com/Genvekt/cli-chat/services/auth/internal/service/consumer
- github.com/Genvekt/cli-chat/services/auth_producer/internal/app
- github.com/Genvekt/cli-chat/services/auth_producer/internal/client/kafka/user
- github.com/Genvekt/cli-chat/services/auth_producer/internal/client/kafka/user/converter
- github.com/Genvekt/cli-chat/services/auth_producer/internal/config
- github.com/Genvekt/cli-chat/services/auth_producer/internal/config/env
- github.com/GoBetterAuth/go-better-auth/v2/internal/events
- github.com/GoSimplicity/LinkMe-microservices/app/linkme-interactive/internal/data
- github.com/GoSimplicity/LinkMe-microservices/app/linkme-post/events/publish
- github.com/GoSimplicity/LinkMe-microservices/app/linkme-post/events/sync
- github.com/GoSimplicity/LinkMe-microservices/app/linkme-post/internal/data
- github.com/GoSimplicity/LinkMe-microservices/app/linkme-ranking/internal/data
- github.com/GoSimplicity/LinkMe/internal/domain/events/check
- github.com/GoSimplicity/LinkMe/internal/domain/events/comment
- github.com/GoSimplicity/LinkMe/internal/domain/events/email
- github.com/GoSimplicity/LinkMe/internal/domain/events/es
- github.com/GoSimplicity/LinkMe/internal/domain/events/post
- github.com/GoSimplicity/LinkMe/internal/domain/events/publish
- github.com/GoSimplicity/LinkMe/internal/domain/events/sms
- github.com/GoSimplicity/LinkMe/ioc
- github.com/GoSimplicity/LinkMe/pkg/samarap
- github.com/GoSimplicity/LinkMe/pkg/samarap/prometheus
- github.com/Goboolean/common/deprecated/kafka
- github.com/Goden-Gun/transport-lib/pkg/kafka
- github.com/Gorgonx7/sarama-example
- github.com/GuanceCloud/bfy-conv/parseV2
- github.com/Guohuixixi/saramax
- github.com/HadesTso/databaseConnect/databaseutils/database
- github.com/Hemiun/testcontainer
- github.com/Henryarrovin/auth-service/kafka_logger_pipeline
- github.com/Hopetree/go-data-flow/pkg/dataflow/builtins/source/kafka
- github.com/I-m-Surrounded-by-IoT/backend/internal/server/collection
- github.com/I-m-Surrounded-by-IoT/backend/internal/server/email
- github.com/I-m-Surrounded-by-IoT/backend/internal/server/log
- github.com/I-m-Surrounded-by-IoT/backend/internal/server/message
- github.com/I-m-Surrounded-by-IoT/backend/service
- github.com/I-m-Surrounded-by-IoT/backend/service/captcha
- github.com/I-m-Surrounded-by-IoT/backend/service/collection
- github.com/I-m-Surrounded-by-IoT/backend/service/collector
- github.com/I-m-Surrounded-by-IoT/backend/service/email
- github.com/I-m-Surrounded-by-IoT/backend/service/log
- github.com/I-m-Surrounded-by-IoT/backend/service/message
- github.com/I-m-Surrounded-by-IoT/backend/service/notify
- github.com/I-m-Surrounded-by-IoT/backend/utils
- github.com/IBM-Cloud/terraform-provider-ibm/ibm/service/eventstreams
- github.com/IbadT/business_bank_back/services/shared/pkg/kafka
- github.com/Iceqaq/fs123/Plugins
- github.com/Interhyp/metadata-service/internal/repository/kafka
- github.com/JIeeiroSst/utils/kafka
- github.com/JMURv/e-commerce/chat/internal/broker/kafka
- github.com/JMURv/e-commerce/favorites/internal/broker/kafka
- github.com/JMURv/e-commerce/items/internal/broker/kafka
- github.com/JMURv/e-commerce/notifications/internal/broker/kafka
- github.com/JMURv/e-commerce/query/internal/broker/kafka
- github.com/JMURv/e-commerce/reviews/internal/broker/kafka
- github.com/JMURv/e-commerce/users/internal/broker/kafka
- github.com/Jafar05/pkg/logger
- github.com/Jakob-al28/url-shortener-go
- github.com/Jared-lu/GXT/saramax
- github.com/Jayleonc/register/internal/pkg/saramax
- github.com/JohnnyJa/AdServer/EventCollector/internal/kafka
- github.com/JulieWasNotAvailable/microservices/beat/pkg/consumer
- github.com/JulieWasNotAvailable/microservices/beat/pkg/producer
- github.com/JulieWasNotAvailable/microservices/unpublished/pkg/consumer
- github.com/JulieWasNotAvailable/microservices/unpublished/pkg/producer
- github.com/JulieWasNotAvailable/microservices/user/pkg/consumer
- github.com/KNICEX/InkFlow/internal/comment
- github.com/KNICEX/InkFlow/internal/comment/internal/event
- github.com/KNICEX/InkFlow/internal/interactive
- github.com/KNICEX/InkFlow/internal/interactive/internal/events
- github.com/KNICEX/InkFlow/internal/notification
- github.com/KNICEX/InkFlow/internal/notification/internal/event
- github.com/KNICEX/InkFlow/internal/recommend
- github.com/KNICEX/InkFlow/internal/recommend/internal/event
- github.com/KNICEX/InkFlow/internal/relation
- github.com/KNICEX/InkFlow/internal/relation/internal/event
- github.com/KNICEX/InkFlow/internal/review
- github.com/KNICEX/InkFlow/internal/review/internal/event
- github.com/KNICEX/InkFlow/internal/search
- github.com/KNICEX/InkFlow/internal/search/internal/event
- github.com/KNICEX/InkFlow/internal/user
- github.com/KNICEX/InkFlow/internal/user/internal/event
- github.com/KNICEX/InkFlow/ioc
- github.com/KNICEX/InkFlow/pkg/saramax
- github.com/KOMKZ/go-yogan-framework/kafka
- github.com/Kephas73/lib-kephas/kafka_client
- github.com/KevinRionaldo/myGoLibrary/kafkaLib
- github.com/KosAIGoLa/sponge/pkg/kafka
- github.com/KostySCH/Reports_go/reports_publisher/internal/service
- github.com/KseniiaSalmina/tikkichest-portfolio-service/internal/sender/kafka
- github.com/KyleYe/open-im-tools/mq/kafka
- github.com/LEILEI0628/GinPro/Saramax
- github.com/LabKiko/cerberus/kafka
- github.com/Lachstec/digsinet-ng/event
- github.com/Leonid-Sarmatov/golang-yandex-last-fight/solver_server/internal/kafka
- github.com/LinkTsang/go-observer/internal/output
- github.com/Linxhhh/LinInk/article/events
- github.com/Linxhhh/LinInk/article/ioc
- github.com/Linxhhh/LinInk/feed/events
- github.com/Linxhhh/LinInk/feed/ioc
- github.com/Linxhhh/LinInk/interaction/events
- github.com/Linxhhh/LinInk/interaction/ioc
- github.com/Linxhhh/LinInk/pkg/saramax
- github.com/Linxhhh/LinInk/search/events
- github.com/Linxhhh/LinInk/search/ioc
- github.com/Linxhhh/LinInk/user/events
- github.com/Linxhhh/LinInk/user/ioc
- github.com/LuckyCaptain-go/kweaver-go-lib/audit
- github.com/LukeEuler/dolly/log
- github.com/MaKcm14/price-service/internal/repository/kafka
- github.com/MaciejNET/PixelPulseSharedGo/messaging
- github.com/MajotraderLucky/Kafka-FIO-Listener/checker
- github.com/ManishaYadav15/banking-ledger/internal/kafka
- github.com/Mantelijo/deblock-backend/internal/svc
- github.com/Meikwei/go-tools/mq/kafka
- github.com/MonteProSoft/common-go/kafka
- github.com/MrMiaoMIMI/goshared/mq/internal/mqsp
- github.com/MrRique15/go_rest_api/main_api/pkg/shared/kafka
- github.com/MrRique15/go_rest_api/payment_service
- github.com/MrRique15/go_rest_api/payment_service/consumers
- github.com/MrRique15/go_rest_api/payment_service/pkg/shared/kafka
- github.com/MrRique15/go_rest_api/shipping_service
- github.com/MrRique15/go_rest_api/shipping_service/consumers
- github.com/MrRique15/go_rest_api/shipping_service/pkg/shared/kafka
- github.com/MsSabo/todo_list/cmd
- github.com/MuhibNayem/Travio/server/pkg/kafka
- github.com/Muvi7z/boilerplate/assembly/internal/app
- github.com/Muvi7z/boilerplate/assembly/internal/config
- github.com/Muvi7z/boilerplate/assembly/internal/config/env
- github.com/Muvi7z/boilerplate/notification/internal/app
- github.com/Muvi7z/boilerplate/notification/internal/config
- github.com/Muvi7z/boilerplate/notification/internal/config/env
- github.com/Muvi7z/boilerplate/platform/kafka/consumer
- github.com/Muvi7z/boilerplate/platform/kafka/producer
- github.com/Myagchiev/transfer-service/pkg/kafka
- github.com/NSObjects/go-template/internal/api/data/db
- github.com/NStegura/saga/orders/internal/app/consumers
- github.com/NStegura/saga/orders/internal/app/consumers/handlers/payment
- github.com/NStegura/saga/orders/internal/app/consumers/handlers/product
- github.com/NStegura/saga/orders/internal/clients/kafka/consumer
- github.com/NStegura/saga/orders/internal/clients/kafka/producer
- github.com/NStegura/saga/payments/internal/app/consumer
- github.com/NStegura/saga/payments/internal/clients/kafka/consumer
- github.com/NStegura/saga/payments/internal/clients/kafka/producer
- github.com/NStegura/saga/products/internal/app/consumers
- github.com/NStegura/saga/products/internal/app/consumers/handlers/order
- github.com/NStegura/saga/products/internal/app/consumers/handlers/payment
- github.com/NStegura/saga/products/internal/clients/kafka/consumer
- github.com/NStegura/saga/products/internal/clients/kafka/producer
- github.com/Nader-gator/http-requests-mirroring
- github.com/NetEase-Media/easy-ngo/clients/xkafka
- github.com/Netsocs-Team/netsocs_go_sdk/pkg/kafka
- github.com/NickNaskida/Watchdog/backend/cmd
- github.com/NikitaTsaralov/utils/logger
- github.com/NikitaVi/platform_shared/pkg/kafka/consumer
- github.com/OfferCat-ai/proto/events
- github.com/OnlyPiglet/fly/kafkatools
- github.com/OscarMoya/Glubber/pkg/queue
- github.com/Paul1k96/microservices_course_auth/internal/api/kafka/user/v1
- github.com/Paul1k96/microservices_course_auth/internal/app
- github.com/Paul1k96/microservices_course_auth/internal/config
- github.com/Paul1k96/microservices_course_auth/internal/config/env
- github.com/Paul1k96/microservices_course_auth/internal/repository/user_event/kafka
- github.com/Paul1k96/microservices_course_platform_common/pkg/client/kafka/consumer
- github.com/PechatnovVladimir/msa_big_tech/chat/internal/app/adapters/chateventshandler
- github.com/PechatnovVladimir/msa_big_tech/lib/boot
- github.com/PechatnovVladimir/msa_big_tech/lib/kafka
- github.com/PechatnovVladimir/msa_big_tech/lib/kafka/consumer
- github.com/PechatnovVladimir/msa_big_tech/pkg/kafka
- github.com/PechatnovVladimir/msa_big_tech/social/internal/app/adapters/socialeventshandler
- github.com/PenguinLQ/webkit/pkg/saramax
- github.com/Petr09Mitin/xrust-beze-back/internal/pkg/kafka
- github.com/Piyushhbhutoria/tote-assignment/pkg/kafka
- github.com/PolinaSvet/kafka
- github.com/Popov-Dmitriy-Ivanovich/Diplom_cmd/kafka
- github.com/Primeskills-Web-Team/golang-api-common/kafka/integration/command/consumer
- github.com/Primeskills-Web-Team/golang-api-common/kafka/integration/command/producer
- github.com/Primeskills-Web-Team/golang-api-common/kafka/integration/config
- github.com/Primeskills-Web-Team/golang-api-common/v2/kafka
- github.com/Prrromanssss/platform_common/pkg/kafka/consumer
- github.com/QinPengLin/repro-origin/sysmodule/kafkamodule
- github.com/Raezil/KafkaEventBus
- github.com/RaghibA/iot-telemetry/pkg/kafka
- github.com/Ralle001/go-kafka-logger
- github.com/RandySteven/Library-GO/pkg/kafkas
- github.com/RedHatInsights/ccx-notification-service/producer/kafka
- github.com/RedHatInsights/ccx-notification-writer
- github.com/RedHatInsights/insights-results-aggregator/broker
- github.com/RedHatInsights/insights-results-aggregator/consumer
- github.com/RedHatInsights/insights-results-aggregator/producer
- github.com/RedHatInsights/insights-results-aggregator/storage
- github.com/RedHatInsights/insights-results-aggregator/tests/helpers
- github.com/Rinai-R/ApexLecture/server/cmd/agent/initialize
- github.com/Ritikjainrj18/Problem-Scheduler/producer
- github.com/Rolan335/grpcMessenger/server/internal/kafka
- github.com/RomanIvanovMinsk/kafka_helper
- github.com/Roshick/go-autumn-kafka/pkg/kafka
- github.com/SENERGY-Platform/analytics-cleanup/pkg/apis
- github.com/SENERGY-Platform/event-deployment/lib/kafka/topicconfig
- github.com/SENERGY-Platform/external-task-worker/lib/com/kafka
- github.com/SENERGY-Platform/import-deploy/lib/kafka-admin
- github.com/SENERGY-Platform/import-repository/lib/source/consumer
- github.com/SENERGY-Platform/lorawan-platform-connector/pkg/controller
- github.com/SENERGY-Platform/moses/lib
- github.com/SENERGY-Platform/mqtt-platform-connector/lib
- github.com/SENERGY-Platform/permission-search/lib/worker/kafka/topicconfig
- github.com/SENERGY-Platform/senergy-platform-connector/lib
- github.com/SENERGY-Platform/service-commons/pkg/kafka
- github.com/SENERGY-Platform/timescale-tableworker/pkg/lib/kafka
- github.com/SIN5t/tiktok_v2/pkg/kafka/video
- github.com/SS4ar/fscan/Plugins
- github.com/SametAvcii/crypto-trade/pkg/events
- github.com/Sea-Go/Sea-RideTheWind/service/hot/rpc
- github.com/Sea-Go/Sea-RideTheWind/service/hot/rpc/internal/mqs
- github.com/Sea-Go/Sea-RideTheWind/service/hot/test/cmd/loadtest
- github.com/Sea-Go/Sea-RideTheWind/service/hot/test/cmd/producer
- github.com/Sea-Go/Sea-RideTheWind/service/task/rpc/internal/Init
- github.com/SergeyMilch/pay_aware/internal/kafka
- github.com/SicParv1sMagna/AtomHackMarsService/internal/kafka
- github.com/Slimo300/Microservices-Videocall-and-Chat-App/backend/lib/msgqueue/kafka
- github.com/SosisterRapStar/cliros/examples/kafka-pubsub
- github.com/SoulStalker/kafkaconsumer
- github.com/Soyaka/microlearn-entitment/internal/kafka
- github.com/Still-her/calm/kafka
- github.com/SyamSolution/notification-service/cmd/http
- github.com/SyamSolution/transaction-service/helper
- github.com/TGRZiminiar/go-mc-kafka/pkg/queue
- github.com/TengFeiyang01/webook/webook/article/events
- github.com/TengFeiyang01/webook/webook/article/integration/startup
- github.com/TengFeiyang01/webook/webook/article/ioc
- github.com/TengFeiyang01/webook/webook/interactive/events
- github.com/TengFeiyang01/webook/webook/interactive/integration/startup
- github.com/TengFeiyang01/webook/webook/interactive/ioc
- github.com/TengFeiyang01/webook/webook/internal/events/article
- github.com/TengFeiyang01/webook/webook/internal/integration/startup
- github.com/TengFeiyang01/webook/webook/ioc
- github.com/TengFeiyang01/webook/webook/pkg/saramax
- github.com/TiktokCommence/component/log/writer
- github.com/Timasha/core/kafka
- github.com/TimeWtr/local_message_table
- github.com/Timofey335/platform_common/pkg/kafka/consumer
- github.com/TingYunGo/goagent/mq/kafka/sarama
- github.com/TremblingV5/box/components/kafkax
- github.com/Trendyol/kafka-wrapper
- github.com/Trendyol/kafka-wrapper/execution_behaviour
- github.com/Trendyol/kafka-wrapper/execution_behaviour/behavioral
- github.com/Trendyol/kafka-wrapper/kafka_tracing
- github.com/Trendyol/kafka-wrapper/mocks
- github.com/Trendyol/kafka-wrapper/params
- github.com/Trendyol/kafka-wrapper/test_utils
- github.com/Trendyol/kafka-wrapper/utils
- github.com/TykTechnologies/benthos/v4/internal/impl/kafka
- github.com/TykTechnologies/labs-streams/cmd
- github.com/UnicomAI/wanwu/internal/knowledge-service/pkg/mq
- github.com/Uonx/go-tools/msg_queue/kafka
- github.com/VadimGossip/concoleChat-auth/internal/app
- github.com/VadimGossip/concoleChat-auth/internal/client/kafka/consumer
- github.com/VadimGossip/concoleChat-auth/internal/client/kafka/producer
- github.com/VadimGossip/concoleChat-auth/internal/config
- github.com/VadimGossip/concoleChat-auth/internal/config/kafka
- github.com/VadimGossip/concoleChat-auth/internal/service/consumer/user
- github.com/ValeryCherneykin/taskanalytics/file_processing/internal/client/kafka/consumer
- github.com/ValeryCherneykin/taskanalytics/file_processing/internal/config
- github.com/ValeryCherneykin/taskanalytics/task_distribution/internal/app
- github.com/ValeryCherneykin/taskanalytics/task_distribution/internal/client/kafka/producer
- github.com/ValeryCherneykin/taskanalytics/task_distribution/internal/config
- github.com/VeRJiL/go-template/internal/pkg/messagebroker/drivers
- github.com/Vova-luk/weather-stream/services/analytic-service/internal/service
- github.com/Vova-luk/weather-stream/services/analytic-service/pkg/kafka
- github.com/Vova-luk/weather-stream/services/location-service/internal/service
- github.com/Vova-luk/weather-stream/services/location-service/pkg/kafka
- github.com/Vova-luk/weather-stream/services/weather-service/internal/service
- github.com/Vova-luk/weather-stream/services/weather-service/pkg/kafka
- github.com/WantBeASleep/med_ml_lib/dbus
- github.com/WeiXinao/basic-go/webook/interactive/events
- github.com/WeiXinao/basic-go/webook/interactive/ioc
- github.com/WeiXinao/basic-go/webook/internal/events/article
- github.com/WeiXinao/basic-go/webook/internal/integration/startup
- github.com/WeiXinao/basic-go/webook/ioc
- github.com/WeiXinao/basic-go/webook/payment/events
- github.com/WeiXinao/basic-go/webook/pkg/migrator/events
- github.com/WeiXinao/basic-go/webook/pkg/migrator/events/fixer
- github.com/WeiXinao/basic-go/webook/pkg/saramax
- github.com/Wenfei952/openim-tools/mq/kafka
- github.com/WwhdsOne/Wlog/writer/mq
- github.com/XC-Zero/zero_common/kafka
- github.com/XDWow/DouyinMall/backend/internal/agent/infra/mq
- github.com/XDWow/DouyinMall/backend/internal/agent/ioc
- github.com/XDWow/DouyinMall/backend/internal/payment/ioc
- github.com/XDWow/DouyinMall/backend/internal/product/ioc
- github.com/XDWow/DouyinMall/backend/internal/product/producer
- github.com/XDWow/DouyinMall/backend/internal/search/events
- github.com/XDWow/DouyinMall/backend/internal/search/ioc
- github.com/XDWow/DouyinMall/backend/pkg/migrator/events
- github.com/XDWow/DouyinMall/backend/pkg/migrator/events/fixer
- github.com/XDWow/DouyinMall/backend/pkg/saramax
- github.com/Xonesent/K8s-Hub/statistics-sender/cmd
- github.com/Xonesent/K8s-Hub/statistics-sender/config
- github.com/Xonesent/K8s-Hub/statistics-sender/internal/server
- github.com/Xonesent/K8s-Hub/statistics-sender/internal/statistics_dropper/dropper_delivery/event
- github.com/Xonesent/K8s-Hub/statistics-sender/internal/statistics_reminder/reminder_usecase
- github.com/Xonesent/K8s-Hub/statistics-sender/pkg/dependency_connectors/kafka/config
- github.com/Xonesent/K8s-Hub/statistics-sender/pkg/dependency_connectors/kafka/cons_group
- github.com/Yangfisher1/zipkin-go/reporter/kafka
- github.com/ZoinMe/notification-service-producer
- github.com/aadarshvelu/bms/app/events
- github.com/aarontianqx/gopkg/kafka
- github.com/abdelmounim-dev/websocket-pooler/broker
- github.com/abhijitpratinidhi/connect/v4/impl/impl/kafka
- github.com/abhilasha336/Kafkademotokenservice
- github.com/abhishekamralkar/kafcmd
- github.com/abraham-leal/kafka-idle-topics/cmd/kafka-idle-topics
- github.com/acronix0/REST-API-Go/internal/kafka
- github.com/adamenger/hummingbird/ingest/publisher
- github.com/aderfg/acning/Plugins
- github.com/adiom-data/dsync/connectors/kafka
- github.com/adityakw90/service-access/internal/config
- github.com/adnpa/IM/pkg/common/mq/kafka
- github.com/agalue/onms-kafka-ipc-receiver/client
- github.com/agapoff/kafka-ops
- github.com/agusrichard/icu-vitals-stream/simulator/producer
- github.com/aide-family/moon/pkg/plugin/event
- github.com/air-iot/sdk-go/v4/conn/mq
- github.com/airunny/timer/pkg/ikafka
- github.com/ajitpratap0/nebula/pkg/cdc
- github.com/akimsavvin/tablet_telegram/cmd/tablet_telegram
- github.com/akulsharma1/distributed-analytics-platform/services/inventory/internal/api/functions
- github.com/akulsharma1/distributed-analytics-platform/services/inventory/internal/kafka
- github.com/akulsharma1/distributed-analytics-platform/services/orders/internal/api/functions
- github.com/akulsharma1/distributed-analytics-platform/services/orders/internal/kafka
- github.com/alarmistdev/status/check/queue/kafka
- github.com/alebabai/go-kafka/adapter/sarama
- github.com/alekseiapa/go-kafka-examples/monitoring_testing/metrics_exporter
- github.com/alexander-kartavtsev/starship/order/internal/app
- github.com/alexander-kartavtsev/starship/order/internal/config
- github.com/alexander-kartavtsev/starship/order/internal/config/env
- github.com/alexander-kartavtsev/starship/platform/pkg/kafka/consumer
- github.com/alexander-kartavtsev/starship/platform/pkg/kafka/example/consumer
- github.com/alexander-kartavtsev/starship/platform/pkg/kafka/example/producer
- github.com/alexander-kartavtsev/starship/platform/pkg/kafka/producer
- github.com/algol-84/auth/internal/client/kafka/producer
- github.com/ali-cambodia/h9_marmota/pkg/mq
- github.com/alibaba/ilogtail/test/engine/setup/subscriber
- github.com/alldev-run/golang-gin-rpc/pkg/messaging
- github.com/alserov/device-shop/device-service/internal/broker
- github.com/alserov/device-shop/device-service/internal/broker/worker
- github.com/alserov/device-shop/gateway/internal/broker
- github.com/alserov/device-shop/order-service/internal/broker
- github.com/alserov/device-shop/order-service/internal/broker/manager
- github.com/alserov/device-shop/user-service/internal/broker
- github.com/alserov/device-shop/user-service/internal/broker/mail
- github.com/alserov/device-shop/user-service/internal/broker/worker
- github.com/alserov/mq/kafka
- github.com/alvi31182/kafka
- github.com/always-web/go-pkg/kafka
- github.com/alyzers/alyzers/pkg/log
- github.com/amatsuki16/go-workshop-2/service
- github.com/amazing-socrates/next-tools/mq/kafka
- github.com/amir-mln/amdp-task/system/drivers/logging
- github.com/ammmnia/tools/mq/kafka
- github.com/ampliway/way-lib-go/msg/v1
- github.com/amuluze/amutool/kafka
- github.com/anarakinson/go_kafka_shared/pkg/kafka_helpers
- github.com/anddriii/kita-futsal/payment-service/controllers/kafka
- github.com/andredubov/rocket-factory/order/internal/app
- github.com/andredubov/rocket-factory/order/internal/config
- github.com/andredubov/rocket-factory/order/internal/config/env
- github.com/andredubov/rocket-factory/platform/pkg/kafka/consumer
- github.com/andredubov/rocket-factory/platform/pkg/kafka/producer
- github.com/andreistefanciprian/gomicropay/ledger/cmd/ledger
- github.com/andreistefanciprian/gomicropay/ledger/internal/ledger
- github.com/andreistefanciprian/gomicropay/money_movement/cmd/money_movement
- github.com/andreistefanciprian/gomicropay/money_movement/internal/implementation
- github.com/andreistefanciprian/gomicropay/money_movement/internal/producer
- github.com/andriva89/kafkadesk/infrastructure
- github.com/anthanhphan/saturday/kafka
- github.com/antonio-alexander/go-bludgeon/pkg/kafka
- github.com/apache/dubbo-go-pixiu/pkg/client/mq
- github.com/apiloqbc/sarama-easy/kafka
- github.com/apus-run/sea-kit/mq/kafka
- github.com/arcorium/rashop/services/mailer/cmd/command_server
- github.com/arcorium/rashop/services/mailer/cmd/query_server
- github.com/arcorium/rashop/services/mailer/constant
- github.com/arcorium/rashop/services/mailer/internal/api/messaging/dispatcher
- github.com/arcorium/rashop/services/mailer/internal/infra/publisher
- github.com/arcorium/rashop/services/media_storage/cmd/command_server
- github.com/arcorium/rashop/services/media_storage/constant
- github.com/arcorium/rashop/services/media_storage/internal/api/messaging/dispatcher
- github.com/arcorium/rashop/services/media_storage/internal/infra/publisher
- github.com/arcorium/rashop/services/token/cmd/command_server
- github.com/arcorium/rashop/services/token/constant
- github.com/arcorium/rashop/services/token/internal/api/messaging/dispatcher
- github.com/arcorium/rashop/services/token/internal/infra/publisher
- github.com/arcorium/rashop/shared/messaging
- github.com/arcorium/rashop/shared/messaging/kafka
- github.com/arcorium/rashop/shared/otel
- github.com/arcorium/rashop/shared/types
- github.com/arepala-uml/books-management-system/pkg/kafka
- github.com/argoproj/argo-events/pkg/eventbus/kafka/base
- github.com/argoproj/argo-events/pkg/eventbus/kafka/eventsource
- github.com/argoproj/argo-events/pkg/eventbus/kafka/sensor
- github.com/argoproj/argo-events/pkg/eventsources/sources/kafka
- github.com/argoproj/argo-events/pkg/sensors
- github.com/argoproj/argo-events/pkg/sensors/triggers/kafka
- github.com/argoproj/argo-events/pkg/shared/util
- github.com/arquivei/goduck/impl/implstream/kafkasarama
- github.com/arshanh/benthos/v4/internal/impl/kafka
- github.com/aryanc1027/api-kafka-golang/internal/kafka
- github.com/asinha08/ts-utils/kafka
- github.com/asynccnu/bff/pkg/saramax
- github.com/asynccnu/ccnubox-be/be-classlist/internal/data
- github.com/asynccnu/ccnubox-be/be-feed/events
- github.com/asynccnu/ccnubox-be/be-feed/events/consumer
- github.com/asynccnu/ccnubox-be/be-feed/events/producer
- github.com/asynccnu/ccnubox-be/be-feed/ioc
- github.com/asynccnu/ccnubox-be/be-grade/events
- github.com/asynccnu/ccnubox-be/be-grade/events/consumer
- github.com/asynccnu/ccnubox-be/be-grade/events/producer
- github.com/asynccnu/ccnubox-be/be-grade/ioc
- github.com/asynccnu/ccnubox-be/common/bizpkg/infra
- github.com/asynccnu/ccnubox-be/common/pkg/otelx/otelsarama
- github.com/asynccnu/ccnubox-be/common/pkg/saramax
- github.com/awd2211/short-drama-system/backend/internal/service
- github.com/axidex/sast-manager/pkg/kafka
- github.com/axiomod/axiomod/framework/kafka
- github.com/ayushthe1/streak/kafka
- github.com/badAkne/order-service/pkg/broker
- github.com/bagusYudistira/k6-kafka-consumer
- github.com/balasl342/kafka-payment-processor/internal/kafka
- github.com/baothaihcmut/Ecommerce-Go/libs/pkg/queue
- github.com/baoyxing/micro-extend/pkg/kafka/sarama
- github.com/bas-baskara/kafka-consumer-grpc
- github.com/batmanven/iicpc2026/pkg/ingestion
- github.com/bborbe/mqtt-kafka-connector
- github.com/benidevo/order-fulfillment/query/internal/events/event_consumers
- github.com/besanh/go-library/kafka
- github.com/bignyap/go-utilities/kafka
- github.com/bira37/benthos/v4/internal/impl/kafka
- github.com/blackye/kunpeng/plugin/go
- github.com/blink-io/x/kafka/sarama/registrar
- github.com/blr-coder/tasks-svc/internal/infrastructure/queues/kafka
- github.com/bmeg/grip/server
- github.com/bobacgo/kit/app/mq/kafka
- github.com/bobo-rs/kfkqueue
- github.com/bodaay/quafka/_examples/sarama
- github.com/bogdanshibilov/blockchaincrawler/internal/auth/codeproducer
- github.com/bondzai/portfolio-backend/internal/usecases
- github.com/boostgo/core/kafkax
- github.com/bsv-blockchain/arcade/kafka
- github.com/bugzzhou/gotools/kafka
- github.com/burdiyan/kafkautil
- github.com/bytedance/Elkeid/server/agent_center/common/kafka
- github.com/caiflower/common-tools/kafka/v2
- github.com/cantaskin/air-pollution-monitoring/backend/shared/messaging/kafka
- github.com/carlcarl/logrus-kafka-hook
- github.com/carlosealves2/create-user-micro-services/common/kafkaclient
- github.com/casuallc/vigil/client/kafka
- github.com/cbhcbhcbh/Quantum/pkg/infra
- github.com/ccheers/xpkg/xmsgbus/impl/kafka
- github.com/cg917658910/fzkj-wallet/notify-service/app/services/order/caller
- github.com/cg917658910/fzkj-wallet/notify-service/app/services/order/consumer
- github.com/cg917658910/fzkj-wallet/notify-service/app/services/order/consumer/tracker
- github.com/cg917658910/fzkj-wallet/notify-service/app/services/order/producer
- github.com/cg917658910/fzkj-wallet/notify-service/app/services/order/scheduler
- github.com/cg917658910/fzkj-wallet/notify-service/app/services/order/types
- github.com/cguertin14/kafka-example/producer
- github.com/chaksunshine/kit/adapters/kafka
- github.com/charlesbases/library/broker/kafka
- github.com/charlesng35/shellcn/plugins/kafka
- github.com/chenmuyao/go-bootcamp/interactive/events
- github.com/chenmuyao/go-bootcamp/interactive/integration/startup
- github.com/chenmuyao/go-bootcamp/interactive/ioc
- github.com/chenmuyao/go-bootcamp/internal/events/article
- github.com/chenmuyao/go-bootcamp/internal/integration/startup
- github.com/chenmuyao/go-bootcamp/ioc
- github.com/chenmuyao/go-bootcamp/pkg/saramax
- github.com/chenrui333/terraformer/providers/kafka
- github.com/choveylee/tdb
- github.com/chrislusf/gleam/plugins/kafka
- github.com/chunhui2001/zero4go/pkg/gkafka
- github.com/ciaranRoche/heimdall-go/provider/kafka
- github.com/ciazhar/go-kafka-example/pkg/kafka
- github.com/cisco-open/go-lanai/pkg/kafka
- github.com/claudiunicolaa/blockchain-monitoring/internal/monitor
- github.com/cloudflare/bbmp2kafka
- github.com/cloudintegrator/go-sonic-kafka-connector/pkg/listener
- github.com/cloudoperators/opentelemetry-collector-contrib/internal/kafka
- github.com/clunc/hr-monitor-ble-server
- github.com/cnsync/simple-game/eventbus/kafka/v2
- github.com/code-sigs/go-box/pkg/kafka
- github.com/codedog2001/webook/interactive/events
- github.com/codedog2001/webook/interactive/intergration/startup
- github.com/codedog2001/webook/interactive/ioc
- github.com/codedog2001/webook/internal/events/article
- github.com/codedog2001/webook/internal/intergration/startup
- github.com/codedog2001/webook/ioc
- github.com/codedog2001/webook/pkg/samarax
- github.com/codesjoy/pkg/basic/xevent/kafka
- github.com/codesjoy/pkg/basic/xkafka
- github.com/codesjoy/pkg/basic/xkafka/internal/primitives/router
- github.com/codesjoy/pkg/basic/xkafka/internal/runtime/group
- github.com/codesjoy/pkg/basic/xkafka/internal/runtime/partition
- github.com/codesjoy/pkg/basic/xkafka/internal/transport/sarama
- github.com/codesjoy/pkg/basic/xkafka/middleware/consume
- github.com/codesjoy/pkg/basic/xkafka/middleware/consume/retry
- github.com/codesjoy/pkg/basic/xkafka/middleware/consume/trace
- github.com/codesjoy/pkg/basic/xkafka/middleware/produce
- github.com/codesjoy/pkg/basic/xkafka/middleware/produce/trace
- github.com/codingWhat/armory/mq/kafka/snippet/consumer/entity
- github.com/codingWhat/armory/mq/kafka/snippet/parallel_consume
- github.com/codingWhat/armory/mq/kafka/snippet/parallel_consume/test
- github.com/codingWhat/armory/mq/kafka/snippet/producer
- github.com/codingWhat/armory/mq/kafka/snippet/producer/entity
- github.com/cohenjo/replicator/pkg/streams
- github.com/common-go/kafka/sarama
- github.com/content-services/content-sources-backend/pkg/config
- github.com/contobox/orbita/internal/job
- github.com/coze-dev/coze-studio/backend/infra/eventbus/impl/kafka
- github.com/cozyo/fast-gin/pkg/mq
- github.com/cppuser/magaz/services/shop/user/cmd/api
- github.com/cqhasy/muxisdk/service
- github.com/creafly/outbox/strategies
- github.com/cripplemymind9/order-service/internal/pkg/kafka
- github.com/cryptkeeperhq/cryptkeeper/internal/messaging/kafka
- github.com/ctl-homasy/pkg/kafka
- github.com/ctl5563096/base/library
- github.com/ctrl-hub/franz/internal
- github.com/cvanh/camscraper/scrapers/klimwinkel
- github.com/cxb116/sspEngine/examples/kafkaConsumer
- github.com/cygy/ginamite/common/kafka
- github.com/daheige/athena/internal/infras/prioritymq/gkafka
- github.com/daidai53/webook/feed/events
- github.com/daidai53/webook/follow/events
- github.com/daidai53/webook/interactive/events
- github.com/daidai53/webook/interactive/ioc
- github.com/daidai53/webook/internal/events/article
- github.com/daidai53/webook/internal/integration/startup
- github.com/daidai53/webook/ioc
- github.com/daidai53/webook/payment/events
- github.com/daidai53/webook/payment/ioc
- github.com/daidai53/webook/pkg/migrator/events
- github.com/daidai53/webook/pkg/migrator/events/fixer
- github.com/daidai53/webook/pkg/saramax
- github.com/daidai53/webook/reward/events
- github.com/daidai53/webook/search/events
- github.com/daidai53/webook/tag/events
- github.com/dalelane/grafana-kafka-datasource/pkg/kafka
- github.com/danielgospodinow/kinkang/cmd/kinkang
- github.com/danielqsj/kafka_exporter
- github.com/daobin/go-practice/mq
- github.com/darccio/dd-trace-go/v2/contrib/IBM/sarama.v1
- github.com/dataflow-operator/dataflow/internal/connectors
- github.com/davidsbond/autopgo/internal/event
- github.com/dawit-go/notification-kafka-lib/producer
- github.com/dawndist/dawn/v2/eventbus/kafka
- github.com/dcs4y/minoutil/v2/kafkaclient
- github.com/decadestory/goutil/logsvc
- github.com/delfimarime/fx/messaging
- github.com/denisovdev/go_kafka_sms_sender/producer/queue/kafka
- github.com/depost2024/go-frame/internal/components/kafka
- github.com/devchain-network/cauldron/cmd/githubconsumer
- github.com/devchain-network/cauldron/cmd/githubconsumergroup
- github.com/devchain-network/cauldron/cmd/gitlabconsumer
- github.com/devchain-network/cauldron/cmd/gitlabconsumergroup
- github.com/devchain-network/cauldron/cmd/webhookserver
- github.com/devchain-network/cauldron/internal/kafkacp/kafkaconsumer
- github.com/devchain-network/cauldron/internal/kafkacp/kafkaconsumergroup
- github.com/devchain-network/cauldron/internal/kafkacp/kafkaproducer
- github.com/devchain-network/cauldron/internal/storage
- github.com/devchain-network/cauldron/internal/storage/githubstorage
- github.com/devchain-network/cauldron/internal/storage/gitlabstorage
- github.com/devchain-network/cauldron/internal/transport/http/githubwebhookhandler
- github.com/devchain-network/cauldron/internal/transport/http/gitlabwebhookhandler
- github.com/deviceinsight/kafkactl/v5/internal
- github.com/deviceinsight/kafkactl/v5/internal/acl
- github.com/deviceinsight/kafkactl/v5/internal/auth
- github.com/deviceinsight/kafkactl/v5/internal/broker
- github.com/deviceinsight/kafkactl/v5/internal/consume
- github.com/deviceinsight/kafkactl/v5/internal/consumergroupoffsets
- github.com/deviceinsight/kafkactl/v5/internal/consumergroups
- github.com/deviceinsight/kafkactl/v5/internal/output
- github.com/deviceinsight/kafkactl/v5/internal/partition
- github.com/deviceinsight/kafkactl/v5/internal/producer
- github.com/deviceinsight/kafkactl/v5/internal/testutil
- github.com/deviceinsight/kafkactl/v5/internal/topic
- github.com/deviceinsight/kafkactl/v5/internal/user
- github.com/devops-360-online/go-with-me/internal/repositories
- github.com/devopsext/events/output
- github.com/dfg007star/go_rocket/order/internal/app
- github.com/dfg007star/go_rocket/order/internal/config
- github.com/dfg007star/go_rocket/order/internal/config/env
- github.com/dfg007star/go_rocket/order/internal/config/mocks
- github.com/dfg007star/go_rocket/platform/pkg/kafka/consumer
- github.com/dfg007star/go_rocket/platform/pkg/kafka/producer
- github.com/dgraph-io/dgraph/v25/worker
- github.com/diamond-bullet/golangpractice/demo/kafka/kafka_single
- github.com/digitalysin/kafka-stream
- github.com/distribworks/dkron/v4/builtin/bins/dkron-executor-kafka
- github.com/djosh34/kafaux
- github.com/dobyte/due/eventbus/kafka/v2
- github.com/domesama/kafkawrapper
- github.com/dr4tinymous/audit
- github.com/drip-in/eden_lib/pubsub
- github.com/duanhf2012/origin/v2/sysmodule/kafkamodule
- github.com/ducanhpham0312/zeevision/backend/internal/consumer
- github.com/easynet-cn/log-agent/object
- github.com/eclipse-xfsc/cloud-event-provider
- github.com/ecodeclub/notify-go/queue/kafka
- github.com/edgeflare/pigo/pkg/pipeline/peer/kafka
- github.com/edorguez/payment-reminder/pkg/kafka
- github.com/edu3dw4rd/kafka-cli
- github.com/ehsaniara/delay-box/config
- github.com/ehsaniara/delay-box/core
- github.com/ehsaniara/delay-box/interfaces
- github.com/ehsaniara/delay-box/interfaces/interfacesfakes
- github.com/ehsaniara/delay-box/kafka
- github.com/ehsaniara/delay-box/kafka/kafkafakes
- github.com/ehsaniara/delay-box/worker
- github.com/ehsaniara/delay-box/worker/workerfakes
- github.com/einherij/enterprise/db/message_queue
- github.com/eladleev/schema-registry-statistics
- github.com/elastic/stream/internal/output/kafka
- github.com/empso11/marmota/pkg/mq
- github.com/encountea/message-service/internal/kafka
- github.com/energostack/bisquitt-psk/pkg/reader
- github.com/eolinker/apinto/drivers/output/kafka
- github.com/erain9/matchingo/pkg/db/queue
- github.com/erickim65/abango
- github.com/ethpandaops/xatu/pkg/output/kafka
- github.com/etloreq/yandex-practicum-arch-tasks/sprint3/microservice-devices/internal/producer
- github.com/everpan/idig/pkg/event/kafka
- github.com/exadevt/go-commont/events
- github.com/execaus/equi_genea_broker_client
- github.com/faciam-dev/gcfm/internal/events
- github.com/fajaramaulana/go-micro-kafka/go-micro-kafka-consumer
- github.com/fajaramaulana/go-micro-kafka/go-micro-kafka-consumer/config
- github.com/fajaramaulana/go-micro-kafka/go-micro-kafka-consumer/mocks
- github.com/fajaramaulana/go-micro-kafka/go-micro-kafka-producer/config
- github.com/fajaramaulana/go-micro-kafka/go-micro-kafka-producer/kafkaconfig
- github.com/fankane/go-utils/plugin/queue/kafka
- github.com/faridgh1991/samsa
- github.com/fclairamb/solidping/server/internal/checkers/checkkafka
- github.com/fedibessrour-bce/sasl/oauthbearer
- github.com/felix-186/sdk-go/conn/mq
- github.com/fhmq/hmq/plugins/bridge
- github.com/filatkinen/distr-transactions/internal/domen/notification/service
- github.com/filatkinen/distr-transactions/internal/domen/orderflow/service
- github.com/filatkinen/distr-transactions/internal/domen/orderservice/service
- github.com/filatkinen/distr-transactions/internal/domen/payment/service
- github.com/filatkinen/distr-transactions/internal/domen/warehouse/service
- github.com/filatkinen/distr-transactions/internal/kafka
- github.com/flashhhhh/pkg/kafka
- github.com/fleezesd/kafka-example/http_server
- github.com/forbearing/gst/provider/kafka
- github.com/forgocode/family/pkg/kafka
- github.com/forhadulislam/learn-go-with-examples/40-kafka/client
- github.com/formancehq/stack/libs/go-libs/publish
- github.com/fortnoxab/renovator/pkg/kafka
- github.com/foxdalas/flagr/pkg/handler
- github.com/frhnfrnk/blog-platform-microservices/notification-service/internal/kafka
- github.com/frisky1985/yuleDKCS/backend/dkcs/internal/mq
- github.com/fsvxavier/nexs-lib/shutdown/examples/sarama/complete
- github.com/fsvxavier/nexs-lib/shutdown/examples/sarama/consumer
- github.com/fsvxavier/nexs-lib/shutdown/examples/sarama/producer_async
- github.com/fsvxavier/nexs-lib/shutdown/examples/sarama/producer_sync
- github.com/fsvxavier/nexs-lib/shutdown/resources
- github.com/fujiwara/kt/v14
- github.com/gaara1994/tool/cmd
- github.com/gagraler/alert-service/pkg/logger
- github.com/geniusrabbit/notificationcenter/v2/kafka
- github.com/gevinzone/basic-go/week7/webook/internal/events/article
- github.com/gevinzone/basic-go/week7/webook/ioc
- github.com/gevinzone/basic-go/week7/webook/pkg/saramax
- github.com/gevinzone/basic-go/week9/webook/internal/events/article
- github.com/gevinzone/basic-go/week9/webook/ioc
- github.com/gevinzone/basic-go/week9/webook/pkg/saramax
- github.com/gfzwh/gfz/kafka
- github.com/giacomoda/msk_test/server
- github.com/gif-gif/go.io/go-mq/go-kafka
- github.com/gnanasuryateja/golib/datastore/messaging_queue/kafka
- github.com/go-anyway/framework-messagequeue
- github.com/go-dev-frame/sponge/pkg/kafka
- github.com/go-eagle/eagle/pkg/queue/kafka
- github.com/go-god/broker/gkafka
- github.com/go-graphite/go-carbon/receiver/kafka
- github.com/go-juno/kit/kafka
- github.com/go-keg/keg/contrib/kafka
- github.com/go-leo/project-layout/pkg/kafkax
- github.com/go-magic/rook/pkg/api/mkafka
- github.com/go-milli/go-milli/broker/kafka
- github.com/go-sigma/sigma/pkg/modules/workq/kafka
- github.com/go-slark/infra/kafka
- github.com/godamri/helix-sdk/messaging
- github.com/gofish2020/easydispatch/heart/kafka
- github.com/goinline/agent/mq/kafka/sarama
- github.com/golovin-a/KafkaLog/tools/kafka
- github.com/gone-io/goner/mq/kafka
- github.com/goodluck0107/gcore/geventbus/kafka
- github.com/gorelov-m-v/go-test-framework/internal/kafka/consumer
- github.com/gospacex/coordx/observability
- github.com/gospacex/gospacex/core/storage/mq/kafka
- github.com/gospacex/logger
- github.com/goto/meteor/plugins/extractors/kafka
- github.com/grafana/alloy/integration-tests/docker/configs/kafka
- github.com/grafana/alloy/internal/component/loki/source/azure_event_hubs
- github.com/grafana/alloy/internal/component/loki/source/azure_event_hubs/internal/parser
- github.com/grafana/alloy/internal/component/loki/source/internal/kafkatarget
- github.com/grafana/alloy/internal/component/loki/source/kafka
- github.com/grafana/alloy/internal/component/prometheus/exporter/kafka
- github.com/grafana/alloy/internal/loki/promtail/scrapeconfig
- github.com/grafana/alloy/internal/static/integrations/kafka_exporter
- github.com/grafana/carbon-relay-ng/route
- github.com/grpc-kit/pkg/cfg
- github.com/guigateixeira/general-auth/kafka
- github.com/hackertron/blocksight/internal/kafka
- github.com/hailsayan/sophocles/pkg/database
- github.com/half-coconut/gocopilot/core-engine/interactive/events
- github.com/half-coconut/gocopilot/core-engine/interactive/ioc
- github.com/half-coconut/gocopilot/core-engine/internal/events/note
- github.com/half-coconut/gocopilot/core-engine/internal/events/report
- github.com/half-coconut/gocopilot/core-engine/ioc
- github.com/half-coconut/gocopilot/core-engine/pkg/saramax
- github.com/halimdotnet/gotesorow/internal/pkg/events/kafkasrm
- github.com/happywbfriends/metrics/examples
- github.com/harisatul/skr-mono/feature/leaderboard
- github.com/harmonic-lqw/webook-interactive/events
- github.com/harmonify/movie-reservation-system/pkg/kafka
- github.com/harmonify/movie-reservation-system/pkg/kafka/test
- github.com/harmonify/movie-reservation-system/pkg/kafka/watermill
- github.com/harmonify/movie-reservation-system/pkg/mocks
- github.com/harmonify/movie-reservation-system/pkg/tracer/carrier
- github.com/harphies/go.microservices.io/messaging/kafka
- github.com/hasansino/go42/internal/events/kafka
- github.com/hdget/hdsdk/provider/mq/kafka
- github.com/helays/utils/close/kafkaClose
- github.com/helays/utils/db/kafka
- github.com/helays/utils/message/pubsub/kafkaHander
- github.com/helays/utils/v2/close/kafkaClose
- github.com/helays/utils/v2/db/kafka
- github.com/helays/utils/v2/db/kafka/clientconf
- github.com/helays/utils/v2/message/pubsub/kafkaHander
- github.com/hell-walker/enterprise/db/message_queue
- github.com/helloh2o/lucky/dac
- github.com/hentan/final_project/internal/kafka
- github.com/hesoyamTM/apphelper-sso/internal/clients/redpanda
- github.com/hespecial/gin-mall/internal/repository/kafka
- github.com/hfup/sunny/components/mqs
- github.com/hgg-6/pkgTool/v2/DBx/mysqlX/gormx/dbMovex/myMovex/messageQueue/consumerx
- github.com/hgg-6/pkgTool/v2/channelx/messageQueuex/saramax/saramaConsumerx
- github.com/hgg-6/pkgTool/v2/channelx/messageQueuex/saramax/saramaConsumerx/ConsumerGroupHandlerx
- github.com/hgg-6/pkgTool/v2/channelx/messageQueuex/saramax/saramaConsumerx/serviceLogic
- github.com/hgg-6/pkgTool/v2/channelx/messageQueuex/saramax/saramaProducerx
- github.com/hgg-6/pkgTool/v2/channelx/mqX/kafkaX/saramaX/consumerX
- github.com/hgg-6/pkgTool/v2/channelx/mqX/kafkaX/saramaX/producerX
- github.com/hjoshi123/fintel/infra/pubsub
- github.com/hodgesds/dlg/executor/kafka
- github.com/homasy/pkg/kafka
- github.com/horizon-connect-eu/go-taf/plugins/communication/kafkabased
- github.com/huangyul/go-webook/interactive/events
- github.com/huangyul/go-webook/interactive/ioc
- github.com/huangyul/go-webook/internal/events
- github.com/huangyul/go-webook/internal/events/article
- github.com/huangyul/go-webook/internal/events/history
- github.com/huangyul/go-webook/ioc
- github.com/huangyul/go-webook/pkg/saramax
- github.com/hudangwei/common/kafka
- github.com/hungle45/gokit/tonic/health/check
- github.com/hussammohammed/marketplace-go-microservices/gateway/messageBroker
- github.com/hussammohammed/marketplace-go-microservices/gateway/servicesHandlers/order
- github.com/hussammohammed/marketplace-go-microservices/microservices/order/internal/controller
- github.com/hussammohammed/marketplace-go-microservices/microservices/order/internal/messageBroker
- github.com/hussammohammed/marketplace-go-microservices/microservices/order/internal/service
- github.com/hydroan/gst/provider/kafka
- github.com/hyetpang/go-frame/internal/components/kafka
- github.com/hypermodeinc/dgraph/v24/worker
- github.com/i101dev/gRPC-kafka-eCommerce/kafka
- github.com/iSparshP/product-management-system/internal/infrastructure/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter04/bookingservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter04/eventservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter04/lib/helper/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter04/lib/msgqueue/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter05/bookingservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter05/eventservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter05/lib/helper/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter05/lib/msgqueue/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter06/bookingservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter06/eventservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter06/lib/helper/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter06/lib/msgqueue/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter09/bookingservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter09/eventservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter09/lib/helper/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter09/lib/msgqueue/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter10/bookingservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter10/eventservice
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter10/lib/helper/kafka
- github.com/ibiscum/Cloud-Native-Programming-with-Golang/chapter10/lib/msgqueue/kafka
- github.com/ibiscum/Go-Programming-Cookbook-Second-Edition/chapter12/asynckafka/consumer
- github.com/ibiscum/Go-Programming-Cookbook-Second-Edition/chapter12/asynckafka/producer
- github.com/ibiscum/Go-Programming-Cookbook-Second-Edition/chapter12/kafkaflow/consumer
- github.com/ibiscum/Go-Programming-Cookbook-Second-Edition/chapter12/kafkaflow/producer
- github.com/ibiscum/Go-Programming-Cookbook-Second-Edition/chapter12/synckafka/consumer
- github.com/ibiscum/Go-Programming-Cookbook-Second-Edition/chapter12/synckafka/producer
- github.com/ibrahimker/golang-praisindo-advanced/session-20-introduction-kafka-gin/cmd/consumer
- github.com/ibrahimker/golang-praisindo-advanced/session-20-introduction-kafka-gin/cmd/producer
- github.com/ibrahimker/golang-praisindo-advanced/session-20-introduction-kafka/consumer
- github.com/ibrahimker/golang-praisindo-advanced/session-20-introduction-kafka/producer
- github.com/ibrahimker/golang-praisindo-advanced/session-21-latihan-cqrs
- github.com/ibrahimker/golang-praisindo-advanced/session-21-latihan-cqrs/consumer/read_db_inserter
- github.com/ibrahimker/golang-praisindo-advanced/session-21-latihan-cqrs/consumer/write_db_inserter
- github.com/ibrahimker/golang-praisindo-advanced/session-21-latihan-cqrs/handler
- github.com/ig0rmin/ich/internal/kafka
- github.com/ig6gzu/biz_exporter
- github.com/ilkerkorkut/go-examples/microservice/observability/internal/logging
- github.com/imind-lab/micro/v2/broker
- github.com/imkerbos/mxsec-platform/internal/server/agentcenter/commandsub
- github.com/imkerbos/mxsec-platform/internal/server/common/kafka
- github.com/imkerbos/mxsec-platform/internal/server/consumer
- github.com/imkerbos/mxsec-platform/internal/server/engine
- github.com/imkerbos/mxsec-platform/internal/server/engine/scheduler
- github.com/imkerbos/mxsec-platform/internal/server/llmproxy/audit
- github.com/imkerbos/mxsec-platform/internal/server/manager/api
- github.com/imkerbos/mxsec-platform/internal/server/vulnsync/publisher
- github.com/imonja/pkg/kafka/sarama
- github.com/impoliteblind/kafka-config-metrics/pkg/kafka
- github.com/informeai/go-kafka/internal
- github.com/ink-yht-code/gint/mq/kafka
- github.com/innovafour/kafka
- github.com/intelops/qualitytrace/agent/workers/trigger/kafka
- github.com/irvingos/go-tools/kafka
- github.com/isimtekin/go-packages/kafka-client
- github.com/ivan-zherdev/benthos/v4/internal/impl/kafka
- github.com/izetmolla/drivers/kafka
- github.com/izzanzahrial/skeleton/internal/domain/post/broker
- github.com/jacksonbarreto/WebGateScanner-DNSSECAnalyzer/internal/groupHandler
- github.com/jacksonbarreto/WebGateScanner-stls/internal/groupHandler
- github.com/jacksonbarreto/WebGateScanner/DNSSECAnalyzer/internal/consumer
- github.com/jacksonbarreto/WebGateScanner/DNSSECAnalyzer/internal/groupHandler
- github.com/jacksonbarreto/WebGateScanner/DNSSECAnalyzer/internal/producer
- github.com/jacksonbarreto/WebGateScanner/pkg/kafka/consumer
- github.com/jacksonbarreto/WebGateScanner/pkg/kafka/producer
- github.com/jacksonbarreto/WebGateScanner/sadi/internal/consumer
- github.com/jacksonbarreto/WebGateScanner/stls/internal/consumer
- github.com/jacksonbarreto/sadi/internal/consumer
- github.com/jacksonbarreto/webgatescanner/DNSSECAnalyzer/internal/groupHandler
- github.com/jacksonbarreto/webgatescanner/pkg/kafka/consumer
- github.com/jacksonbarreto/webgatescanner/pkg/kafka/producer
- github.com/jacksonbarreto/webgatescanner/sadi/internal/consumer
- github.com/jacksonbarreto/webgatescanner/stls/internal/consumer
- github.com/jalapeno-api-gateway/jagw/pkg/messages
- github.com/jasmine-nguyen/go-microservices/money_movement/internal/producer
- github.com/jayleonc/geektime-go/webook/follow/events
- github.com/jayleonc/geektime-go/webook/interactive/events
- github.com/jayleonc/geektime-go/webook/interactive/events/prometheus
- github.com/jayleonc/geektime-go/webook/interactive/integration/startup
- github.com/jayleonc/geektime-go/webook/interactive/ioc
- github.com/jayleonc/geektime-go/webook/internal/events/article
- github.com/jayleonc/geektime-go/webook/internal/integration/startup
- github.com/jayleonc/geektime-go/webook/internal/service/sms/async
- github.com/jayleonc/geektime-go/webook/ioc
- github.com/jayleonc/geektime-go/webook/pkg/migrator/events/fixer
- github.com/jayleonc/geektime-go/webook/pkg/migrator/events/producer
- github.com/jayleonc/geektime-go/webook/pkg/saramax
- github.com/jayleonc/geektime-go/websocket/simple
- github.com/jdrews/go-tailer
- github.com/jeevansurendran/kcopy
- github.com/jifuy/commongo/mq/kafka
- github.com/jjauzion/zolamy-go/kfk
- github.com/joaoasantana/e-inventory-service/pkg/conn
- github.com/joaoprofile/gofi/msq/provider/kafka
- github.com/jokopitoyosby/messages-broker/consumer
- github.com/jonathanface/storm-reporter/API
- github.com/jordanmarcelino/learn-go-microservices/order-service/internal/mq
- github.com/jordanmarcelino/learn-go-microservices/order-service/internal/provider
- github.com/jordanmarcelino/learn-go-microservices/pkg/database
- github.com/jordanmarcelino/learn-go-microservices/product-service/internal/mq
- github.com/jordanmarcelino/learn-go-microservices/product-service/internal/provider
- github.com/joshuaunity/mmc_core/utils
- github.com/julesChu12/fly/mora/pkg/mq
- github.com/jwebb1334/fission/pkg/mqtrigger/messageQueue/kafka
- github.com/kanapuli/mcp-kafka/kafka
- github.com/kenjones-cisco/logrus-kafka-hook
- github.com/kevinu2/ngo/v2/pkgs/Mq/KafkaMq
- github.com/khan-lau/kmq-utils/kafkamq
- github.com/khasmag06/effective-mobile-test/pkg/kafka
- github.com/kiin21/go-rest/internal/shared/infrastructure/messagebroker/kafka
- github.com/kingstonduy/go-core/transport/broker/kafka
- github.com/kirill-a-belov/test_task_framework/internal/app/kafka
- github.com/kitanoyoru/kita/apps/email/pkg/events
- github.com/kkangxu/himlad-magic/microservice
- github.com/ksolj/ongaku-api/cmd/api
- github.com/kubescape/kubescape-network-scanner/pkg/networkscanner/servicediscovery/applicationlayerdiscovery
- github.com/kuoss/eventrouter/sinks
- github.com/kweaver-ai/dsg/services/apps/configuration-center/domain/info_system/impl
- github.com/kweaver-ai/dsg/services/apps/configuration-center/infrastructure/mq/kafka
- github.com/kweaver-ai/dsg/services/apps/data-semantic/consumer/internal/handler
- github.com/kweaver-ai/dsg/services/apps/data-semantic/consumer/internal/logic
- github.com/kweaver-ai/dsg/services/apps/task_center/adapter/driven/mq/kafka
- github.com/kweaver-ai/dsg/services/apps/task_center/common/settings
- github.com/kweaver-ai/dsg/services/apps/task_center/domain/work_order_task
- github.com/kweaver-ai/idrm-go-frame/core/transport/kq/kafka
- github.com/kweaver-ai/kweaver-go-lib/audit
- github.com/l0slaker/webook/interactive/events
- github.com/l0slaker/webook/interactive/ioc
- github.com/l0slaker/webook/internal/events/article
- github.com/l0slaker/webook/internal/integration/startup
- github.com/l0slaker/webook/ioc
- github.com/l0slaker/webook/pkg/migrator/events
- github.com/l0slaker/webook/pkg/migrator/events/fixer
- github.com/l0slaker/webook/pkg/saramax
- github.com/last-ent/kafkexp
- github.com/last9/go-agent/integrations/kafka
- github.com/leeliliang/transportWraper/transport/kafka
- github.com/lenhattri/kaeshi-migrate/pkg/logger
- github.com/leonvanderhaeghen/stockplatform/services/orderSvc/internal/infrastructure/kafka
- github.com/lep13/messaging-notification-service/kafka
- github.com/liangma499/xbase/eventbus/kafka
- github.com/limerence-code/goproject/middleware/cdc
- github.com/limingyao/excellent-go/pkg/kafka
- github.com/liony823/tools/mq/kafka
- github.com/liqiongtao/googo.io/goo-kafka
- github.com/liserc/openchat-tools/mq/kafka
- github.com/liumingmin/goutils/db/kafka
- github.com/liupch66/basic-go/webook/interact/events
- github.com/liupch66/basic-go/webook/interact/ioc
- github.com/liupch66/basic-go/webook/internal/events/article
- github.com/liupch66/basic-go/webook/internal/integration/startup
- github.com/liupch66/basic-go/webook/ioc
- github.com/liupch66/basic-go/webook/pkg/migrator/events
- github.com/liupch66/basic-go/webook/pkg/migrator/events/fixer
- github.com/liupch66/basic-go/webook/pkg/saramax
- github.com/llamadeus/ebike3/packages/shared/micro
- github.com/lll8c/webook/interactive/events
- github.com/lll8c/webook/interactive/integration/startup
- github.com/lll8c/webook/interactive/ioc
- github.com/lll8c/webook/internal/events/article
- github.com/lll8c/webook/ioc
- github.com/lll8c/webook/payment/events
- github.com/lll8c/webook/payment/ioc
- github.com/lll8c/webook/pkg/migrator/events
- github.com/lll8c/webook/pkg/migrator/events/fixer
- github.com/lll8c/webook/pkg/saramax
- github.com/lll8c/webook/reward/events
- github.com/lockp111/go-easykafka
- github.com/logi-camp/go-streams/kafka
- github.com/lookandhate/course_platform_lib/pkg/message_queue/kafka/client/consumer
- github.com/losfair/hgw/homegw-libs/kafka-sink
- github.com/lowl11/boost/pkg/web/kafka
- github.com/lowl11/boost2/data/types
- github.com/lowl11/boost2/internal/infrastructure/logger
- github.com/lowl11/boost2/internal/kafka/async_producer
- github.com/lowl11/boost2/internal/kafka/consumer
- github.com/lowl11/boost2/internal/kafka/consumer_group
- github.com/lowl11/boost2/internal/kafka/sync_producer
- github.com/lowl11/boost2/pkg/kafka/configurator
- github.com/lucaskatayama/learn-hexagonal/go/pkg/kafka
- github.com/lucky/murmur2-partitioner-go/partitioner
- github.com/lukmanlukmin/go-lib/kafka
- github.com/luno/workflow/adapters/kafkastreamer
- github.com/luongduc1246/ultility/broker
- github.com/luvx21/coding-go/coding-usage/mq/kafka
- github.com/lyb88999/PortScan/internal/kafka
- github.com/lyy42995004/IM-Go/internal/kafka
- github.com/m1kr0b/message-processing/internal/kafka
- github.com/maard/kafkautil
- github.com/madcok-co/unicorn/contrib/broker/kafka
- github.com/maksadbek/statsfornba/pkg/platform/kafka
- github.com/manas012003/go-kafka-redis-webserver
- github.com/mannulus-immortalis/xmtask/internal/kafka
- github.com/marinaaaniram/go-auth/cmd/kafka_consumer
- github.com/marinaaaniram/go-auth/cmd/kafka_producer
- github.com/marinaaaniram/go-auth/internal/app
- github.com/marinaaaniram/go-auth/internal/client/kafka/consumer
- github.com/marinaaaniram/go-auth/internal/client/kafka/producer
- github.com/marinaaaniram/go-auth/internal/config
- github.com/marinaaaniram/go-auth/internal/config/env
- github.com/marinaaaniram/go-auth/internal/service/consumer
- github.com/martketplace-vkr/pkg/inbox
- github.com/martketplace-vkr/pkg/inbox/internal/provider/kafka
- github.com/martketplace-vkr/pkg/kafka
- github.com/martketplace-vkr/pkg/kafka-distributor
- github.com/martketplace-vkr/pkg/kafka-distributor/distributor
- github.com/martketplace-vkr/pkg/kafkaconnector
- github.com/martketplace-vkr/pkg/outbox
- github.com/martketplace-vkr/pkg/outbox/internal/broker/kafka
- github.com/max-kriv0s/go-microservices-edu/order/internal/app
- github.com/max-kriv0s/go-microservices-edu/order/internal/config
- github.com/max-kriv0s/go-microservices-edu/order/internal/config/env
- github.com/max-kriv0s/go-microservices-edu/platform/pkg/kafka/consumer
- github.com/max-kriv0s/go-microservices-edu/platform/pkg/kafka/producer
- github.com/mbakhodurov/examples/week_5/kafka/clean_arch/ufo/cmd/consumer
- github.com/mbakhodurov/examples/week_5/kafka/clean_arch/ufo/internal/app
- github.com/mbakhodurov/examples/week_5/kafka/clean_arch/ufo/internal/config
- github.com/mbakhodurov/examples/week_5/kafka/clean_arch/ufo/internal/config/env
- github.com/mbakhodurov/homeworks/week5/order/internal/app
- github.com/mbakhodurov/homeworks/week5/order/internal/config
- github.com/mbakhodurov/homeworks/week5/order/internal/config/env
- github.com/mbakhodurov/homeworks/week6/assembly/internal/app
- github.com/mbakhodurov/homeworks/week6/assembly/internal/config
- github.com/mbakhodurov/homeworks/week6/assembly/internal/config/env
- github.com/mbakhodurov/homeworks/week6/platform/pkg/kafka/consumer
- github.com/mbakhodurov/homeworks/week6/platform/pkg/kafka/producer
- github.com/megaease/access-log-go/accesslog/eventhub
- github.com/meidada2464/gostudy/Kafka_sarama_test/producer
- github.com/meoying/local-msg-go
- github.com/meoying/local-msg-go/example/monitor
- github.com/meoying/local-msg-go/example/no_sharding
- github.com/meoying/local-msg-go/example/trace_no_sharding
- github.com/meoying/local-msg-go/internal/admin/service
- github.com/meoying/local-msg-go/internal/service
- github.com/meoying/local-msg-go/internal/test/mocks
- github.com/meristalis/tg-bot-notes/pkg/kafka/producer
- github.com/micro-plat/hydra/components/queues/mq/kafka
- github.com/mildsunup/higo/mq/kafka
- github.com/mingrammer/sarama/examples/http_server
- github.com/mingrammer/sarama/examples/sasl_scram_client
- github.com/mingrammer/sarama/mocks
- github.com/mingrammer/sarama/tools/kafka-console-consumer
- github.com/mingrammer/sarama/tools/kafka-console-partitionconsumer
- github.com/mingrammer/sarama/tools/kafka-console-producer
- github.com/mingrammer/sarama/tools/kafka-producer-performance
- github.com/minhvuongrbs/webhook-service/pkg/kafka
- github.com/mirkobrombin/go-warp/v1/syncbus/kafka
- github.com/misakimei123/redbook/interactive/events
- github.com/misakimei123/redbook/interactive/ioc
- github.com/misakimei123/redbook/internal/events/article
- github.com/misakimei123/redbook/internal/integration/startup
- github.com/misakimei123/redbook/ioc
- github.com/misakimei123/redbook/pkg/migrator/events
- github.com/misakimei123/redbook/pkg/migrator/events/fixer
- github.com/misakimei123/redbook/pkg/saramax
- github.com/mmtbak/microlibrary/mq
- github.com/mohammad-siraj/hexarchgo/internal/libs/eventbroker
- github.com/moistoctopus/kafka-config-metrics/pkg/kafka
- github.com/molast/crawler-core/common/kafka
- github.com/mooncake9527/durian/pkg/kafka
- github.com/moweilong/milady/pkg/kafka
- github.com/mrasu/echoed/create-echoed/template/base/example/opentelemetry-demo-override/src/checkoutservice
- github.com/mstgnz/cronjob/pkg/conn
- github.com/muxi-Infra/auditor-Backend/sdk/v1/webhook
- github.com/n-r-w/itestkit/queue/kafkaproducer
- github.com/narendra121/pkghub/pub-sub/kafka-pkg
- github.com/nastyazhadan/spot-order-grpc/orderService/internal/application/order
- github.com/nastyazhadan/spot-order-grpc/shared/infrastructure/kafka/consumer
- github.com/nastyazhadan/spot-order-grpc/shared/infrastructure/kafka/producer
- github.com/nastyazhadan/spot-order-grpc/spotService/internal/application/spot
- github.com/neflyte/gowait/waiter
- github.com/nehal119/benthos-119/pkg/impl/kafka
- github.com/ngoctb13/seta-train/shared-modules/infra/kafka
- github.com/nibbleshift/blobfish/impl/kafka
- github.com/nik19ta/gostat/api_service/internal/stats/service
- github.com/nik19ta/gostat/api_service/pkg/kafka
- github.com/nik19ta/gostat/mail_service/cmd/mail
- github.com/nik19ta/gostat/mail_service/internal/mail/delivery/kafka
- github.com/nik19ta/gostat/mail_service/pkg/kafka_listener
- github.com/nik19ta/gostat/stats_service/cmd/api_stats
- github.com/nik19ta/gostat/stats_service/internal/stats/delivery/kafka
- github.com/nik19ta/gostat/stats_service/pkg/kafka
- github.com/nik19ta/gostat/stats_service/pkg/kafka_listener
- github.com/niksahn/diploma-go-kafka
- github.com/niudaii/goutil/kafka
- github.com/nkolesnikov999/micro2-OK/order/internal/app
- github.com/nkolesnikov999/micro2-OK/order/internal/config
- github.com/nkolesnikov999/micro2-OK/order/internal/config/env
- github.com/nkolesnikov999/micro2-OK/order/internal/config/mocks
- github.com/nkolesnikov999/micro2-OK/platform/pkg/kafka/consumer
- github.com/nkolesnikov999/micro2-OK/platform/pkg/kafka/producer
- github.com/nocturna-ta/golib/event/kafka
- github.com/nodelike/chronos-gateway/internal/services
- github.com/notopia-uit/notopia/pkg/otel
- github.com/novando/go-ska/pkg/mq/kafka
- github.com/nowfred/dd-trace-go/contrib/IBM/sarama.v1
- github.com/ntentasd/nostradamus-api/internal/kafka
- github.com/nucleuskit/bridge/sarama
- github.com/nxdir-s/idlerpg/internal/adapters/secondary
- github.com/nxsre/logrus-kafka-hook
- github.com/obaydullahmhs/kafka-dump/pkg/kafka
- github.com/obaydullahmhs/kafka-producer/pkg/producer
- github.com/obse4/goCommon/kafka
- github.com/obstor/obstor/pkg/event/target
- github.com/oktopriima/marvel/pkg/kafka
- github.com/olad5/kafka-sheet-processor/broker/kafka
- github.com/olezhek28/microservices_course/week_5/clean_kafka/cmd/producer
- github.com/olezhek28/microservices_course/week_5/clean_kafka/internal/app
- github.com/olezhek28/microservices_course/week_5/clean_kafka/internal/client/kafka/consumer
- github.com/olezhek28/microservices_course/week_5/clean_kafka/internal/config
- github.com/olezhek28/microservices_course/week_5/clean_kafka/internal/config/env
- github.com/olezhek28/microservices_course/week_5/clean_kafka/internal/service/consumer/note_saver
- github.com/olezhek28/microservices_course/week_5/cluster_kafka/cmd/consumer
- github.com/olezhek28/microservices_course/week_5/cluster_kafka/cmd/producer
- github.com/olezhek28/microservices_course/week_5/consumer_group_kafka/cmd/consumer
- github.com/olezhek28/microservices_course/week_5/consumer_group_kafka/cmd/producer
- github.com/olezhek28/microservices_course/week_5/easy_kafka/cmd/consumer
- github.com/olezhek28/microservices_course/week_5/easy_kafka/cmd/producer
- github.com/omran95/chat-app/pkg/infrastructure
- github.com/ondrejsika/counter/internal/backend_kafka
- github.com/onedaydev/myBank/banking-system/services/alarm/internal/kafka
- github.com/open-ch/franz/pkg/franz
- github.com/open-telemetry/opentelemetry-demo/src/accountingservice
- github.com/open-telemetry/opentelemetry-demo/src/accountingservice/kafka
- github.com/open-telemetry/opentelemetry-demo/src/checkout
- github.com/open-telemetry/opentelemetry-demo/src/checkout/kafka
- github.com/open-telemetry/opentelemetry-demo/src/checkoutservice
- github.com/open-telemetry/opentelemetry-demo/src/checkoutservice/kafka
- github.com/opencord/voltha-lib-go/v7/pkg/kafka
- github.com/opendevops-cn/codo-golang-sdk/kafka
- github.com/openimsdk/tools/mq/kafka
- github.com/openshift/eventrouter/sinks
- github.com/openzipkin/zipkin-go/reporter/kafka
- github.com/opisvigilant/futura/go-lib/stream
- github.com/origadmin/casbin-watcher/v3/drivers/kafka
- github.com/ovh/venom/executors/kafka
- github.com/p-society/gc-server/kafka
- github.com/p1lot/dropdetector/internal/kafka
- github.com/paaavkata/go-kafka
- github.com/palkx/vault-plugin-secrets-kafka
- github.com/pallat/doubles/dummies
- github.com/pandaychen/golang_in_action/sarama
- github.com/pankajvermacr7/go-kit/kafka
- github.com/pastequo/repoB/pkg/kafka
- github.com/patyukin/bs-auth/internal/queue/kafka
- github.com/pceric/kafka-offset-lag-for-prometheus
- github.com/pengenjago/gostack/pubsub
- github.com/phox/rknn-go/example/rtsp_mqtt
- github.com/pitimon/kafka-mylab-noted/kafka-log-producer-demo
- github.com/pocwithmehul/common-go-lib/pkg/kafka
- github.com/ppzoim/tools/mq/kafka
- github.com/prabhatdotdev/weave/transport/kafka
- github.com/prathameshbordwekar/log-client/logger
- github.com/praveenkumaresan/gogarage/cmd/partikey
- github.com/prchen818/ot-col-custom/cmd/kafka-consumer
- github.com/prilive-com/kafkasender/kafkasender
- github.com/prune998/kafka-offset-exporter
- github.com/pthethanh/nano/plugins/broker/kafka
- github.com/puneet105/job-queue/internal/queue
- github.com/qiafan666/gotato/mq/gkafka
- github.com/qianjisantech/gosmo
- github.com/qiaogw/pkg/logs
- github.com/qicgroupdoha/go-kit/queue/kafka
- github.com/qida/gohp/logx
- github.com/qingmk/common/server
- github.com/qishenonly/kafka
- github.com/qiushenglei/gin-skeleton/internal/app/data
- github.com/quangkhaidam93/go-web-server/example/kafka
- github.com/quangvu30/order-go/kafka
- github.com/quantonganh/blog/kafka
- github.com/quixio/telegraf/plugins/outputs/quix
- github.com/r27153733/ByteMoeOJ/app/moejudge/helper/mq
- github.com/radiophysiker/microservices-homework/homeworks/week5/boilerplates/kafka/consumer
- github.com/radiophysiker/microservices-homework/homeworks/week5/boilerplates/kafka/producer
- github.com/radiophysiker/microservices-homework/platform/pkg/kafka/consumer
- github.com/radiophysiker/microservices-homework/platform/pkg/kafka/producer
- github.com/rafaelsouzaribeiro/golang-broker/pkg/apache-kafka
- github.com/rafaelsouzaribeiro/listens-to-apache-kafka-golang/cmd/consumer
- github.com/rafaelsouzaribeiro/listens-to-apache-kafka-golang/cmd/producer
- github.com/rafaelsouzaribeiro/listens-to-apache-kafka-golang/pkg/utils/consumer
- github.com/rafaelsouzaribeiro/listens-to-apache-kafka-golang/pkg/utils/producer
- github.com/ranorsolutions/http-common-go/pkg/messaging/kafka
- github.com/raptor-ml/streaming-runner/internal/brokers/kafka
- github.com/rasadov/EcommerceAPI/order/cmd/order
- github.com/rasadov/EcommerceAPI/order/internal
- github.com/rasadov/EcommerceAPI/payment/cmd/payment
- github.com/rasadov/EcommerceAPI/payment/internal
- github.com/rasadov/EcommerceAPI/pkg/kafka
- github.com/rasadov/EcommerceAPI/product/cmd/product
- github.com/rasadov/EcommerceAPI/product/internal
- github.com/raystack/meteor/plugins/extractors/kafka
- github.com/rbaliyan/event/v3/transport/kafka
- github.com/realmicro/realmicro/broker/kafka/sarama
- github.com/redhajuanda/krangka/internal/adapter/outbound/kafka
- github.com/redpanda-data/connect/v4/internal/impl/kafka
- github.com/rermrf/emo/saramax
- github.com/restayway/gorm-pulse/extensions/kafka
- github.com/reugn/go-streams/examples/kafka
- github.com/rhythin/bookspot/services/shared/kafkaclient
- github.com/ribeirosaimon/motion-go/api/internal/akafka
- github.com/riyadennis/webservice_go/lib
- github.com/rocchen/tools/mq/kafka
- github.com/romanivanovminsk/kafka_helper
- github.com/romberli/go-util/middleware/kafka
- github.com/root-gg/kamux
- github.com/rootexit/rexLib/rexQueue
- github.com/routerarchitects/ra-common-mods/kafka
- github.com/rozhnof/auth-service/internal/infrastructure/kafka
- github.com/s0vunia/platform_common/pkg/kafka/consumer
- github.com/sainath123112/e-commerce-backend/user-service/internal/kafka
- github.com/samims/hcaas/pkg/tracing
- github.com/sanservices/kit/kafkalistener
- github.com/savin000/audit-log/internal/kafka
- github.com/sceyt/sceyt-collection-tools/pkg/kafka
- github.com/sea-go/sea-ridethewind/service/hot/rpc
- github.com/sea-go/sea-ridethewind/service/hot/rpc/internal/mqs
- github.com/sea-go/sea-ridethewind/service/hot/test/cmd/loadtest
- github.com/sea-go/sea-ridethewind/service/hot/test/cmd/producer
- github.com/sea-go/sea-ridethewind/service/task/rpc/internal/Init
- github.com/seedlings-calm/chat-kafka/internal/infrastructure/kafka
- github.com/serdarburakguneri/hobby-streamer/backend/pkg/events
- github.com/sergej-kurakin/http-to-kafka
- github.com/sergunya/social-platform/shared/events
- github.com/sgokul961/echo-hub-post-svc/pkg/helper
- github.com/sh3ll3y/promotion-service/internal/kafka
- github.com/shockerjue/gffg/kafka
- github.com/shockingspil/kafka-config-metrics/pkg/kafka
- github.com/sigmasee/sigmasee/shared/enterprise/messaging/kafka/sarama
- github.com/silves-xiang/data-bridge/plugins/kafka
- github.com/simonalong/gole-boot/extend/kafka
- github.com/sine-io/sinx/builtin/bins/sinx-executor-kafka
- github.com/sirius2001/loon/pkg/kaf
- github.com/sithu-go/abango
- github.com/sjmark/kafka
- github.com/skapfer/dd-trace-go/contrib/IBM/sarama.v1
- github.com/slam0504/go-ddd-adapters/eventbus/kafka
- github.com/slilp/go-saving-money-service/common/kafka
- github.com/smap-hcmut/shared-libs/go/kafka
- github.com/smart-echo/micro-plugins/broker/kafka
- github.com/smartim/tools/mq/kafka
- github.com/smartwalle/mx/kafka
- github.com/snetsystems/cloudhub/backend/kafka
- github.com/snowplow/snowbridge/pkg/common
- github.com/snowplow/snowbridge/pkg/source/kafka
- github.com/snowplow/snowbridge/pkg/target
- github.com/snowplow/snowbridge/v3/pkg/common
- github.com/snowplow/snowbridge/v3/pkg/source/kafka
- github.com/snowplow/snowbridge/v3/pkg/target
- github.com/snowplow/snowbridge/v5/pkg/common
- github.com/snowplow/snowbridge/v5/pkg/source/kafka
- github.com/snowplow/snowbridge/v5/pkg/target/kafka
- github.com/snowplow/snowbridge/v5/pkg/testutil
- github.com/son-la/snorlax/internal/kafka
- github.com/songzhibin97/status-neko/provide/kafka_producer
- github.com/sosnovski/kafka
- github.com/spothero/tools/kafka
- github.com/srk13790/kafka-mysql-elastic/kafka
- github.com/starismoon/study_geek/homework_6/webook/internal/events/article
- github.com/starismoon/study_geek/homework_6/webook/internal/integration/startup
- github.com/starismoon/study_geek/homework_6/webook/ioc
- github.com/starismoon/study_geek/homework_6/webook/pkg/samarax
- github.com/starismoon/study_geek/homework_7/webook/internal/events/article
- github.com/starismoon/study_geek/homework_7/webook/internal/integration/startup
- github.com/starismoon/study_geek/homework_7/webook/ioc
- github.com/starismoon/study_geek/homework_7/webook/pkg/samarax
- github.com/starismoon/study_geek/homework_8
- github.com/starismoon/study_geek/homework_9/webook/internal/events/article
- github.com/starismoon/study_geek/homework_9/webook/internal/integration/startup
- github.com/starismoon/study_geek/homework_9/webook/ioc
- github.com/starismoon/study_geek/homework_9/webook/pkg/samarax
- github.com/stepan-pokladov/csw/server/internal/queue/kafka
- github.com/steteruk/go-delivery-service/pkg/kafka
- github.com/stickyrumor/kafka-config-metrics/pkg/kafka
- github.com/stn1slv/kafka-console-avro-tools
- github.com/stonify5/common/pkg/event
- github.com/su-los/goinfra/pkg/messaging/kafka
- github.com/subiz/kafka
- github.com/suhanyujie/go_utils/pkg/mq/kafka
- github.com/sujay-mahadik/kafka-go/consumer
- github.com/sunr3d/order-stream-processor/internal/infra/kafka
- github.com/super-saga/go-x/messaging/kafka
- github.com/surajNirala/go-custom-kafka/producer
- github.com/surkovvs/ct-kafka/ct_sarama
- github.com/sv410/Distributed-Real-Time-Push-Notification-Service/internal/kafka
- github.com/tamirat-dejene/ha-soranu/shared/pkg/messaging/kafka/sarama
- github.com/tangchengxiang666/tools/mq/kafka
- github.com/targc/kaf
- github.com/tarmalonchik/golibs/kafkawrapper
- github.com/teamgram/marmota/pkg/mq
- github.com/teamlify-devx/unimq/drivers/kafka
- github.com/telekom/pubsub-horizon-go/tracing
- github.com/telkomindonesia/go-boilerplate/internal/kafka
- github.com/templatedop/watermill/pkg/kafka
- github.com/teng231/kafclient
- github.com/terrificstep/kafka-config-metrics/pkg/kafka
- github.com/theo123490/hamilton/clients
- github.com/thinhphamnls/gd/container
- github.com/ti/common-go/dependencies/broker/kafka
- github.com/tidepool-org/clinic-worker/cdc
- github.com/tidepool-org/clinic-worker/clinicians
- github.com/tidepool-org/clinic-worker/clinics
- github.com/tidepool-org/clinic-worker/datasources
- github.com/tidepool-org/clinic-worker/merge
- github.com/tidepool-org/clinic-worker/migration
- github.com/tidepool-org/clinic-worker/patients
- github.com/tidepool-org/clinic-worker/patientsummary
- github.com/tidepool-org/clinic-worker/redox
- github.com/tidepool-org/marketo-service/handler
- github.com/tidwall/tile38/internal/endpoint
- github.com/tinh-tinh/tinhtinh/microservices/kafka
- github.com/tmsong/hlog
- github.com/tnmhoang/protobet-libs/kafka
- github.com/tokmz/qi/pkg/mq
- github.com/torderonex/messageservice/internal/broker/kafka
- github.com/tqhuy-dev/xgen-uranus/kafka_provider
- github.com/treeman-zhou/code-snippet-go/db/kafka
- github.com/trendyol/stove/go/stove-kafka/sarama
- github.com/ttraveller7/invokerlib-loader
- github.com/tuanuet/retry-kafka/consumer
- github.com/tuanuet/retry-kafka/example/raw
- github.com/tuanuet/retry-kafka/example/simple
- github.com/tuanuet/retry-kafka/producer
- github.com/tuanuet/retry-kafka/retriable
- github.com/tuanuet/retry-kafka/v2/consumer/kafka
- github.com/tuanuet/retry-kafka/v2/consumer/redis
- github.com/tuanuet/retry-kafka/v2/example/raw
- github.com/tuanuet/retry-kafka/v2/example/simple
- github.com/tuanuet/retry-kafka/v2/producer/kafka
- github.com/tuanuet/retry-kafka/v2/retriable
- github.com/turtacn/emqx-go/pkg/integration
- github.com/uchupx/kajian-api/pkg/kafka
- github.com/umerfarok/kafka-live-dashboard
- github.com/umtdemr/go-kafka-with-rest-case/pkg/kafka
- github.com/unawarevisito/franz/pkg/franz
- github.com/uncool-dudes/utils/watermill
- github.com/united-manufacturing-hub/Sarama-Kafka-Wrapper-2/pkg/kafka/consumer/raw
- github.com/united-manufacturing-hub/Sarama-Kafka-Wrapper-2/pkg/kafka/consumer/redpanda
- github.com/united-manufacturing-hub/Sarama-Kafka-Wrapper-2/pkg/kafka/producer
- github.com/united-manufacturing-hub/Sarama-Kafka-Wrapper-2/pkg/kafka/shared
- github.com/united-manufacturing-hub/Sarama-Kafka-Wrapper/pkg/kafka
- github.com/ushakovn/boiler/pkg/kafka/producer
- github.com/utr1903/opentelemetry-kubernetes-demo/apps/golang/commons/otel/kafka
- github.com/utr1903/opentelemetry-kubernetes-demo/apps/golang/commons/otel/semconv/v1.24.0
- github.com/utr1903/opentelemetry-kubernetes-demo/apps/golang/kafkaconsumer/consumer
- github.com/utr1903/opentelemetry-kubernetes-demo/apps/golang/simulator/kafkaproducer
- github.com/utr1903/opentelemetry-playground/golang/apps/kafkaconsumer/consumer
- github.com/utr1903/opentelemetry-playground/golang/apps/kafkaconsumer/otel/kafka
- github.com/utr1903/opentelemetry-playground/golang/apps/kafkaconsumer/otel/semconv/v1.24.0
- github.com/utr1903/opentelemetry-playground/golang/apps/simulator/kafkaproducer
- github.com/utr1903/opentelemetry-playground/golang/apps/simulator/otel/kafka
- github.com/utr1903/opentelemetry-playground/golang/apps/simulator/otel/semconv/v1.24.0
- github.com/utrack/otelsarama
- github.com/uttamsutariya/crypto-pulse/internal/kafka
- github.com/uw-labs/substrate/kafka
- github.com/uzutizd/x/kafkax
- github.com/vagabundor/kafkabuff
- github.com/ve-weiyi/vkit/adapter/mqx/kafkax
- github.com/velvetriddles/mini-smart-home/libs/kafka
- github.com/vfriend/tools/mq/kafka
- github.com/vietthangc1/golang-pkg/kafkax
- github.com/vladislavninetyeight/service/internal/services/post
- github.com/vs-uulm/go-taf/plugins/communication/kafkabased
- github.com/vzahanych/gochoreo/pkg/kafka
- github.com/warlikenatu/kafka-config-metrics/pkg/kafka
- github.com/waryataw/platform_common/pkg/kafka/consumer
- github.com/watchlist-kata/watchlist/pkg/logger
- github.com/weblazy/easy/ekafka
- github.com/webook-project-go/webook-pkgs/saramax
- github.com/wgarbaya/sarama-oauth-jwtbearer
- github.com/whatap/go-api/instrumentation/github.com/IBM/sarama/whatapsarama
- github.com/whirlyshmily/kafka-report-sdk/sdk
- github.com/willsdu/otelsarama
- github.com/wingedrelat/kafka-config-metrics/pkg/kafka
- github.com/wkRonin/toolkit/saramax
- github.com/x626step/speed/xkafka
- github.com/xbaseio/xbase/eventbus/kafka
- github.com/xbdxzx520/webook/feed/events
- github.com/xbdxzx520/webook/feed/ioc
- github.com/xbdxzx520/webook/follow/events
- github.com/xbdxzx520/webook/im/events
- github.com/xbdxzx520/webook/interactive/events
- github.com/xbdxzx520/webook/interactive/ioc
- github.com/xbdxzx520/webook/internal/events/article
- github.com/xbdxzx520/webook/internal/integration/startup
- github.com/xbdxzx520/webook/ioc
- github.com/xbdxzx520/webook/payment/events
- github.com/xbdxzx520/webook/payment/ioc
- github.com/xbdxzx520/webook/pkg/migrator/events
- github.com/xbdxzx520/webook/pkg/migrator/events/fixer
- github.com/xbdxzx520/webook/pkg/saramax
- github.com/xbdxzx520/webook/reward/events
- github.com/xbdxzx520/webook/search/events
- github.com/xbdxzx520/webook/search/ioc
- github.com/xbdxzx520/webook/search/test/startup
- github.com/xbdxzx520/webook/tag/events
- github.com/xiaogao688/zf-project/learn/kafka/topic_list
- github.com/xinghe903/chatify/access/internal/data
- github.com/xraph/forge/extensions/kafka
- github.com/xrizer/cart-service/internal/events
- github.com/xtaci/rewind
- github.com/xuhaidong1/go-generic-tools/pluginsx/saramax
- github.com/xwc1125/xwc1125-pkg/database/kafka
- github.com/xxscloud5722/cLink/src/app
- github.com/xxtea01/tools/mq/kafka
- github.com/xyu-io/genie/transceiver/kafka
- github.com/yakob-abada/go-kafka
- github.com/yangwoodstar/NovaCore/src/transportCore/kafka
- github.com/yangyin5127/go-binlog-kafka
- github.com/yanking/gomicro/pkg/client/mq
- github.com/yayaleslie/golib/kafka
- github.com/yeaze/connect/v4/internal/impl/kafka
- github.com/yogenyslav/pkg/infrastructure/kafka
- github.com/yvyrovyi-cinemo/utils/kafkalib
- github.com/zhangji2/golibrary/mq
- github.com/zhaozuodong/gomitmproxy/middlewares
- github.com/zhetkerbaevan/messaggio-test-task/internal/kafka
- github.com/zhgqiang/sdk-go/v4/conn/mq
- github.com/zhoujubhong/kafkaclient
- github.com/zijiren233/logrus-kafka-hook
- github.com/zmskv/websocket_stream/internal/kafka
- github.com/zmsocc/practice/syntax
- github.com/zmsocc/practice/webook/interactive/events
- github.com/zmsocc/practice/webook/interactive/ioc
- github.com/zmsocc/practice/webook/internal/event/article
- github.com/zmsocc/practice/webook/internal/integration/startup
- github.com/zmsocc/practice/webook/ioc
- github.com/zmsocc/practice/webook/pkg/saramax
- github.com/zp857/goutil/kafka
- github.com/zuzi90/tz-enricher/internal/providers/kafka
- github.com/zybpkg/golib/v2/kafka
- gitlab.com/AAAAAlexeyyyyy/geoservice/apigate/internal/domain/kafka
- gitlab.com/AAAAAlexeyyyyy/geoservice/apigate/internal/infrastructure/kafka/consumer
- gitlab.com/AAAAAlexeyyyyy/geoservice/apigate/internal/infrastructure/kafka/producer/async
- gitlab.com/AAAAAlexeyyyyy/geoservice/apigate/internal/infrastructure/kafka/producer/sync
- gitlab.com/AAAAAlexeyyyyy/geoservice/register/internal/domain
- gitlab.com/AAAAAlexeyyyyy/geoservice/register/internal/infrastructure/kafka/consumer
- gitlab.com/AAAAAlexeyyyyy/geoservice/register/internal/infrastructure/kafka/producer/sync
- gitlab.com/bersufekadgetachew/cbe-super-app-shared/shared/notification/producer
- gitlab.com/fclick1/loghub-collector/internal/queue
- gitlab.com/go-infra/go-infra-mq/kafkamq
- gitlab.com/golang-libs/mosk.git/interfaces/kafka/sarama
- gitlab.com/golib3/core/kafka
- gitlab.com/matchsystems-golang/kafka
- gitlab.com/sean.moranMI/infra_go_libs/message_broker
- gitlab.devvv.io/common/h9_marmota/pkg/mq
- gitlab.eclipse.org/eclipse/xfsc/libraries/messaging/cloudeventprovider
- gitlab.khayangan.id/mejik-corp-public/microgen-v3-function-shared-packages/messaging
- gitlab.maetime.com/mcmf/maego/kafka
- gitlab.mai.ru/notifier/backend/scheduler/internal/infrastructure/kafka/producer
- gitlab.mai.ru/online-store-pet-project/backend/auth-service/internal/infrastructure/producer/kafka
- gitlab.mai.ru/online-store-pet-project/backend/notification-service/internal/infrastructure/consumer/kafka
- gitlab.mai.ru/online-store-pet-project/backend/order-service/internal/infrastructure/kafka
- gitlab.mai.ru/online-store-pet-project/backend/order-service/internal/infrastructure/notification-sender/kafka
- gitlab.mokiwi.com/kiwi_sdk/public/kwkafka
- gitverse.ru/shirlysk/sso/internal/messaging/kafka
- gocloud.dev/pubsub/kafkapubsub
- gopkg.in/DataDog/dd-trace-go.v1/contrib/IBM/sarama.v1
- knative.dev/eventing-kafka-broker/control-plane/cmd/kafka-controller
- knative.dev/eventing-kafka-broker/control-plane/pkg/autoscaler/keda
- knative.dev/eventing-kafka-broker/control-plane/pkg/config
- knative.dev/eventing-kafka-broker/control-plane/pkg/kafka
- knative.dev/eventing-kafka-broker/control-plane/pkg/kafka/clientpool
- knative.dev/eventing-kafka-broker/control-plane/pkg/kafka/offset
- knative.dev/eventing-kafka-broker/control-plane/pkg/kafka/sarama
- knative.dev/eventing-kafka-broker/control-plane/pkg/kafka/testing
- knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/channel
- knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/consumergroup
- knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/sink
- knative.dev/eventing-kafka-broker/control-plane/pkg/security
- knative.dev/eventing-kafka-broker/control-plane/pkg/security/oauth
- knative.dev/eventing-kafka-broker/test/test_images/committed-offset
- knative.dev/eventing-kafka-broker/test/test_images/consumer-group-lag-provider-test
- knative.dev/eventing-kafka-broker/test/test_images/kafka-consumer
- kubedb.dev/db-client-go/kafka
- kubeops.dev/pgoutbox/internal/publisher