sarama

package module

Go to main page

Known importers: 1,439 (displaying 1,892 packages, including internal and invalid packages)

bitbucket.org/axbannaz/sizetest/ (7)

bitbucket.org/celtic-coder/ (4)

bitbucket.org/celtic-coder/action/ (2)

bitbucket.org/celtic-coder/kafka/ (2)

bitbucket.org/jurnal/go-common/ (2)

bitbucket.org/nwt-nevada/diamonds-backend-service/pkg/telemetrywriter
e.coding.net/odinit/it-self/gokit/kafka
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

gitea.com/ucslibs/kafkasarama (4)

gitee.com/amuluze/amutool/kafka
gitee.com/appplugin/tools/mq/kafka

gitee.com/aqualion/go-webbook/ (5)

gitee.com/byx_darwin/micro-extend/pkg/kafka/sarama
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/go-wares/ (2)

gitee.com/guoting520/mycommon.git/kafka
gitee.com/hioaf/opentelemetry/common/kafka

gitee.com/infobili/go-drivers (2)

gitee.com/laotie999/guardian/app/sys_service

gitee.com/m_tao/sagittarius-golang/ (2)

gitee.com/minguo_li/mgo/common/msgqueue/kafka

gitee.com/os-lee/easy-paas/ (2)

gitee.com/patent_clairvoyance/clairvoyance-backend/ (3)

gitee.com/penbox/basic-go/ (11)

gitee.com/qt-wu/glog/hooks
gitee.com/the_sun_light/pkg/kafka
gitee.com/waiot/collector/internal/config
gitee.com/weixuehao/kratos-bootloader/plugins/broker/saka

gitee.com/wkRonin/wkRonin-basic-go/ (6)

gitee.com/wuzheng0709/backend-gopkg/ (2)

gitee.com/xiao_hange/ (3)

gitee.com/xiao_hange/go-admin-file/ (2)

gitee.com/xiao_hange/go-admin-pkg/pkg/saramax

gitee.com/zrj99123/common/ (2)

github.com/0angelic0/dd-trace-go/contrib/IBM/sarama.v1

github.com/0xivanov/crypto-notification-system/ (3)

github.com/13excite/kafka-svc/ (2)

github.com/18721889353/sunshine/pkg/kafka

github.com/2777484478/go_logagent_transfer/ (3)

github.com/3th1nk/easygo/mq/kafka

github.com/4everland/ipfs-top/ (2)

github.com/4ont/kit/go/kratostune
github.com/4thel00z/task-manager/internal
github.com/8xmx8/easier/pkg/amqp/kafka
github.com/AbnerEarl/goutils/kafkas
github.com/AchmadRifai/sarama-consumer-go
github.com/Ashwin7867/go-kafka-retrier/retrier

github.com/Astemirdum/monolib/ (2)

github.com/Benny93/kafui/pkg/datasource/kafds

github.com/Boklazhenko/kafka/ (3)

github.com/Borislavv/go-kafka/ (7)

github.com/Causely/chaosmania/pkg/actions
github.com/Cc360428/HelpPackage/kafkac

github.com/CeoFred/gin-boilerplate/ (2)

github.com/CocaineCong/tangseng/ (2)

github.com/CppUser/kafka
github.com/DEEPAKK-T/livekafkafeeder

github.com/DIMO-Network/ (17)

github.com/DIMO-Network/device-data-api/ (3)

github.com/DIMO-Network/devices-api/ (5)

github.com/DIMO-Network/meta-transaction-processor/ (3)

github.com/DIMO-Network/privacy-processor/cmd/privacy-processor

github.com/DIMO-Network/rewards-api/ (2)

github.com/DIMO-Network/shared/kafka
github.com/DIMO-Network/users-api/internal/services
github.com/DIMO-Network/valuations-api/internal/api

github.com/DaHuangQwQ/gpkg/ (3)

github.com/Darker-D/ddbase/queue/kafka

github.com/DataDog/dd-trace-go/ (3)

github.com/DecodeWorms/kakify (3)

github.com/DeltaNicola/trading-lib/events/kafka
github.com/DianGeIM/tools/mq/kafka
github.com/Dmitrij-bot/marketserv/internal/usecase

github.com/Dnlbb/auth/ (4)

github.com/EladLeev/kafka-config-metrics/util
github.com/EricKim65/abango
github.com/Eyup-Devop/logtor/creators

github.com/F1997/categraf/ (4)

github.com/Financial-Times/kafka-client-go/v4

github.com/FluorescentTouch/testosteron (4)

github.com/Fu-XDU/mingfu_go_common/kafka

github.com/GoSimplicity/ (16)

github.com/GoSimplicity/LinkMe-microservices/ (5)

github.com/GoSimplicity/LinkMe/ (11)

github.com/Goboolean/common/deprecated/kafka
github.com/GuanceCloud/bfy-conv/parseV2

github.com/I-m-Surrounded-by-IoT/backend/ (13)

github.com/IBM-Cloud/terraform-provider-ibm/ibm/service/eventstreams

github.com/IBM/sarama/ (2)

github.com/Interhyp/metadata-service/internal/repository/kafka

github.com/IzhakJakov/sarama-cluster (2)

github.com/JMURv/e-commerce/ (7)

github.com/Jared-lu/GXT/saramax
github.com/Jayleonc/register/internal/pkg/saramax
github.com/Kephas73/lib-kephas/kafka_client
github.com/KevinRionaldo/myGoLibrary/kafkaLib

github.com/KyberNetwork/tradelogs/ (2)

github.com/KyleYe/open-im-tools/mq/kafka

github.com/LXJ0000/go-backend/ (7)

github.com/LabKiko/cerberus/kafka
github.com/Leonid-Sarmatov/golang-yandex-last-fight/solver_server/internal/kafka

github.com/Linxhhh/webook/ (3)

github.com/LukeEuler/dolly/log
github.com/MaciejNET/PixelPulseSharedGo/messaging

github.com/MadsRC/sarama/ (5)

github.com/MajotraderLucky/Kafka-FIO-Listener/checker

github.com/Mark-Panda/rulego-components/ (2)

github.com/Mashuk22/telegrammanager/userservice/cmd/userservice

github.com/MauveSoftware/kafkaclient (2)

github.com/Meikwei/go-tools/mq/kafka

github.com/Memonagi/wallet_project/ (2)

github.com/Mongey/terraform-provider-kafka/ (2)

github.com/MrRique15/go_rest_api/main_api/pkg/shared/kafka

github.com/MuxiKeStack/ (20)

github.com/MuxiKeStack/be-answer/ (2)

github.com/MuxiKeStack/be-comment/ (3)

github.com/MuxiKeStack/be-course/ (3)

github.com/MuxiKeStack/be-feed/ (3)

github.com/MuxiKeStack/be-grade/ (3)

github.com/MuxiKeStack/be-stance/ (3)

github.com/MuxiKeStack/bff/ (3)

github.com/NesterovYehor/TextNest/pkg/kafka
github.com/NetEase-Media/easy-ngo/clients/xkafka

github.com/NickolaiP/api/ (3)

github.com/NikitaTsaralov/utils/logger

github.com/Oleg-Pro/auth/ (6)

github.com/OrigamiWang/msd/ (4)

github.com/ParspooyeshFanavar/sarama-cluster (2)

github.com/Paul1k96/microservices_course_platform_common/pkg/client/kafka/consumer

github.com/PerfilievAlexandr/chat-server/ (3)

github.com/PolinaSvet/kafka

github.com/Primeskills-Web-Team/golang-api-common/ (3)

github.com/Prrromanssss/platform_common/pkg/kafka/consumer
github.com/QinPengLin/repro-origin/sysmodule/kafkamodule
github.com/RomanIvanovMinsk/kafka_helper
github.com/Roshick/go-autumn-kafka/pkg/kafka

github.com/SENERGY-Platform/ (15)

github.com/SENERGY-Platform/import-repository/ (2)

github.com/SENERGY-Platform/platform-connector-lib (2)

github.com/SIN5t/tiktok_v2/pkg/kafka/video

github.com/SashaMelva/web-service-gin/ (2)

github.com/Sharykhin/go-delivery-dymas/ (2)

github.com/ShmelJUJ/software-engineering/ (4)

github.com/SicParv1sMagna/AtomHackMarsService/internal/kafka

github.com/SigNoz/signoz-otel-collector/ (3)

github.com/Slimo300/Microservices-Videocall-and-Chat-App/backend/lib/msgqueue/kafka
github.com/Soyaka/microlearn-entitment/internal/kafka

github.com/SyamSolution/ (2)

github.com/TTraveller7/invokerlib/ (3)

github.com/Tech-Arvand/collections_service/ (3)

github.com/TencentBlueKing/bkmonitor-datalink/ (3)

github.com/ThreeDotsLabs/ (2)

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 (7)

github.com/Tsengdk/sarama/ (5)

github.com/TykTechnologies/ (2)

github.com/Uonx/go-tools/msg_queue/kafka

github.com/VadimGossip/concoleChat-auth/ (6)

github.com/VanessaVallarini/campaign-consumer-api/ (4)

github.com/WwhdsOne/Wlog/writer/mq
github.com/XC-Zero/zero_common/kafka

github.com/YanLong-L/migratiox/ (4)

github.com/Yangfisher1/zipkin-go/reporter/kafka

github.com/aarchies/hephaestus/ (2)

github.com/aaronjheng/kafka-cli/ (2)

github.com/abdelrahman146/digital-wallet/ (2)

github.com/abdulazizax/mini-twitter/ (2)

github.com/abdullahnettoor/connect-social-media/ (2)

github.com/abh1shekyadav/go-kafka/ (2)

github.com/abhijitpratinidhi/connect/v4/impl/impl/kafka
github.com/abhishekamralkar/kafcmd
github.com/abraham-leal/kafka-idle-topics/cmd/kafka-idle-topics
github.com/adamenger/hummingbird/ingest/publisher

github.com/adarsh-a-tw/ (2)

github.com/adhiana46/da-shared/ (2)

github.com/adityjoshi/avinyaa/ (2)

github.com/afzalhussain23/kafka-notify/ (2)

github.com/agadilkhan/pickup-point-service/ (2)

github.com/agalue/onms-kafka-ipc-receiver/client
github.com/air-iot/sdk-go/v4/conn/mq
github.com/airunny/timer/pkg/ikafka

github.com/akgupta-47/go-kafka/ (2)

github.com/akhi9550/ (2)

github.com/akimdev15/go-kafka-learn/ (2)

github.com/akimsavvin/ (3)

github.com/akimsavvin/tablet_backend/ (2)

github.com/akimsavvin/tablet_telegram/cmd/tablet_telegram

github.com/akkahshh24/go-kafka-notify/ (3)

github.com/akshay0074700747/ (4)

github.com/akshay0074700747/project-company_management-company-service/ (2)

github.com/akshay0074700747/project-company_management-project-service/ (2)

github.com/akulsharma1/distributed-analytics-platform/ (4)

github.com/alebabai/go-kafka/adapter/sarama

github.com/aleksandra0kr/matchingapp/ (2)

github.com/alexiscampan/kafka-learning/ (2)

github.com/algol-84/auth/internal/client/kafka/producer
github.com/ali-cambodia/h9_marmota/pkg/mq

github.com/alirezazeynali75/exify/ (2)

github.com/alserov/ (19)

github.com/alserov/car_insurance/ (2)

github.com/alserov/device-shop/ (8)

github.com/alserov/mq/kafka

github.com/alserov/rently/ (5)

github.com/alserov/restate/ (3)

github.com/alvi31182/kafka
github.com/always-web/go-pkg/kafka
github.com/amazing-socrates/next-tools/mq/kafka

github.com/ambitiousmice/go-one/ (3)

github.com/ampliway/way-lib-go/msg/v1
github.com/amuluze/amutool/kafka

github.com/aniketxpawar/golang-kafka/ (2)

github.com/ankush-003/alerts-simulation-and-remediation/ (2)

github.com/anton-kapralov/currency-market-pulse/ (4)

github.com/antonio-alexander/go-bludgeon/pkg/kafka
github.com/apecloud/dbctl/engines/kafka
github.com/apus-run/sea-kit/mq/kafka

github.com/arcorium/rashop/ (17)

github.com/argoproj/argo-events/ (7)

github.com/aristanetworks/goarista/ (4)

github.com/arquivei/goduck/impl/implstream/kafkasarama
github.com/arshanh/benthos/v4/internal/impl/kafka

github.com/arslanovdi/otelsarama (3)

github.com/arturyumaev/goworkshops/ (3)

github.com/aryanc1027/api-kafka-golang/internal/kafka
github.com/ashkarax/ciao_socilaMedia_postNrelationService/utils/kafka_producer
github.com/asinha08/ts-utils/kafka

github.com/aykanferhat/go-kafka-partition-scaler/ (2)

github.com/ayushthe1/streak/kafka
github.com/bagusYudistira/k6-kafka-consumer

github.com/balamurugankk/go/ (2)

github.com/balasl342/kafka-payment-processor/internal/kafka
github.com/baoyxing/micro-extend/pkg/kafka/sarama
github.com/bas-baskara/kafka-consumer-grpc

github.com/bborbe/ (3)

github.com/bborbe/kafka (2)

github.com/bborbe/mqtt-kafka-connector

github.com/bcebigdata/kafka-sample-golang/ (2)

github.com/beatlabs/bake/ (2)

github.com/bgq98/utils/ (3)

github.com/bhuvanesh/kafka-notify/ (2)

github.com/biangacila/ (2)

github.com/billz-2/packages/pkg/tracing

github.com/bingoohuang/ (4)

github.com/bingoohuang/gg/pkg/kafka

github.com/bingoohuang/ngg/ (3)

github.com/bira37/benthos/v4/internal/impl/kafka

github.com/birdayz/kaf/ (2)

github.com/bitmaskit/notifications/ (3)

github.com/bjorndonald/lasgcce/ (2)

github.com/blink-io/x/kafka/sarama/registrar
github.com/blr-coder/tasks-svc/internal/infrastructure/queues/kafka
github.com/bobo-rs/kfkqueue
github.com/bogdanshibilov/blockchaincrawler/internal/auth/codeproducer
github.com/bondzai/portfolio-backend/internal/usecases

github.com/bonxatiwat/bonx-shop-tutorial/ (4)

github.com/boostgo/lite/ (2)

github.com/bozkurtemre/backend-assesstment/ (2)

github.com/broswen/ (4)

github.com/broswen/stateful-consumer/internal/consumer

github.com/broswen/webhookrelay/ (3)

github.com/bruce-mig/kafka-sarama/ (2)

github.com/bsanzhiev/bahamas/ (3)

github.com/bugzzhou/gotools/kafka

github.com/bulutcan99/kafka_pubsub/ (2)

github.com/burdiyan/kafkautil

github.com/caichuanwang/kafka-go/ (2)

github.com/cantylv/coursework-bmstu-2024-networking/ (3)

github.com/carlosealves2/create-user-micro-services/common/kafkaclient

github.com/catalystgo/bootstrap/ (2)

github.com/cavanwang/msg-delay-send/ (2)

github.com/cguertin14/kafka-example/producer
github.com/charlesbases/library/broker/kafka

github.com/charlieloom/ (2)

github.com/choveylee/tdb

github.com/chrisdamba/ (3)

github.com/chrisdamba/foodatasim/ (2)

github.com/chrisdamba/simstreamdata/pkg/simulator

github.com/chrislusf/gleam/plugins/kafka

github.com/ciazhar/ (8)

github.com/ciazhar/go-kafka-example/pkg/kafka

github.com/ciazhar/go-start-small/ (5)

github.com/ciazhar/go-zhar/ (2)

github.com/cisco-open/go-lanai/pkg/kafka

github.com/cloudevents/sdk-go/ (5)

github.com/cloudintegrator/go-sonic-kafka-connector/pkg/listener
github.com/cloudquery/cloudquery/plugins/destination/kafka/client

github.com/cloudtrust/ (3)

github.com/cloudtrust/common-service/v2/events

github.com/cloudtrust/kafka-client (2)

github.com/clunc/hr-monitor-ble-server
github.com/cnsync/simple-game/eventbus/kafka/v2

github.com/cockroachdb/replicator/ (2)

github.com/codedog2001/webook/ (7)

github.com/codingWhat/armory/ (4)

github.com/codytheroux96/go-kafka/ (2)

github.com/colataco/telegraf-plugins/ (2)

github.com/common-go/kafka/sarama
github.com/content-services/content-sources-backend/pkg/config
github.com/contobox/orbita/internal/job

github.com/core-go/ (2)

github.com/cppuser/magaz/services/shop/user/cmd/api

github.com/cry1s/transport_layer/ (3)

github.com/ctl5563096/base/library

github.com/ctolon/cdn-api/ (2)

github.com/ctrl-hub/franz/internal
github.com/cvanh/camscraper/scrapers/klimwinkel

github.com/d2jvkpn/ (2)

github.com/dabory/abango-rest (2)

github.com/dadaxiaoxiao/ (11)

github.com/dadaxiaoxiao/go-pkg/ (3)

github.com/dadaxiaoxiao/payment/ (2)

github.com/dadaxiaoxiao/reward/ (2)

github.com/dadaxiaoxiao/search/ (2)

github.com/dadaxiaoxiao/tag/ (2)

github.com/daidai53/webook/ (15)

github.com/danielgospodinow/kinkang/cmd/kinkang
github.com/danielqsj/kafka_exporter
github.com/daobin/go-practice/mq

github.com/dapr/components-contrib/ (2)

github.com/darccio/dd-trace-go/v2/contrib/IBM/sarama.v1

github.com/datumforge/datum/ (2)

github.com/davidredborder/sarama-cluster (2)

github.com/davidsbond/autopgo/internal/event

github.com/ddr4869/msazoom/ (3)

github.com/dedihartono801/promo-scheduler/ (2)

github.com/deepflowio/deepflow/ (2)

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/deviceinsight/kafkactl/ (12)

github.com/devops-360-online/go-with-me/internal/repositories
github.com/devopsext/events/output

github.com/dexguitar/chatapp/ (2)

github.com/dgraph-io/dgraph/v24/worker
github.com/diamond-bullet/golangpractice/demo/kafka/kafka_single

github.com/diegom0ta/go-kafka/ (2)

github.com/dimoktorr/unit_tests/ (2)

github.com/dimonleksin/ (5)

github.com/dimonleksin/go-kafka-rest/ (4)

github.com/dimonleksin/kafka_reasign_partition/pkg

github.com/distribworks/dkron/v4/builtin/bins/dkron-executor-kafka

github.com/dmohanta-jnpr/ (2)

github.com/dnwe/otelsarama (3)

github.com/dobyte/due/eventbus/kafka/v2

github.com/dojeto/kafka-batch-go-example/ (2)

github.com/dominikus1993/kafka-topic-creator/ (2)

github.com/dorianneto/kafka-notify/ (2)

github.com/duanhf2012/origin/v2/sysmodule/kafkamodule
github.com/ducanhpham0312/zeevision/backend/internal/consumer

github.com/duolacloud/broker-core-kafka (2)

github.com/easynet-cn/log-agent/object

github.com/eben92/go-kafka/ (2)

github.com/ecodeclub/notify-go/queue/kafka

github.com/edgedelta/opentelemetry-demo/ (2)

github.com/edgeflare/pgo/pkg/pipeline/kafka
github.com/edu3dw4rd/kafka-cli

github.com/ehsaniara/delay-box/ (8)

github.com/eiixy/monorepo/ (4)

github.com/einherij/enterprise/db/message_queue
github.com/eladleev/schema-registry-statistics

github.com/eld4niz/kafka-notification-api/ (2)

github.com/electric-saw/kafta/ (6)

github.com/encountea/message-service/internal/kafka
github.com/energostack/bisquitt-psk/pkg/reader

github.com/epicbytes/ (2)

github.com/erickim65/abango

github.com/erikqwerty/erik-platform/ (2)

github.com/escalopa/kafka-playground/ (2)

github.com/ethpandaops/xatu/pkg/output/kafka
github.com/etloreq/yandex-practicum-arch-tasks/sprint3/microservice-devices/internal/producer

github.com/evanzhang87/evans-tools/ (2)

github.com/exadevt/go-commont/events

github.com/exgamer/gosdk/ (2)

github.com/f110/github-400-test/ (2)

github.com/fajaramaulana/ (7)

github.com/fajaramaulana/go-micro-kafka/ (5)

github.com/fajaramaulana/notification-service-payment/ (2)

github.com/fallra1n/product-keeper/ (4)

github.com/fankane/go-utils/plugin/queue/kafka
github.com/faridgh1991/samsa

github.com/fazpass/goliath/ (2)

github.com/felipedsf/go-payment/ (3)

github.com/ferminhg/learning-go/ (4)

github.com/fervent-45/transaction_service/ (2)

github.com/fidesy/sdk/common/kafka

github.com/filatkinen/distr-transactions/ (6)

github.com/firerplayer/notification-kafka-go/ (3)

github.com/fission/ (3)

github.com/fission/fission/pkg/mqtrigger/messageQueue/kafka

github.com/fission/keda-connectors/ (2)

github.com/fleezesd/kafka-example/http_server

github.com/fluffy-bunny/goka-play/ (2)

github.com/fmelihh/kafka-go/ (2)

github.com/forgocode/family/pkg/kafka
github.com/forhadulislam/learn-go-with-examples/40-kafka/client

github.com/formancehq/ (2)

github.com/frhnfrnk/blog-platform-microservices/notification-service/internal/kafka

github.com/futurehomeno/streams/ (2)

github.com/g0r0d3tsky/mail/ (2)

github.com/gaara1994/tool/cmd

github.com/gagraler/ (2)

github.com/gateway-dao/seaweedfs/ (4)

github.com/gaurav-225/golang-projects/ (2)

github.com/geniusrabbit/notificationcenter/v2/kafka

github.com/gevinzone/basic-go/ (6)

github.com/ginger-repository/kafka/ (3)

github.com/gnanasuryateja/golib/datastore/messaging_queue/kafka

github.com/go-chujang/demo-aa/ (5)

github.com/go-graphite/go-carbon/receiver/kafka
github.com/go-juno/kit/kafka

github.com/go-keg/ (7)

github.com/go-keg/keg/contrib/kafka

github.com/go-keg/monorepo/ (3)

github.com/go-keg/simple/ (3)

github.com/go-magic/rook/pkg/api/mkafka
github.com/go-sigma/sigma/pkg/modules/workq/kafka
github.com/go-slark/infra/kafka

github.com/go-streamline/standard-processors-bundle/ (2)

github.com/go-wonk/si/ (2)

github.com/gofish2020/easydispatch/heart/kafka
github.com/goinline/agent/mq/kafka/sarama

github.com/golangid/candi/ (2)

github.com/golovin-a/KafkaLog/tools/kafka
github.com/goto/meteor/plugins/extractors/kafka

github.com/grafana/ (10)

github.com/grafana/alloy/ (7)

github.com/grafana/loki/ (3)

github.com/greenblat17/ (6)

github.com/greenblat17/user-consumer/ (4)

github.com/grinnan/minio/ (2)

github.com/guigateixeira/general-auth/kafka

github.com/gvidow/go-chat-transport/ (5)

github.com/hainenber/hetman/ (2)

github.com/happywbfriends/metrics/examples
github.com/harisatul/skr-mono/feature/leaderboard
github.com/harmonic-lqw/webook-interactive/events
github.com/harphies/go.microservices.io/messaging/kafka

github.com/harrylee2015/harry_tools/ (2)

github.com/hawkv6/ (4)

github.com/hawkv6/clab-telemetry-linker/ (2)

github.com/hawkv6/generic-processor/ (2)

github.com/hd2yao/log-agent/ (4)

github.com/hdget/ (2)

github.com/helays/utils/close/kafkaClose
github.com/hell-walker/enterprise/db/message_queue

github.com/heroku/heroku-kafka-demo-go (2)

github.com/hespecial/gin-mall/internal/repository/kafka

github.com/hihone/kafka_demo/ (2)

github.com/hiteshjain48/kafka-notify/ (2)

github.com/hjoshi123/fintel/infra/pubsub

github.com/hjwalt/flows/ (2)

github.com/hnldxhyxluo/sarama/ (5)

github.com/hongry18/sarama-kafka-go/ (2)

github.com/hopeio/ (5)

github.com/hopeio/initialize/conf_dao/kafka

github.com/hopeio/tiga/ (3)

github.com/hopeio/utils/log/output/kafka

github.com/hosseinmirzapur/gokafka-example/ (2)

github.com/hrist-todorova/notification-system/ (3)

github.com/htsync/microservice/ (2)

github.com/hudangwei/common/kafka

github.com/hussammohammed/marketplace-go-microservices/ (5)

github.com/hyetpang/go-frame/internal/components/kafka

github.com/hyperledger/ (4)

github.com/hyperledger/fabric-admin-sdk/internal/configtxgen/viperutil

github.com/hyperledger/firefly-ethconnect/ (3)

github.com/hyphypnotic/messagio-tk/ (4)

github.com/i101dev/template-kafka/ (2)

github.com/ibrahimker/golang-praisindo-advanced/ (8)

github.com/ig6gzu/biz_exporter

github.com/ihippik/ (2)

github.com/ilkerkorkut/go-examples/microservice/observability/internal/logging

github.com/illidaris/ (2)

github.com/imind-lab/micro/v2/broker
github.com/imonja/pkg/kafka/sarama

github.com/imrishuroy/ (2)

github.com/influxdata/ (5)

github.com/influxdata/kapacitor/ (2)

github.com/influxdata/telegraf/ (3)

github.com/informeai/go-kafka/internal

github.com/inglo357/go-kafka/ (2)

github.com/instana/go-sensor/ (2)

github.com/intelops/qualitytrace/agent/workers/trigger/kafka

github.com/ipv02/auth/ (6)

github.com/istomyang/ (6)

github.com/istomyang/event/ (2)

github.com/istomyang/wsevent/ (4)

github.com/itimky/spindle/ (4)

github.com/izzanzahrial/skeleton/internal/domain/post/broker

github.com/jacksonbarreto/ (16)

github.com/jacksonbarreto/WebGateScanner-DNSSECAnalyzer/internal/groupHandler

github.com/jacksonbarreto/WebGateScanner-kafka/ (2)

github.com/jacksonbarreto/WebGateScanner-stls/internal/groupHandler

github.com/jacksonbarreto/WebGateScanner/ (5)

github.com/jacksonbarreto/sadi/internal/consumer
github.com/jacksonbarreto/stls/internal/consumer

github.com/jacksonbarreto/webgatescanner/ (5)

github.com/jalapeno-api-gateway/jagw/pkg/messages

github.com/jason-costello/weather/ (3)

github.com/jasonzhao47/cuddle/ (4)

github.com/jau1jz/cornus/ (4)

github.com/jayleonc/geektime-go/ (13)

github.com/jeevansurendran/kcopy

github.com/jenagansivakumar/go-kafka/ (2)

github.com/jensilo/ccbd-kafka-exercise/ (2)

github.com/jesseinvent/go-kafka/ (2)

github.com/jifuy/commongo/mq/kafka

github.com/jinggangnanyou/ (2)

github.com/jipark0716/fcm-sender/ (2)

github.com/jj22ee/opentelemetry-collector-contrib/ (2)

github.com/johnwongx/webook/ (2)

github.com/jose-lico/log-processing-microservices/ (3)

github.com/jpmoraess/ (4)

github.com/jpmoraess/go-food/order-service/internal/infrastructure/messaging

github.com/jpmoraess/toll-calculator/ (3)

github.com/jwebb1334/fission/pkg/mqtrigger/messageQueue/kafka

github.com/kadzany/messaging-lib/ (3)

github.com/kaolnwza/spider-cat-microsvc/ (4)

github.com/kedacore/keda/ (2)

github.com/kenjones-cisco/logrus-kafka-hook
github.com/khasmag06/effective-mobile-test/pkg/kafka

github.com/khulnasoft/deepflow/ (2)

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/knbr13/company-service-go/ (4)

github.com/kobsio/klogs/pkg/kafka

github.com/korableg/bus/ (3)

github.com/korvised/ilog-shop/ (4)

github.com/kubescape/kubescape-network-scanner/pkg/networkscanner/servicediscovery/applicationlayerdiscovery

github.com/kubeshop/tracetest/ (2)

github.com/kuromii5/messagio/ (2)

github.com/kyh0703/go-project-layout/internal/pkg/kafka

github.com/lazywoo/mercury/ (10)

github.com/leetcode-golang-classroom/golang-coffee-store-with-kafka/ (2)

github.com/lengocson131002/ (2)

github.com/leonardo404-code/kafka-notify/ (4)

github.com/lep13/messaging-notification-service/kafka
github.com/limingyao/excellent-go/pkg/kafka

github.com/linkedin/Burrow/ (3)

github.com/liqiongtao/googo.io/goo-kafka
github.com/liserc/openchat-tools/mq/kafka
github.com/liumingmin/goutils/db/kafka

github.com/lkumarjain/benchmark/ (2)

github.com/lll8c/webook/ (11)

github.com/lockp111/go-easykafka

github.com/longpi1/ (2)

github.com/lookandhate/course_platform_lib/pkg/message_queue/kafka/client/consumer

github.com/louis296/mesence-communicate/ (2)

github.com/lovoo/goka (5)

github.com/lowl11/ (8)

github.com/lowl11/boost/pkg/web/kafka

github.com/lowl11/boost2/ (7)

github.com/lucaskatayama/learn-hexagonal/go/pkg/kafka
github.com/lucky/murmur2-partitioner-go/partitioner
github.com/luongduc1246/ultility/broker

github.com/lutcoding/redbook/ (3)

github.com/luvx21/coding-go/coding-usage/mq/kafka
github.com/m1kr0b/message-processing/internal/kafka
github.com/maard/kafkautil

github.com/maestro-milagro/ (2)

github.com/maksadbek/statsfornba/pkg/platform/kafka
github.com/manas012003/go-kafka-redis-webserver

github.com/marcusbello/mjevents/ (4)

github.com/maxbroker/log-manager/ (3)

github.com/maxuanquang/ (5)

github.com/maxuanquang/idm/ (2)

github.com/maxuanquang/ojs/ (3)

github.com/mdaxf/ (3)

github.com/mdaxf/datahub/kafka

github.com/mdaxf/iac/ (2)

github.com/meetmorrowsolonmars/zhopij/ (3)

github.com/meidada2464/gostudy/Kafka_sarama_test/producer

github.com/memphisdev/superstream.go (2)

github.com/meoying/local-msg-go (5)

github.com/meraiku/ (4)

github.com/meraiku/kafka/ (2)

github.com/meraiku/micro/ (2)

github.com/michaelcapera/ (2)

github.com/mikhailsoldatkin/auth/ (4)

github.com/mingrammer/sarama/ (7)

github.com/minhvuongrbs/webhook-service/pkg/kafka

github.com/minio/minio/ (2)

github.com/misakimei123/redbook/ (8)

github.com/mklfarha/sarama-fx (2)

github.com/mmtbak/microlibrary/library/mq
github.com/mohammad-siraj/hexarchgo/internal/libs/eventbroker

github.com/mohammedfuta2000/kafka-project/ (2)

github.com/moment-technology/goka (5)

github.com/mooncake9527/durian/pkg/kafka
github.com/mrasu/echoed/create-echoed/template/base/example/opentelemetry-demo-override/src/checkoutservice

github.com/mss-boot-io/mss-boot-admin/ (3)

github.com/mstgnz/ (2)

github.com/mtgnorton/ws-cluster/ (2)

github.com/muly/golang/ (3)

github.com/muradshahsuvarov/gochess/ (2)

github.com/my-little-pet/user-microservice/ (3)

github.com/myrteametrics/myrtea-sdk/ (2)

github.com/nais/ (5)

github.com/nais/contests/internal/kafka

github.com/nais/kafkarator/ (4)

github.com/namnv2496/ (4)

github.com/namnv2496/go-coffee-shop-demo/ (2)

github.com/namnv2496/go-wallet/ (2)

github.com/nandhasuhendra/mock-debezium-kafka/ (2)

github.com/nanmenkaimak/github-gist/ (2)

github.com/narendra121/pkghub/pub-sub/kafka-pkg

github.com/neblic/platform/ (2)

github.com/neflyte/gowait/waiter
github.com/nehal119/benthos-119/pkg/impl/kafka

github.com/nenormalka/freya/ (3)

github.com/neo532/ (4)

github.com/neo532/gokit/ (2)

github.com/neo532/kratos_layout/ (2)

github.com/neokofg/go-pet-detailed-microservices/ (4)

github.com/neracastle/ (4)

github.com/neracastle/auth/ (3)

github.com/neracastle/go-libs/pkg/kafka

github.com/nextmicro/next/ (2)

github.com/nibbleshift/blobfish/impl/kafka

github.com/nik19ta/gostat/ (9)

github.com/nitin-chauhan66/ecommerce-microservices/ (2)

github.com/nmoek/golang_learning/ (2)

github.com/noah-platform/noah/ (2)

github.com/noctarius/timescaledb-event-streamer/ (3)

github.com/norbybaru/go-kafka/ (2)

github.com/nowfred/dd-trace-go/contrib/IBM/sarama.v1

github.com/nqxcode/ (6)

github.com/nqxcode/auth_microservice/ (3)

github.com/nqxcode/platform_common/ (3)

github.com/nt2311-vn/go-kafka/ (2)

github.com/ntentasd/ecommerce-microservices/ (2)

github.com/nthskyradiated/go-kafka/ (2)

github.com/numaproj/numaflow/ (4)

github.com/nxsre/logrus-kafka-hook

github.com/obaydullahmhs/ (7)

github.com/obaydullahmhs/kafka-client-go/ (5)

github.com/obse4/goCommon/kafka

github.com/off-chain-storage/GoSphere/ (2)

github.com/olad5/kafka-sheet-processor/broker/kafka

github.com/oldsaltedfish/wireprovider/ (2)

github.com/olezhek28/microservices_course/ (12)

github.com/omran95/chat-app/pkg/infrastructure
github.com/open-ch/franz/pkg/franz

github.com/open-telemetry/ (9)

github.com/open-telemetry/opentelemetry-collector-contrib/ (5)

github.com/open-telemetry/opentelemetry-demo/ (4)

github.com/openconfig/gnmic/ (3)

github.com/openimsdk/ (3)

github.com/openimsdk/open-im-server/ (2)

github.com/openimsdk/tools/mq/kafka

github.com/opensourceways/ (5)

github.com/opensourceways/kafka-lib/ (3)

github.com/opensourceways/message-collect/ (2)

github.com/openzipkin/zipkin-go/reporter/kafka

github.com/orochi-keydream/ (4)

github.com/orochi-keydream/counter-service/ (2)

github.com/orochi-keydream/dialogue-service/ (2)

github.com/ovh/venom/executors/kafka
github.com/p-society/gc-server/kafka
github.com/palkx/vault-plugin-secrets-kafka

github.com/pallat/kafkasarama/ (2)

github.com/pandaychen/golang_in_action/sarama

github.com/patchoulitis/canalkafka-goconsumer (2)

github.com/patyukin/bs-auth/internal/queue/kafka

github.com/paulfernandosr/order-processor-golang/ (2)

github.com/perfectgentlemande/go-kafka-example/ (2)

github.com/phanitejak/kptgolib/ (5)

github.com/phetployst/sekai-shop-microservices/ (4)

github.com/philipparndt/go-kafka/ (2)

github.com/pingcap/ (5)

github.com/pingcap/ticdc/ (2)

github.com/pingcap/tiflow/ (3)

github.com/pinpoint-apm/pinpoint-go-agent/ (2)

github.com/piovani/ (3)

github.com/pirateunclejack/go-practice/ (2)

github.com/pircuser61/go_kafka/ (4)

github.com/piroyoung/uranai-kafka (2)

github.com/pitimon/kafka-mylab-noted/kafka-log-producer-demo

github.com/piyush1146115/simple-notification-service/ (2)

github.com/pmas98/ (2)

github.com/pranavnallari/go-kafka/ (2)

github.com/prasher1421/go-kafka/ (2)

github.com/praveenkumaresan/gogarage/cmd/partikey

github.com/prongbang/ (2)

github.com/prune998/kafka-offset-exporter
github.com/pthethanh/nano/plugins/broker/kafka
github.com/puneet105/job-queue/internal/queue

github.com/purposeinplay/go-commons/ (3)

github.com/qiafan666/gotato/commons/gkafka
github.com/qiaogw/pkg/logs
github.com/qicgroupdoha/go-kit/queue/kafka
github.com/qingmk/common/server
github.com/qiushenglei/gin-skeleton/internal/app/data
github.com/quangkhaidam93/go-web-server/example/kafka
github.com/quangvu30/order-go/kafka

github.com/quankori/kori-book/ (2)

github.com/quantonganh/blog/kafka

github.com/quintans/eventsourcing/ (2)

github.com/quixio/telegraf/plugins/outputs/quix

github.com/rafaelsouzaribeiro/ (5)

github.com/rafaelsouzaribeiro/golang-broker/pkg/apache-kafka

github.com/rafaelsouzaribeiro/listens-to-apache-kafka-golang/ (4)

github.com/rafalmnich/streams/ (2)

github.com/raghav1030/ (3)

github.com/raghav1030/go-kafka/ (2)

github.com/raghav1030/postgres-debezium-kafka-redis-streaming/cmd/kafka_service

github.com/rajabhishekmaurya/kafka-example/ (2)

github.com/raptor-ml/streaming-runner/internal/brokers/kafka

github.com/rauzh/ (6)

github.com/rauzh/cd-broker/sync_broker

github.com/rauzh/cd-core/ (5)

github.com/ravin-bhambhu07/ (4)

github.com/ravin-bhambhu07/cluster (2)

github.com/ravin-bhambhu07/test-cluster (2)

github.com/raystack/meteor/plugins/extractors/kafka
github.com/realmicro/realmicro/broker/kafka/sarama

github.com/redBorder/sarama-cluster (2)

github.com/redborder/sarama-cluster (2)

github.com/redpanda-data/connect/v4/internal/impl/kafka

github.com/remiges-tech/logharbour/ (2)

github.com/resonantchaos22/go-kafka-notify/ (2)

github.com/reugn/go-streams/examples/kafka

github.com/revdaalex/kafka-consumer-go (5)

github.com/ribeirosaimon/motion-go/api/internal/akafka

github.com/ricardo-ch/go-kafka/ (3)

github.com/rickgou/sarama/ (5)

github.com/riley817/go-kafka-example/ (2)

github.com/riyadennis/webservice_go/lib

github.com/rizalreza/go-kafka/ (2)

github.com/rkchv/ (5)

github.com/rkchv/auth/ (4)

github.com/rkchv/chat/lib/kafka

github.com/romanivanovminsk/kafka_helper

github.com/romannikonorov/ (2)

github.com/root-gg/kamux

github.com/ropon/cd_cmdb/ (2)

github.com/roysitumorang/laukpauk/ (2)

github.com/rulego/rulego-components/ (2)

github.com/ryanjoy0000/go-network-monitoring-tool/ (2)

github.com/ryarnyah/kafka-offset/ (2)

github.com/s0vunia/ (6)

github.com/s0vunia/auth_microservice/ (5)

github.com/s0vunia/platform_common/pkg/kafka/consumer

github.com/sagar764/go-kafka/ (2)

github.com/sainath123112/e-commerce-backend/user-service/internal/kafka

github.com/sarthakagrawal34/golang-kafka/ (2)

github.com/sb-projects/sb-login/ (3)

github.com/sciclon2/kafka-lag-go/ (3)

github.com/seedlings-calm/chat-kafka/internal/infrastructure/kafka

github.com/senyu-up/toolbox/ (3)

github.com/serenite11/market/ (2)

github.com/sergej-kurakin/http-to-kafka
github.com/sgokul961/echo-hub-post-svc/pkg/helper
github.com/sh3ll3y/promotion-service/internal/kafka
github.com/shockerjue/gffg/kafka
github.com/shortlink-org/shortlink/pkg/mq/kafka
github.com/sigmasee/sigmasee/shared/enterprise/messaging/kafka/sarama

github.com/signmem/ (9)

github.com/signmem/falcon-plus/ (2)

github.com/signmem/kafka/ (7)

github.com/singchia/frontier/ (2)

github.com/sk-pkg/kafka (2)

github.com/skapfer/dd-trace-go/contrib/IBM/sarama.v1
github.com/slilp/go-saving-money-service/common/kafka
github.com/smart-echo/micro-plugins/broker/kafka
github.com/smartwalle/mx/kafka

github.com/smutosey/kafka-client/ (2)

github.com/snowplow/snowbridge/ (3)

github.com/solumD/auth/ (5)

github.com/son-la/snorlax/internal/kafka
github.com/songzhibin97/status-neko/provide/kafka_producer

github.com/souravsk/myevent/ (4)

github.com/spothero/tools/kafka

github.com/spv-dev/auth/ (3)

github.com/srk13790/kafka-mysql-elastic/kafka

github.com/starismoon/study_geek/ (13)

github.com/stepan-pokladov/csw/server/internal/queue/kafka
github.com/steteruk/go-delivery-service/pkg/kafka
github.com/subiz/kafka
github.com/suiguo/hwlib/kafka_sarama
github.com/sujay-mahadik/kafka-go/consumer

github.com/sunreaver/antman/ (2)

github.com/supersida159/e-commerce/ (2)

github.com/surajn222/golang/ (2)

github.com/szq-123/ (2)

github.com/teamgram/marmota/pkg/mq
github.com/telekom/pubsub-horizon-go/tracing
github.com/telkomindonesia/go-boilerplate/pkg/kafka
github.com/teng231/kafclient

github.com/teran/linker/ (2)

github.com/thakurabhiv/go-kafka-demo/ (2)

github.com/thanhpv3380/ftl-common-go/ (2)

github.com/thapakazi/kfk9s/ (2)

github.com/thegeorgenikhil/pcron (2)

github.com/theo123490/hamilton/clients
github.com/thomaspoignant/go-feature-flag/exporter/kafkaexporter

github.com/tiantiandas/prototube-go (2)

github.com/tidepool-org/clinic-worker/ (9)

github.com/tillkuhn/angkor/ (2)

github.com/tizzhh/micro-banking/ (2)

github.com/torderonex/messageservice/internal/broker/kafka

github.com/tranHieuDev23/GoLoad/ (2)

github.com/treeman-zhou/code-snippet-go/db/kafka

github.com/trinhdaiphuc/go-kit/ (4)

github.com/ttraveller7/invokerlib-loader

github.com/tuanuet/retry-kafka/ (3)

github.com/uchupx/kajian-api/pkg/kafka

github.com/ucslibs/kafkasarama (4)

github.com/umerfarok/kafka-live-dashboard
github.com/umtdemr/go-kafka-with-rest-case/pkg/kafka

github.com/united-manufacturing-hub/ (5)

github.com/united-manufacturing-hub/Sarama-Kafka-Wrapper-2/ (4)

github.com/united-manufacturing-hub/Sarama-Kafka-Wrapper/pkg/kafka

github.com/ushakovn/boiler/pkg/kafka/producer

github.com/utibeabasi6/go-task-scheduler/ (2)

github.com/utr1903/ (10)

github.com/utr1903/opentelemetry-kubernetes-demo/ (4)

github.com/utr1903/opentelemetry-playground/ (6)

github.com/uttamsutariya/crypto-pulse/internal/kafka
github.com/uw-labs/substrate/kafka
github.com/uzutizd/x/kafkax

github.com/valek177/auth/ (6)

github.com/vibzz2003/go-kafka/ (2)

github.com/victorzhou123/kafka-lib/ (3)

github.com/vietthangc1/golang-pkg/kafkax

github.com/violetpay-org/ (10)

github.com/violetpay-org/event-queue/ (3)

github.com/violetpay-org/point3-quman/ (2)

github.com/violetpay-org/queue-manager/ (3)

github.com/violetpay-org/queue-streamer (2)

github.com/vladislavninetyeight/service/internal/services/post

github.com/vmware/go-ipfix/ (3)

github.com/vmyroslav/sarama-health (2)

github.com/vnscriptkid/kafka-fluency/ (2)

github.com/vuvietnguyenit/golibs/ (4)

github.com/warpstreamlabs/bento/ (2)

github.com/waryataw/ (6)

github.com/waryataw/auth/ (5)

github.com/waryataw/platform_common/pkg/kafka/consumer

github.com/wesrobin/chat-er-x3/ (3)

github.com/wfusion/gofusion/ (3)

github.com/wgarbaya/sarama-oauth-jwtbearer

github.com/willjrcom/kafka-golang/ (2)

github.com/wkRonin/toolkit/saramax

github.com/wonksing/ (6)

github.com/wonksing/go-tutorials/ (4)

github.com/wonksing/si/ (2)

github.com/wwzz0314/gochat/ (3)

github.com/wx-up/go-book/ (5)

github.com/xbdxzx520/webook/ (19)

github.com/xiaoshanjiang/my-geektime/ (3)

github.com/xlsa/erda/ (4)

github.com/xuhaidong1/go-generic-tools/pluginsx/saramax
github.com/xwc1125/xwc1125-pkg/database/kafka

github.com/xxm404/k-console (2)

github.com/yakob-abada/go-kafka

github.com/yamakiller/velcro-go/ (2)

github.com/yanglunara/im/ (3)

github.com/ydssx/kratos-kit/pkg/client/kafka
github.com/yogenyslav/pkg/infrastructure/kafka

github.com/yoshihiro-shu/ (4)

github.com/yoshihiro-shu/examples/ (2)

github.com/yoshihiro-shu/financial-bot/ (2)

github.com/yueja/go-kafka/ (3)

github.com/yvyrovyi-cinemo/utils/kafkalib

github.com/yyxxgame/gopkg/ (2)

github.com/zccxyz/devpkg/ (2)

github.com/zeimedee/saber/ (2)

github.com/zhaozuodong/gomitmproxy/middlewares

github.com/zheng11581/ (2)

github.com/zhetkerbaevan/messaggio-test-task/internal/kafka

github.com/zhihanii/im-pusher/ (5)

github.com/zhoujubhong/kafkaclient
github.com/zhufuyi/sponge/pkg/kafka

github.com/zigamedved/go-kafka-demo/ (2)

github.com/zijiren233/logrus-kafka-hook

github.com/zmloong/lotus/ (2)

github.com/zoueature/mq/ (2)

github.com/zp857/goutil/kafka
github.com/zuzi90/tz-enricher/internal/providers/kafka

gitlab.com/18la008c/exercise-golang/ (3)

gitlab.com/eemj/image-processor/ (3)

gitlab.com/golang-libs/mosk.git/interfaces/kafka/sarama
gitlab.com/le9ru/erp_proto/pkg/timeline
gitlab.com/matchsystems-golang/kafka
gitlab.com/sean.moranMI/infra_go_libs/message_broker

gitlab.com/t6085/minio/ (2)

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

gitlab16.skiftrade.kz/libs/ (2)

go.jamie.mt/toolbox/ (2)

gocloud.dev/pubsub/kafkapubsub
gopkg.in/DataDog/dd-trace-go.v1/contrib/IBM/sarama.v1

knative.dev/eventing-kafka-broker/ (14)

kubedb.dev/db-client-go/kafka

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL