kafka

package

Go to main page

Known importers: 3,202 (displaying 3,625 packages, including internal and invalid packages)

bitbucket.org/4s/go-messaging/ (2)

bitbucket.org/airenas/listgo/ (2)

bitbucket.org/chattigodev/chattigo-golang-kafka-library/ (3)

bitbucket.org/danamas/common-lib/stdlib/kafka
bitbucket.org/danielper/util/msg
bitbucket.org/patrick_herrmann/mps_go_messaging
bitbucketdc.careem-internal.com/scm/cp/go-microservice.git/pkg/events/kafka
code.afis.me/go-nano-services/modules/database/lib/kafka
git.chocodev.kz/go-tools/events/kafka
git.halomobi.net/common/halolib/kafka
git.mindsmiths.com/vingd/go-vingdmind-utils/kafkaworker
git.proto.group/protoobp/pobp-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
gitcode.net/common_go/producer/kafka
gitee.com/common_go/producer/kafka

gitee.com/fatzeng/srf_switch_expansion_package/ (5)

gitee.com/gomods/ (2)

gitee.com/wuzy830/ (2)

github.com/04Akaps/ (3)

github.com/04Akaps/gateway_module/kafka

github.com/04Akaps/kafka-go/ (2)

github.com/0angelic0/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/0michalsokolowski0/watermill/message/infrastructure/kafka

github.com/0xAckerMan/movieapp-ms/ (2)

github.com/1123/golang-kafka-client-kubernetes

github.com/1412270/gokafka (2)

github.com/1Prestes/gointensivo2/ (2)

github.com/3dsinteractive/ (23)

github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/ (9)

github.com/3dsinteractive/automation-technology/ (13)

github.com/3dsinteractive/tcir-app

github.com/3rs4lg4d0/ (4)

github.com/3rs4lg4d0/go-kafka-checker

github.com/3rs4lg4d0/goutbox/ (3)

github.com/64bitAryan/go-microservice/data_receiver
github.com/84codes/cloudkafka-benchmarks
github.com/8xmx8/easier/pkg/amqp/confluent

github.com/AVENTER-UG/ (2)

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

github.com/Aamir-Lone/go-kafka/ (2)

github.com/Abbas-gheydi/kafka-tiny-tools/internal/kafkat

github.com/AdrianeRibeiro/ (4)

github.com/AdrianeRibeiro/CodePix/ (2)

github.com/AdrianeRibeiro/ImersaoFullCycle/ (2)

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

github.com/Aldiwildan77/backend-skeleton/ (2)

github.com/AlexsJones/frontier/components/kafka

github.com/AndersonQ/ (3)

github.com/AndersonQ/gokafka (2)

github.com/AndersonQ/talks/2022.03.10.Golang.Live

github.com/Arkhandyr/FullCycle/ (2)

github.com/ArnaudGallardo/ (3)

github.com/ArnaudGallardo/rocktest-core

github.com/ArnaudGallardo/rocktest-go/ (2)

github.com/ArtemVoronov/ (4)

github.com/ArthurDias01/imersaofsfc2-simulator (3)

github.com/Azure/azure-event-hubs-for-kafka/ (3)

github.com/BaianorASR/ifc2-simulator/infra/kafka
github.com/Basic-Components/connecthelper/kafkahelper

github.com/Beeketing/confluent-kafka-go/ (11)

github.com/BladeCKG/blockhouse-realtime-data-streaming-api-golang/mykafka
github.com/BlakeASmith/DistributedWebScraping/go/src
github.com/Boklazhenko/kafka

github.com/Brigant/AGS/ (3)

github.com/BroadbandForum/obbaa-477/ (2)

github.com/Bruno-Casas/imersao-fullstack-fullcycle/ (2)

github.com/BrunoC0102/imersao-fullcycle-13/ (2)

github.com/BrunoRHolanda/imersao-fullstack-fullcycle/ (2)

github.com/Carlos-Descalzi/mtjobrunner/pkg/controller/mtjobrunner

github.com/CelsoTaliatelli/ (4)

github.com/CelsoTaliatelli/ms-walletconsumer/ (2)

github.com/CelsoTaliatelli/ms-walletcore/ (2)

github.com/ChAngLEx/Myproject/common

github.com/Chavozoom/go-Kafka/ (2)

github.com/CheesecakeLabs/token-factory-v2/backend/pkg/kafka
github.com/Corner-W/sk/mque/kfk
github.com/Cray-HPE/hms-trs-app-api/v2/pkg/trs_http_api
github.com/Cristianoaf81GIT/codebank/infrastructure/kafka

github.com/CrowdStrike/kafka-replicator/ (7)

github.com/CyberhavenInc/confluent-kafka-go/ (22)

github.com/DanTulovsky/web-static/server

github.com/DaniloCalegaro/bolsa-valores/ (2)

github.com/Danny5487401/go_package_example/ (5)

github.com/DataDog/ (17)

github.com/DataDog/confluent-kafka-go/ (7)

github.com/DataDog/data-streams-go/integrations/kafka

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

github.com/DataDog/kafka-kit/ (6)

github.com/Deciohanda/gointensivo/ (2)

github.com/DevotedHealth/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/Didafe/devfullcycle-imersao13-go/ (2)

github.com/Dioneprey/homebroker-fullcycle/ (2)

github.com/Dmitrij-Kochetov/peoples/ (2)

github.com/Drinnn/kool-pix/ (2)

github.com/EBWi11/AgentSmith-HIDS/agent_golang/common
github.com/EdSwArchitect/go-kafka

github.com/Eduardo0725/imersao-fullstack-fullcycle/ (2)

github.com/EfimoffN/receivingLogs/dbapi/kafkadb

github.com/EliasOlie/IFF-Kafka/ (2)

github.com/EliasSantiago/kafka-example/infra/kafka
github.com/Enflick/statemachine2
github.com/EvertonLMsilva/api-avulso/internal/infra/akafka
github.com/Feruz666/gokafka/producer

github.com/GODPARK/KafValidator/ (2)

github.com/Gabriel-P22/home_broker_go/ (2)

github.com/Gabriel962008/code-delivery/simulador/infra/kafka

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

github.com/GabrielMessiasdaRosa/imersao_fullcycle/ (2)

github.com/GenEars/kafka2websocket/k2ws
github.com/GiairoZeppeli/utils/kafka
github.com/GirishBhutiya/mqtt-kafka-bridge/internal
github.com/GoPlugin/pluginV2Lib/pluginV2-relay/pkg/monitoring

github.com/Goboolean/ (7)

github.com/Goboolean/common/ (2)

github.com/Goboolean/fetch-server.v1/internal/infrastructure/kafka

github.com/Goboolean/fetch-system.IaC/ (2)

github.com/Goboolean/fetch-system.infrastructure/pkg/kafka
github.com/Goboolean/fetch-system.worker/internal/infrastructure/kafka

github.com/Golang-Tools/kafkahelper/ (3)

github.com/GuiCintra27/go/ (2)

github.com/Guilherme-daCosta/go-mensageria-products/ (2)

github.com/GuilhermeBiavati/imersao-fullstack-fullcycle/ (2)

github.com/GustavoEklund/payment-gateway-api/ (2)

github.com/HTM1000/homebroker/ (2)

github.com/Halgenthaler/System-Delivery (3)

github.com/Harmew/imersao12-go-esquenta/ (2)

github.com/HyAgOsK/home_broker_full_cycle/ (2)

github.com/IBM/world-wire/ (3)

github.com/IPreferWater/kafka_bees/kafkabee
github.com/IRSHIT033/E-comm-GO-/server/Order_service/kafka_consumer
github.com/Israelsodano/msgb/msgb_kafka

github.com/ItaloG/full-cycle-walletcore/ (2)

github.com/JPauloMoura/payment-gateway/ (2)

github.com/JacksonFA/codebank/infra/kafka
github.com/JeffRisberg/LiveProjectAsynchronousEventsWithKafka/publisher
github.com/Jefschlarski/ps-intelbras-iot/telemetry_consumer/src/kafka
github.com/JingIsCoding/kafka_job_queue
github.com/JoaoRafa19/codepix/application/kafka

github.com/JonatasMSantos/golang-apis-messaging-hexagonal-architecture/ (2)

github.com/JordanRad/notification-system-assignment/ (2)

github.com/JuanDiegoCastellanos/kafka_golang

github.com/Julio-Norberto/api-message/ (2)

github.com/JulioOLV/codebank/infrastructure/kafka

github.com/JulioZittei/homebroker-matcher-go/ (2)

github.com/Junkes887/queues/ (2)

github.com/Karosso/fullcycle10.0/ (3)

github.com/KaueSabinoSRV17/DeliveryGoSimulator (2)

github.com/KoddiDev/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/KumKeeHyun/PDK/logic-core/kafkaConsumer/confluent
github.com/LeandroMelloo/simulador-golang/infra/kafka

github.com/Lemos1347/inteli-modulo-9-prova-2/ (2)

github.com/LoniasGR/hyperledger-fabric-sla-chaincode/ (6)

github.com/LostPetInitiative/CardMatcher/kafkajobs

github.com/Lucas-Mondini/code-pix/ (2)

github.com/Lucasnhso/codepix-go/ (2)

github.com/LuizAdamchuk/dmchk-cordinate-simulator (3)

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

github.com/MarcosRibeiroJesus/Stock-Exchange/ (2)

github.com/Mardiniii/go-kafka-poc/ (2)

github.com/MatheusJFA/Imersao_FullCycle/ (2)

github.com/MatheusNP/fc-ms-wallet/ (2)

github.com/MihasBel/test-transactions-service/adapters/broker
github.com/MohitArora1/gallery/controller

github.com/MorselShogiew/UsersManager/ (2)

github.com/MyBudgetPtyLtd/kstream/ (2)

github.com/NonTechCompany/go-kafka-restful/kafka_event
github.com/Octops/agones-event-broadcaster/pkg/brokers/kafka
github.com/OpenFactor-Holding/superapp/kafka

github.com/PIMPfiction/confluent-kafka/ (2)

github.com/PedroGuilhermeSilv/codepix/ (2)

github.com/PharbersDeveloper/bp-go-lib/kafka

github.com/RafaZeero/fullcycle-fullstack-imersao8 (2)

github.com/RafaelDalarosa/fc-bank/infra/kafka

github.com/ReshiAdavan/CryptGO/ (5)

github.com/SadesTorm/imersao-fullstack-fullcycle/ (2)

github.com/SardorSaidov8084/restaurant-payment-service/src/application/integration_events/handlers/card_created
github.com/SerkanKutlu/orderService/pkg/kafka

github.com/Shemistan/uzum_delivery/ (2)

github.com/ShobenHou/monitor/ (4)

github.com/SourceFellows/confluent-kafka-go/ (22)

github.com/Soyaka/microlearn-entitment/ (2)

github.com/StevanoZ/dv-shared/ (2)

github.com/Swiggy/grill/ (2)

github.com/THreeDotsLabs/watermill/message/infrastructure/kafka
github.com/TechMaster/LearnGo/Kafka
github.com/Telefonica/prometheus-kafka-adapter
github.com/ThreeDotsLabs/Watermill/message/infrastructure/kafka
github.com/Tracking-SYS/go-lib/kafka
github.com/Traff1k/demo-kafka-producer/kafka
github.com/TubularBlockchain/kafka_consumer

github.com/TykTechnologies/graphql-go-tools/ (2)

github.com/TylerAldrich814/MetaReviews/rating/internal/ingester/kafka
github.com/WeOps-Lab/rewind/pkgs/kafka
github.com/YAOYouYou/go-toolkit/kafka
github.com/a-tr/go_consumer/controller

github.com/aaron-zeisler/kafka-the-definitive-guide/ (4)

github.com/aayush-agarwal1/kafka
github.com/abhaynpai/go-benchmark-kafka-api/producer

github.com/abhirajranjan/spaces/ (23)

github.com/aboronilov/go-kafka-microservices/data_receiver
github.com/accuknox/auto-policy-discovery/src/feedconsumer

github.com/achillesss/jupiter/ (2)

github.com/aclk/goblog/common/kafka
github.com/acmutd/bsg/central-service/services

github.com/adaickalavan/ (5)

github.com/adaickalavan/machine-learning-deployment-extended/govideo

github.com/adaickalavan/machine-learning-deployment/ (3)

github.com/adaickalavan/scalable-deployment-kubernetes-extended/govideo

github.com/adamatti/sandboxgo/Kafka

github.com/adanfm/fc2-gokafka/ (2)

github.com/addodelgrossi/kc

github.com/adelblande/codepix/ (2)

github.com/adevinta/graph-vulcan-assets/stream/kafka
github.com/adheipsingh/kafka
github.com/aditya37/go-kafka-connector
github.com/adlindo/gocom/pubsub

github.com/adri-fernandes/imersao-fullstack-fullcycle/ (3)

github.com/adrianacarvsilva/fullcycle-gokafka/ (2)

github.com/adriangrahl/points-simulator (2)

github.com/adrianostankewicz/ms-consolidacao/ (3)

github.com/adryhappier/gin-kafka-mongo/src/handlers/job

github.com/aeekayy/stilla/ (2)

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

github.com/afandylamusu/go-boilerplate

github.com/agalue/ (3)

github.com/agis/confluent-interceptor-segfault

github.com/agriuseatstweets/ (2)

github.com/ahmad-khatib0/go/ (2)

github.com/ahmadfajar92/flexible-plate/go/src

github.com/ahugofreire/ (5)

github.com/ahugofreire/car-simulator-freight/ (2)

github.com/ahugofreire/simulator (3)

github.com/aifaniyi/kafkaclient

github.com/airenas/listgo/ (2)

github.com/airingone/air-kafkaclient
github.com/ajlima/go-ms-arch-example/cmd

github.com/ajvideira/imersao-fullstack-fullcycle/ (2)

github.com/akalmyk/kafker

github.com/akhripko/dummy/ (2)

github.com/akkeris/logshuttle/ (2)

github.com/akolybelnikov/xm-exercise/internal/kafka

github.com/alanunesouza/fc-kafka/ (2)

github.com/aldenfachetti/go-intensive-devFullCycle/ (2)

github.com/aleksbgs/ambassador/src/controllers

github.com/alekseiapa/go-kafka-examples/ (2)

github.com/aleszilagyi/kafka-golang-api/ (2)

github.com/alex-bezverkhniy/calltester/pkg/services

github.com/alexandrecpedro/fullcycle/ (2)

github.com/alexandrejuniorc/ms-homebroker-go/ (2)

github.com/alexdsayandexru/sorm/internal/kafka

github.com/alexm4tos/code-delivery/ (3)

github.com/alfredyang1986/blackmirror/bmkafka
github.com/aliforever/gocom/pubsub
github.com/alifpay/training/kafka

github.com/alistairking/confluent-kafka-go/ (19)

github.com/aliyun-sls/ (2)

github.com/alkoenig09/confluent-kafka-go/ (19)

github.com/alokic/queue/app/dispatcher/queue/kafka

github.com/alonsofritz/simple-api-kafka-go/ (2)

github.com/alphazero/confluent-kafka-go/ (7)

github.com/alrusov/kafka (2)

github.com/amanaation/backend_microservice_go
github.com/amato1oveing/ctool/kafka
github.com/amendge/go/transfer/kafka
github.com/amient/goconnect/io/kafka1
github.com/amiranmanesh/octalbit-utils/socket/kafka

github.com/amirhossein2831/message-brokering/ (2)

github.com/amirphl/lottery-game/ (2)

github.com/amrHassanAbdallah/notificationaway/test
github.com/amruthpremjith/kafka-consumer-test/consumer
github.com/andiveloper/eventor/pkg

github.com/andrefsilveira1/ (6)

github.com/andrefsilveira1/kafka/ (2)

github.com/andrefsilveira1/microservices/ (4)

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

github.com/andrepreira/homebroker_app/ (2)

github.com/andrerampanelli/ (4)

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

github.com/andrerampanelli/gokafka/ (2)

github.com/andrew-hillier/protocol-buffers

github.com/andrewunifei/SOLID-system/ (2)

github.com/andsleonardo/confluent-kafka-go/kafka/go_rdkafka_generr

github.com/angelospanag/throttle-api-using-kafka-poc (3)

github.com/animber-coder/gokafka

github.com/ant-libs-go/kafka/ (2)

github.com/antalakas/stream-structs
github.com/anthonyhartanto/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/anti-duhring/easy-shipping-microsservice/ (2)

github.com/antifuchs/mz-certificate-transparency

github.com/antonialucianapires/aplicacao-exemplo-kafka-go-fc/ (2)

github.com/apontes77/imersao-fullstack-fullcycle/ (2)

github.com/arashbina/ (2)

github.com/architecture-it/go-platform/AMQStream

github.com/arcosx/Sirius/ (4)

github.com/argoproj-labs/argo-dataflow/ (4)

github.com/ariandi/kilat-be-go1

github.com/arieuqis/go_training/ (2)

github.com/aristofaneslira/curso-fullcycle/go/internal/market/entity/infra/kafka

github.com/arkhn/fhir-river/ (4)

github.com/arriqaaq/gkc

github.com/arshabbir/ (2)

github.com/artembudaiev/feeder/internal/kafka

github.com/arthben/basic_kafka/ (2)

github.com/arthurpedroti/go-project/ (2)

github.com/ashishbabar/go-eth-api-contract-service/utils
github.com/asiragusa/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/aslakjohansen/dde-mdds/ (5)

github.com/astronomerio/ (10)

github.com/astronomerio/clickstream-ingestion-api/ (2)

github.com/astronomerio/cs-event-api/ (2)

github.com/astronomerio/cs-event-router/ (2)

github.com/astronomerio/event-api/ (2)

github.com/astronomerio/event-router/ (2)

github.com/atsu/goat/ (3)

github.com/autoluck/go-kafka/test
github.com/avisiedo/go-microservice-1/internal/interface/presenter/event

github.com/aw-was-here/confluent-kafka-go/ (2)

github.com/axelgeorg/ImersaoGo_03022023/ (2)

github.com/axell-brendow/full-cycle-2.0-kafka/ (2)

github.com/ayrtonbsouza/poc-go-kafka/ (2)

github.com/azure/azure-event-hubs-for-kafka/ (3)

github.com/bac-ta/bigdata/ (3)

github.com/bacamargo/invest-dash-with-home-broker/go/internal/infra/kafka

github.com/bahalla/lets-chat-golang/ (2)

github.com/baisang/beaver
github.com/banqinghong/screws/golang/kafka
github.com/baolq2020/bngobe/services
github.com/basebandit/bookshop/server/cmd/ratingingester
github.com/batasrki/ppe4peeps/handlers

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

github.com/bayudava29/go-kafka-producer (2)

github.com/bcowtech/ (3)

github.com/bcowtech/lib-kafka

github.com/bcowtech/worker-kafka (2)

github.com/beeketing/confluent-kafka-go/ (11)

github.com/bellacbs/Delivery/ (3)

github.com/bengtrj/simple-kafka-producer

github.com/beriloqueiroz/desafio-dev-back/ (4)

github.com/betNevS/code-examples/ (2)

github.com/bharat-rajani/ (5)

github.com/bharat-rajani/cloudoreg/ (2)

github.com/bharat-rajani/kafka-transactions-golang (3)

github.com/biancanobrega/imersao-fullstack-fullcycle/ (2)

github.com/bioform/go-web-app-template/config

github.com/bjsneto/fc-kafka/ (2)

github.com/blackhorseya/ethscan/ (3)

github.com/blacklane/go-libs/ (8)

github.com/blendle/ (7)

github.com/blendle/go-streamprocessor/ (6)

github.com/blendle/pg2kafka

github.com/blueturbo-ad/go-utils/kafka_client

github.com/bmurase/codepix/ (2)

github.com/bobhonores/somello/ (2)

github.com/bondzai/portfolio-backend/pkg/kafka

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

github.com/bookrun-go/guiche

github.com/bosshentai/ (5)

github.com/bosshentai/fullcycle-challenge/ (2)

github.com/bosshentai/imersao2022/ (3)

github.com/box-delivery/kafka-go

github.com/brandaogabriel7/full-cycle-go-intensivo/ (2)

github.com/brenno-calado/position_simulator (3)

github.com/brettcodling/kafkalib
github.com/briansorahan/kafka-admin

github.com/brimb0r-org/eq/ (2)

github.com/brnocorreia/home-broker/ (2)

github.com/bro-n-bro/spacebox-writer/adapter/broker

github.com/brunoan99/fc-kafka/ (3)

github.com/brunocordeiro180/gokafka/ (2)

github.com/brunocotto/fullcycle-immersion/ (2)

github.com/brwillian/kafka-consumer-api (2)

github.com/btubbs/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
github.com/bucaojit/PolygonTools/streamer

github.com/burhankangsi/ (2)

github.com/bygui86/ (9)

github.com/bygui86/go-kafka/ (5)

github.com/bygui86/go-traces/ (4)

github.com/bytemoves/toll-calculator/distance_calculator

github.com/caiquebb/imersao-fullstack-fullcycle/ (2)

github.com/caiquetgr/fullcycle_courses/ (2)

github.com/callistaenterprise/goblog/common/kafka

github.com/calvinwijya/go-streaming (2)

github.com/caoloss/-serverless-event-gateway-connectorpy/sources/kafka

github.com/captain-corgi/go-kafka-example/ (2)

github.com/caraml-dev/ (2)

github.com/carloskenny/imersao13fullcycle/ (2)

github.com/carstenmichel/godmpkfk
github.com/carwale/golibraries/kafka

github.com/cassiodavid/go-kafka-mysql (2)

github.com/cassioglay/simulator (3)

github.com/ccr5/bootcamp-dev-fullcycle-go-microservice/ (2)

github.com/cezarzaleski/fullcycle/ (2)

github.com/chandresh-pancholi/edith/pkg/kafka/admin
github.com/changlex/myproject/common

github.com/charles00willian/kafka-go-starter/ (2)

github.com/charliemcelfresh/practical_go_patterns/ (2)

github.com/chow1937/confluent-kafka-go/ (7)

github.com/chris-han-nih/avro-kafka-golang/ (2)

github.com/christian-elsee/kafka/pkg
github.com/christianvozar/hex-example/internal/adapter/kafka
github.com/chuahjw/kafka-prometheus-exporter

github.com/chudjane-scg/kafka/ (2)

github.com/ciblele/siemens-energy/Rascunhos

github.com/clebersimm/fc-ms-wallet/ (2)

github.com/cleysonsilvame/imersao10-full-cycle/ (3)

github.com/clferracin/minientregas-simulator/infra/kafka

github.com/cloud-barista/cb-dragonfly/ (4)

github.com/cloudkarafka/ (3)

github.com/cloudkarafka/cloudkarafka-manager/ (2)

github.com/cloudkarafka/go-kafka-example

github.com/cloudzp/booklet/golang/src/kafka-client
github.com/clunc/hr-monitor-ble-server/pkg/kafka
github.com/cmparrela/go-clean-architecture/infrastructure/kafka

github.com/codeedu/fc2-gokafka/ (2)

github.com/codingDr/watermill-kafka/pkg/kafka

github.com/codingpierogi/streaming-demo/ (4)

github.com/colivi/confluent-kafka-go/ (19)

github.com/common-go/kafka/confluent

github.com/comp1x/final-task/ (2)

github.com/confluentinc/ (61)

github.com/confluentinc/cli/ (3)

github.com/confluentinc/confluent-kafka-go-dev/ (13)

github.com/confluentinc/confluent-kafka-go-example

github.com/confluentinc/confluent-kafka-go/ (41)

github.com/confluentinc/schema-deletion-tool/pkg

github.com/confluentinc/telemetry-reporter-go/ (2)

github.com/consolelabs/ (2)

github.com/contrerasarf03/kafka-client

github.com/corabank/ (2)

github.com/core-go/ (2)

github.com/corluk/go-utils (2)

github.com/cornelia247/nyxfilms/rating/internal/ingester/kafka

github.com/cotriml/go-api-and-kafka-messaging/ (2)

github.com/coulterac/kafka/ (2)

github.com/covaw/kafka-go/kafkatool
github.com/cpustejovsky/franz
github.com/criistiiandm/kafka-server/go/kafkaPlugin

github.com/cristovaoolegario/ (5)

github.com/cristovaoolegario/cartola/ (3)

github.com/cristovaoolegario/tasks-api/ (2)

github.com/cronnay/lol-crawler (2)

github.com/cshari-zededa/kafka-self-topic
github.com/cwaeland/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/cyberhaveninc/confluent-kafka-go/ (22)

github.com/d7561985/ (20)

github.com/d7561985/confluent-kafka-go/ (19)

github.com/d7561985/kafka-ab/adapter/conf-kafka

github.com/daib/confluent-kafka-go/ (22)

github.com/dalbarracin/kafka-golang-example/internal/kafka

github.com/dan36poars/simulator-gps (3)

github.com/danielamazonas/imersao-fullstack-fullcycle/consumer

github.com/danielmunro/ (8)

github.com/danielmunro/otto-community-service/ (2)

github.com/danielmunro/otto-image-service/ (2)

github.com/danielmunro/otto-notification-service/internal/kafka

github.com/danielmunro/otto-user-service/ (3)

github.com/danielrocha1/functionmysql/ (2)

github.com/daniil-kzn/graphql-go-tools/examples/kafka_pubsub/transactional_producer

github.com/danilobandeira29/ (3)

github.com/danilobandeira29/ms-wallet-balance/internal/kafka

github.com/danilobandeira29/ms-wallet/ (2)

github.com/danyukod/ (7)

github.com/danyukod/chave-pix-utils/pkg/kafka

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

github.com/danyukod/wallet-core-event-listener/ (3)

github.com/danyukod/wallet-core-go/cmd/walletcore

github.com/darccio/dd-trace-go/v2/contrib/confluentinc/confluent-kafka-go/kafka

github.com/darrenyjq/kratos-md/ (2)

github.com/darth-raijin/gafka-binance/internal/kafka
github.com/data-mill-cloud/mastro/commons/sources/kafka
github.com/datacircus/highwire/service/server

github.com/datadog/confluent-kafka-go/ (7)

github.com/datasage-io/datasage/src/integrations

github.com/dateiexplorer/dhbw-kafkaapplications/ (2)

github.com/david34corbalan/aula-challenge (5)

github.com/davidalecrim1/go-kafka-example/ (3)

github.com/davidoram/webhookd/ (2)

github.com/dawei101/gor/rkafka
github.com/db-sara/kafkake
github.com/dbi-digital-analytics/fungjai/webhook/producer

github.com/dchukmasov/graphql-go-tools/ (2)

github.com/debman/blacklog-exporter/internal/kafkaclient
github.com/dedihartono801/go-clean-architecture/infrastructure/kafka

github.com/deemanthak/bettingsupporters/ (2)

github.com/deepfence/PacketStreamer/pkg/plugins/kafka
github.com/deeptiman/go-cache-kubernetes/kafka

github.com/deividroger/ (4)

github.com/deividroger/gokafka/ (2)

github.com/deividroger/ms-wallet/ (2)

github.com/delapaska/kafka-golang (3)

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

github.com/deni1688/exercise_tracker/mykafka

github.com/denisfilisov/logsservice/ (4)

github.com/denison3965/CodePix/ (2)

github.com/denizumutdereli/ (3)

github.com/denniskern/kafka-producer-test
github.com/derekyu332/goii/frame/kafka

github.com/despondency/notifications-service/ (2)

github.com/dev-full-cycle/simulator (3)

github.com/devAndre-Isaac/simulator-full-cycle (3)

github.com/devfans/net-kafka-repeater/repeater

github.com/devfullcycle/ (12)

github.com/devfullcycle/gointensivo2/ (2)

github.com/devfullcycle/imersao-12-esquenta-kafka/ (2)

github.com/devfullcycle/imersao12-go-esquenta/ (2)

github.com/devfullcycle/imersao13/ (2)

github.com/devfullcycle/imersao14/ (2)

github.com/devfullcycle/imersao21/ (2)

github.com/devharshgupta/kafka-message-scheduler/common/kafka
github.com/devotedhealth/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/dfuse-io/dkafka

github.com/dialogs/dialog-go-lib/ (3)

github.com/dianhadi/mq/pkg/mq/kafka
github.com/diasjuniorr/code-commerce/codebank/infrastructure/kafka

github.com/diegojacober/bolsa/ (2)

github.com/diegopacheco/go-playground/kafka

github.com/diegoxa/kafka-docker/ (2)

github.com/digitalocean/firebolt/ (6)

github.com/digvijaywagh22/trial

github.com/dikyayodihamzah/connex-bot (2)

github.com/diogofgomespinheiro/fc-go-kafka-example/cmd/producer

github.com/dionerweiss/fc-ms-wallet/ (2)

github.com/discomco/go-cart/sdk/drivers/kafka
github.com/disturb16/kafkaclient

github.com/divyajain44/fundamentals-of-golang/ (2)

github.com/dkienzle/network-monitor/pcap_kafka

github.com/dmitryzzz/grpc-example/ (2)

github.com/dmkorzh/history-service/cmd/call-collector

github.com/dnadocodigo/dnadocodigo.fullcycle.go.io/ (2)

github.com/doki-programs/kavka-nest (3)

github.com/dominickbrasileiro/ (5)

github.com/dominickbrasileiro/code-delivery/ (3)

github.com/dominickbrasileiro/debezium-kafka-go/ (2)

github.com/dongrv/baselib/rabbitmq

github.com/donvito/learngo/ (4)

github.com/dopefresh/banking/ (4)

github.com/dorianneto/ (5)

github.com/dorianneto/codepix/ (2)

github.com/dorianneto/delivery-simulator/ (3)

github.com/dot-backend/synergetic-craft/ (2)

github.com/doublegrey/rest2kafka

github.com/dougecomp/kafka-go-example/ (3)

github.com/douglarek/kafka-tools (3)

github.com/douglira/go-grpc/ (4)

github.com/dsperax/pix-payment/ (2)

github.com/duclmse/fengine/ (3)

github.com/dueruen/learning-kubernetes/ (2)

github.com/dumunari/codebank/infrastructure/kafka
github.com/duyanh1904/learn-docker-go/worker

github.com/duysmile/kafka-go-simple/ (2)

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

github.com/dyegocaldeira/fleet-freight-calculator/ (2)

github.com/e-nikolaev/OTUS_Go_hw/ (3)

github.com/ebilsanta/social-network/backend/complex_services/follower_complex_service/services
github.com/edfungus/eevee

github.com/edlanioj/kafka-challenge-go/ (2)

github.com/ednelsonap/gokafka/cmd/producer

github.com/edsonfire/simulator (3)

github.com/eduardotecnologo/Homebroker/ (2)

github.com/edujudici/imersao-golang-kafka/ (2)

github.com/edupooter/intensivo-golang/ (2)

github.com/edwildson/go-api-with-kafka/ (2)

github.com/egravert/kafka-samples/manual-commit

github.com/eko/ (23)

github.com/eko/confluent-kafka-go/ (21)

github.com/eko/opentelemetry-go-contrib/ (2)

github.com/eldersonjls/ms-wallet-core/ (2)

github.com/eliasfeijo/wallet-fc/ (2)

github.com/eliashenriqueferreira/codepix/ (2)

github.com/elielsimoncelo/kafka-start/ (2)

github.com/eliweltonmoreira/gokafka/ (2)

github.com/ellofae/payment-system-kafka/ (4)

github.com/eltonfonseca/codebank/infra/kafka

github.com/emilebui/ (7)

github.com/emilebui/demoX-rk_api/ (2)

github.com/emilebui/demoX-rk_worker/ (5)

github.com/emmanuelneri/microservices-orchestration/ (2)

github.com/emmanueluwa/tolling/ (2)

github.com/emmanuelviniciusdev/ (4)

github.com/emmanuelviniciusdev/imersao-fullcycle-apache-kafka/ (2)

github.com/emmanuelviniciusdev/imersao-fullcycle-event-driven-architecture/ (2)

github.com/en/siren/ (5)

github.com/eng-gabrielscardoso/exchange-core/ (2)

github.com/engendromestre/homebrocker/ (3)

github.com/enkodio/ (6)

github.com/enkodio/pkg-kafka/ (5)

github.com/enkodio/pkg-outbox/internal/pkg/config/entity

github.com/entropyx/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/erda-project/ (4)

github.com/erda-project/erda-infra/ (2)

github.com/erda-project/erda/ (2)

github.com/erdemkosk/box_bridge/ (2)

github.com/erenkaratas99/COApiCore/ (2)

github.com/erikfelipe/imersao_fullcycle/ (2)

github.com/erikurbanski/codebank/infrastructure/kafka
github.com/ernestrc/logd-go/lua

github.com/ernstvorsteveld/go-cv-cassandra/ (3)

github.com/ervitis/go-kafka-client

github.com/etf1/ (4)

github.com/etf1/kafka-message-scheduler-admin/ (2)

github.com/etf1/opentelemetry-go-contrib/ (2)

github.com/ethanhosier/go-kafka

github.com/evoila/ (2)

github.com/ewencp/confluent-kafka-go/ (7)

github.com/exherb/confluent-kafka-go/ (14)

github.com/exsmund/grpc-psql-example/ (2)

github.com/fabbaraujo/imersao-01-codepix-go/ (2)

github.com/fabioalmeida132/go-consolidador/ (3)

github.com/fabiohvieira/sales/ (2)

github.com/fabiojapa/saka-golang-kafka-producer

github.com/fabioods/go-with-kafka/ (2)

github.com/fabiotavarespr/liveProject-asynchronous-event-handling/ (2)

github.com/fablopes/InvestIQ/ (2)

github.com/fabriciormeneses/go_microservice/ (2)

github.com/fairyhunter13/kafkaclient

github.com/fanticheli/delivery-monitoring/ (3)

github.com/faruan/ (4)

github.com/faruan/codebank/infrastructure/kafka

github.com/faruan/fullcycle-simulator-aluno (3)

github.com/featurebasedb/featurebase/ (5)

github.com/felipeagger/kafka-golang/producer

github.com/felipecostaaraujo/imersao13/ (2)

github.com/felipedesenna/stockexchange/ (2)

github.com/felipefa/imersionfsfc2/ (3)

github.com/felipemarques/imersao-fullcycle-simulator (3)

github.com/felixvicent/code-delivery-simulator (3)

github.com/fernandoguide/imersaofsfc2-simulator/ (3)

github.com/fgnanni/fullcycle-go-intensivo-calculo-de-taxas/ (2)

github.com/fiddeb/fwpolicymetrics/cmd

github.com/figma/confluent-kafka-go-dev/ (13)

github.com/figmagit/confluent-kafka-go-dev/ (13)

github.com/filipefranz/kafka/ (2)

github.com/finncolman/confluent-kafka-go/ (19)

github.com/flant/negentropy/ (2)

github.com/flaviomdutra/ms-wallet-core/ (2)

github.com/flaviosenne/fullcycle-3/ (2)

github.com/fle4a/transaction-system/ (3)

github.com/flpcastro/ (6)

github.com/flpcastro/fullcycle-repository/ (4)

github.com/flpcastro/golang-kafka-impl/ (2)

github.com/flurn/callisto/ (3)

github.com/flushentitypacket/kafka-playground
github.com/fogcloud-io/fn-amqp-to-kafka

github.com/fomichalopoulos/companiesMicroService (3)

github.com/fontinelle/fc-ms-wallet/ (2)

github.com/forzyz/ (4)

github.com/forzyz/gokafffka

github.com/forzyz/gokafka (3)

github.com/fparareda/go-producer-kafka

github.com/fran96/restaurant-go/ (2)

github.com/francatm/go-trading/ (2)

github.com/freeitas/kafka/ (2)

github.com/freel/go-kafka-rest

github.com/freitas-miranda/imersao-fullcycle/ (2)

github.com/frizkey/gocom/pubsub

github.com/frsbrito/Imersao-Full-Stack/ (2)

github.com/gabrielborel/pix/ (2)

github.com/gabrielmq/ (4)

github.com/gabrielmq/codepix/ (2)

github.com/gabrielmq/kafka-consumer-go/ (2)

github.com/gabrielsos/fullcycle-simulator-api (3)

github.com/gabselbach/fullcycle10/infra/kafka

github.com/gabsferrara/ (4)

github.com/gabsferrara/kafka-go-POC/ (2)

github.com/gabsferrara/microsservice-poc/ (2)

github.com/galactichiker/asteroid/src/internal/logmill
github.com/galvital/flux/eventstore

github.com/gamkittisak/kafkamessageq-api/ (3)

github.com/gbeserra95/home-broker/ (2)

github.com/gdfragoso/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/genears/kafka2websocket/k2ws

github.com/genghongjie/go-code/ (3)

github.com/geoffwilliams/kscanner/cmd/main

github.com/georgeerickson/confluent-kafka-go/ (7)

github.com/georgi-georgiev/ (4)

github.com/georgi-georgiev/plunder

github.com/georgi-georgiev/vow/ (3)

github.com/geoscosta/HomeBrocker/ (2)

github.com/ggrrrr/notification-system/common-lib/eventbus

github.com/gguridi/benchmark-kafka-go-clients/ (2)

github.com/giannisalinetti/edge-retail-consumer
github.com/gig/orion-go-sdk/transport/kafka
github.com/gihyunk/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/giovane-aG/imersaofsfc2-simulator (3)

github.com/gitstliu/ (2)

github.com/gleb-tocarenco/assistant_go
github.com/go-bamboo/contrib/client/confluent

github.com/go-hasaki/hasaki-layout-advanced/ (2)

github.com/go-woox/woox-layout-advanced/ (2)

github.com/goakshit/gandalf/ (2)

github.com/gogapopp/url-shortener/ (4)

github.com/gojekfarm/xtools/examples/xkafka

github.com/gomesmatheus/gokafka/ (2)

github.com/gosom/kit/es/kafka

github.com/grpc-boot/bkafka (3)

github.com/gsouza97/gointensivo/ (2)

github.com/gtkpad/gokafka/ (3)

github.com/gtsh77/kafka-mq-go/ (9)

github.com/guhstanley/fc-go-codepix/ (2)

github.com/gui-meireles/fc2-kafka-advanced/ (2)

github.com/guiifernandes/ (4)

github.com/guiifernandes/api-go-kafka/ (2)

github.com/guiifernandes/go-exchange/ (2)

github.com/guil95/ (3)

github.com/guil95/outbox (2)

github.com/guil95/split-entrypoints/config/brokers/kafka

github.com/guilherme-luvi/go-queue-worker/internal/queue

github.com/guilherme-or/vivo-synq/ (2)

github.com/guilhermefaleiros/codestream/video-processing/internal/infrastructure/kafka
github.com/guilhermemrnd/codepix/application/kafka

github.com/guillermogrillo/ (2)

github.com/guiluizmaia/fc2-gokafka/ (2)

github.com/guimochila/microservices-with-go/ (2)

github.com/guipalm4/tracking-simulator/simulator/infra/kafka

github.com/guipassos/golib/ (3)

github.com/guirald/email-sender-go (2)

github.com/gunsluo/go-example/kafka
github.com/gustavobretas/fullcycle/simulador/infra/kafka

github.com/gustavoeyros/message-broker-golang/ (2)

github.com/gustavofdeoliveira/2024-m09-dev/ (2)

github.com/gwilym/confluent-kafka-go/ (7)

github.com/hawk-eye03/kafka-poc/lib/consumers
github.com/hdlproject/es-transaction-service/interface_adapter/messaging
github.com/hendrikhh/kafka-topic-operator/internal/topic-manager

github.com/henriqueholtz/fullcycle/ (2)

github.com/henriquerborba/my-cartola/ (3)

github.com/herculesgabriel/ (4)

github.com/herculesgabriel/codepix/ (2)

github.com/herculesgabriel/payments-processor/ (2)

github.com/herlloncardoso/gokafka/cmd/producer

github.com/hetacode/ (2)

github.com/hewenyu/toolspackage/kafka_plus

github.com/hexa00/confluent-kafka-go/ (19)

github.com/hibrid/statemachine2 (3)

github.com/hmuir28/ (2)

github.com/hopkings2008/yigfs/ (4)

github.com/hoptical/grafana-kafka-datasource/pkg/kafka_client

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

github.com/hraniere/imersao-fullstack-fullcycle/consumer
github.com/hrojas2021/go-kafka-mongodb/pkg/kafka/confluentic
github.com/hrvadl/studdy-buddy/email/pkg/kafka
github.com/hsxflowers/vendas-api/pkg/broker/kafkapkg

github.com/huanggx-sea/confluent-kafka-go/ (19)

github.com/huantt/kafka-dump/ (3)

github.com/hugolhafner/wendigo/internal/services/kafka

github.com/hugosrc/shortlink/ (2)

github.com/hulla-hoop/testSobes/ (4)

github.com/humanitas03/go-practice/go-kafka-consumer
github.com/hunken/go-toolkit/pkg/kafka

github.com/hyperbolicresearch/hlog/ (3)

github.com/hyperxpizza/eda/ (4)

github.com/hyuti/consumer-blueprint/ (2)

github.com/iamviniciuss/wallet-core-eda/ (5)

github.com/ibm-avocados/ibmcloud-kubernetes-admin/ (3)

github.com/ibm/world-wire/ (3)

github.com/icaro-as/brokersystem/ (2)

github.com/ignalina/ (3)

github.com/ignalina/shredder/ (2)

github.com/ignalina/templated_generator

github.com/igomez10/kafka-mvp (2)

github.com/igorsfreitas/bovespa-b3-simulator-api/ (2)

github.com/igortoigildin/stupefied_bell/ (2)

github.com/ijsong/farseer/pkg/kafka
github.com/illenko/gofr-issue-replication

github.com/im-so-sorry/streaming-vk/ (2)

github.com/imhshekhar47/hs-rtta/ (2)

github.com/imperiuse/golib/ (3)

github.com/inaciogu/go-product-service/ (2)

github.com/indece-official/ (2)

github.com/inkochetkov/brokers-check/kafka

github.com/inmarsat1979/indiagw (2)

github.com/insan1a/exile/ (6)

github.com/inspr/inspr/ (2)

github.com/instantpun/kafka-consumer

github.com/intfish123/confluent-kafka-go/ (22)

github.com/ipsozzZ/gtool/ (2)

github.com/ipsozzz/gtool/ (2)

github.com/iqbaludinm/hr-microservice/ (9)

github.com/iramarfalcao/ (2)

github.com/ismaeldf/codepix/ (2)

github.com/ismaelnt/HomeBroker/ (2)

github.com/itsjunglexyz/extensions/ (6)

github.com/itzmatheus/cartola-fc-consolidator/ (3)

github.com/itzurabhi/companies-micro/ (2)

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

github.com/iwanjunaid/ (16)

github.com/iwanjunaid/basesvc/ (8)

github.com/iwanjunaid/mokabox/ (4)

github.com/iwanjunaid/pokabox/ (4)

github.com/iyarkov2/chat/ (5)

github.com/izaakdale/kafka-client

github.com/izabelrodrigues/fullcycle-15-gokafka/ (2)

github.com/izzanzahrial/test-kafka
github.com/j03hanafi/kafkaGo

github.com/jackduh/goKafka/ (3)

github.com/jacsonrsasse/imersao-full-cycle/codebank/infra/kafka
github.com/jadoint/micro/pkg/msgqueue

github.com/jailtonjunior94/ (5)

github.com/jailtonjunior94/fullcycle-kafka/ (2)

github.com/jailtonjunior94/fullcycle-simulator (3)

github.com/jakopako/dnstap-sensor

github.com/jalilbengoufa/ptp/ (2)

github.com/jalvess021/api-golang/ (2)

github.com/jami/ (4)

github.com/jami/kafka-eb-collector/src

github.com/jami/kafka-service-runtime-configuration/ (3)

github.com/jandro-es/merlin/consumers

github.com/jayanthkrishna/kafka-golang (3)

github.com/jayxuchen/ups_tracker/ (2)

github.com/jdaniloc/Individual-FullCycle-01 (3)

github.com/jdemeyer/confluent-kafka-go/ (2)

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

github.com/jeffotoni/goexample/kafka/kafka.confluentinc/pkg/kafka
github.com/jeqo/kafka-topic-operator/pkg/controller/kafkatopic
github.com/jessicacastro/stock/go/internal/infra/kafka

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

github.com/jhonathanalencar/go-hexagonal/ (2)

github.com/jhq0113/gochat/lib/pubsub
github.com/jiaying2001/agent/kafka

github.com/jiunjiunma/manning-async-kafka/ (4)

github.com/jkratz55/kefka (4)

github.com/jliunyu/confluent-kafka-go/ (3)

github.com/jnakagawa1/codepix-go/ (2)

github.com/joaokbmartins/app-go-kafka-mysql/ (2)

github.com/joaolevi/golang_projects/pkg/kafka

github.com/joaomarcosbc/imersaoFC-ms/ (2)

github.com/joaoprds/project_bank/infrastructure/kafka
github.com/joelsantos-js/home-breaker/internal/marktet/infra/kafka

github.com/joferreira/fc-ms-wallet/ (2)

github.com/johnatasr/fake99-simulator (3)

github.com/johncylee/jiji

github.com/johnnysat/imersao-fullcycle/ (2)

github.com/jonathanvinicius/codepix/ (2)

github.com/joseluis8906/project-layout/pkg/kafka
github.com/joseluiszuflores/kafka-examples/confluent

github.com/josenaldo/ (3)

github.com/josenaldo/fc-gokafka/cmd/producer

github.com/josenaldo/fc-walletcore/ (2)

github.com/joshchu00/finance-go-common/kafka

github.com/josielsousa/golang-gclib-alpine-confluent-kafka/ (2)

github.com/josimarz/fc-eda-challenge/ (3)

github.com/josvisser66/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/journeymidnight/yig/messagebus/kafka

github.com/jpgsaraceni/best-funks/ (3)

github.com/jspc/rp-consumer/produce

github.com/juanmanuel-tirado/savetheworldwithgo/ (2)

github.com/juliofilizzola/simulator (6)

github.com/justin831201/trading-service/ (2)

github.com/jvcalassio/fc-payment-gateway/ (2)

github.com/jveiiga/ (4)

github.com/jveiiga/go-docker-and-kafka-classes/ (2)

github.com/jveiiga/imersao-full-cycle/ (2)

github.com/kaduartur/planet/kafka
github.com/kafka-go-streams/kafka-go-streams-primer/table_with_consumer_example
github.com/kafka-ops/kafka-perf-test/cmd

github.com/kanataidarov/gorm_kafka_docker/ (3)

github.com/kantapit123/ (2)

github.com/karidea/release-changelog

github.com/karlaugust1/code_pix_go/ (2)

github.com/kartpop/connector-api/pkg/data/kafkaq
github.com/kata-ai/messagebus-golang-kafka/messagebus

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

github.com/kbehouse/go-kafka-ksql
github.com/keigodasu/kafka-tail/lib

github.com/ken-house/go-scaffold/ (5)

github.com/kentus/automotivetechnologysolutions/go

github.com/killertiger/ (4)

github.com/killertiger/fullcycle_kafkago/ (2)

github.com/killertiger/fullcycle_wallet_core/ (2)

github.com/kirankumardg/kafkaexp

github.com/kitanoyoru/kafka-keda-example/ (2)

github.com/kjansson/skyffel-kafka

github.com/kkHAIKE/confluent-kafka-go/ (22)

github.com/kkeker/go-kafka-source-http

github.com/kkhaike/confluent-kafka-go/ (22)

github.com/kkiling/kafka-lib/ (2)

github.com/kmsdoit/protectgo-sensor-collection-server/ (4)

github.com/ksd-mx/mx-payments/ (2)

github.com/kshitij10496/exp/ (3)

github.com/ksupdev/ (2)

github.com/ktbh4jc/tucows-alt/ (4)

github.com/kyma-incubator/knative-kafka/ (10)

github.com/kzar1n/events-consumer/internal/infra/akafka
github.com/landoop/docker-images/ais-generator
github.com/langsdorf/gobank/infrastructure/kafka
github.com/lannguyen-c0x12c/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/lanpaiva/ (3)

github.com/lanpaiva/api-user/ (2)

github.com/lanpaiva/products-kafka/internal/infra/repository/akafka

github.com/laracarvalho/homebroker/ (2)

github.com/larezende/broker_orders_processor_go/ (2)

github.com/laurentpoirierfr/kafka-console/ (4)

github.com/layunne/kafka-go-first/ (2)

github.com/lcrownover/lazycmd/internal/lazycmd

github.com/leandrofacim/imersao13/ (2)

github.com/leandrozanin/fc-eda/ (3)

github.com/lechitz/listadeprodutos/ (2)

github.com/leedinh/go-ultimate/ (2)

github.com/legolas145/ (4)

github.com/legolas145/kafkaWrapper/ (2)

github.com/legolas145/kafkawrapper/ (2)

github.com/leobelini-studies/full-cycle_apis-mensageria-golang/ (2)

github.com/leocomelli/kafka-ssl-example/go-client-app

github.com/leodimano/extensions/ (3)

github.com/leoviveiros/exemplo-kafka-golang/ (2)

github.com/lethexixin/go-funcs/ (2)

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

github.com/lfmexi/tcpgateway/ (2)

github.com/lfrei/ (2)

github.com/lhfam97/imersaofsfc2-simulator (3)

github.com/lhmzhou/kafka-poc/ (2)

github.com/lhps/codepix-go/ (2)

github.com/liguoqinjim/go-labs/ (2)

github.com/limaantonio/gokafka/ (2)

github.com/linedevth/echo-kafka-producer-example/producer

github.com/lipandr/go-microservice-rating-app/ (2)

github.com/liquidm/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/liridonrama/microservices-with-go-email
github.com/lisa-sum/confluent-kafka-go

github.com/lissandrojs/simulator-golang (3)

github.com/liverday/codebank/core/infrastructure/kafka
github.com/lixiandea/go-zero-mall/test
github.com/lkumarjain/benchmark/kafka-client/confluent
github.com/lnpotter/logsync/cmd/processor

github.com/localthreader/codelivery (3)

github.com/logiqai/hauler-kafka
github.com/loniasgr/hyperledger-fabric-sla-chaincode/testers/consumer
github.com/lonnblad/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/lorenasg1/ (4)

github.com/lorenasg1/codepix/ (2)

github.com/lorenasg1/imersao-fullstack-fullcycle-desafio2/ (2)

github.com/lorenzotinfena/kafka-example (3)

github.com/losfair/caddy-watch (2)

github.com/lovelydett/my_ieee/internel/components

github.com/loxt/fullcycle2.0-kafka/ (2)

github.com/loyalty-application/ (2)

github.com/lprimante/imersao-simulator/ (3)

github.com/lrweck/todo/internal/publisher/kafka

github.com/lschulz/p4-examples/ (2)

github.com/lsgndln/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/luansapelli/kafka-producer

github.com/lucas-ferrari-correa/codepix-go/ (2)

github.com/lucasAzS/psychic-octo-garbanzo (3)

github.com/lucascmreis/codelivery/ (3)

github.com/lucasguiss/imersao-fullcycle-simulator (3)

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

github.com/lucasreisprestes/application-go-hexagonal/ (2)

github.com/lucasres/kafka-go-estudo/ (2)

github.com/lucasrgt/go-microservice/ (2)

github.com/lucasrmp/async-communication-kafka/ (2)

github.com/lucasviniciosfs/codebank/infrastructure/kafka

github.com/lucbarr/extensions/ (3)

github.com/luciano340/fc_kafka/ (2)

github.com/luigizuccarelli/ (3)

github.com/luiscetta/codebank/infrastructure/kafka

github.com/luispinto23/movieexample/ (2)

github.com/luizaugustoventura/aula-kafka-gokafka/ (2)

github.com/luizf-lf/imsersao-fullstack-fullcycle/ (2)

github.com/luizgribeiro/kafka-bbb-poc/src

github.com/luizpanta/homebroker/ (2)

github.com/luizvicenteps/simulator_go (3)

github.com/luopengift/pkg/kafka2
github.com/luyenw/tech-training/go-kafka

github.com/m-pavel/firebolt/ (6)

github.com/m0-ar/ambassador-microsevices-golang/admin/src/events

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

github.com/maan19/golang-eventdriven-microservices

github.com/macario12/GRCPF2/ (2)

github.com/macmessa/imersao-fullcycle3/codebank/infrastructure/message_broker
github.com/madridwan/kafka/kafka/confluent

github.com/maiconloure/codepix/ (2)

github.com/maksim-paskal/kafka-topic-admin/cmd
github.com/malav4all/kafka-dynamic-forwarder
github.com/malike/go-kafka-alert/service
github.com/mallekoppie/gotutorial/KafkaClient

github.com/malytinKonstantin/go-messenger-mono/ (11)

github.com/mamalmaleki/go-movie/cmd/ratingingester
github.com/mansi-rajora09/zbpkafka
github.com/marcelofabianov/contract_management_service_go/pkg/kafka

github.com/marcelofelixsalgado/fullcycle-eda/ (4)

github.com/marcioecom/payment/ (2)

github.com/marcusmarcelino/fullcycle-homebroker/ (2)

github.com/mardiniii/go-kafka-poc/ (2)

github.com/marechal-dev/code-invest/ (2)

github.com/mark-christiansen/go-kafka/confluent

github.com/martindrlik/ (3)

github.com/matemora/cartola-fc/ (3)

github.com/mateusbueno/fc2-gokafka/ (2)

github.com/mateusclira/kafka-go-trainning/ (2)

github.com/mateusjbarbosa/imersao-fullstack-fullcycle/ (4)

github.com/mateuslima90/payment-gateway/ (2)

github.com/mateustudeia/payment-gateway/ (2)

github.com/matg0mes/go-kafka-poc/ (2)

github.com/matheus-santos-souza/ (4)

github.com/matheus-santos-souza/go-ms-walletcore/ (2)

github.com/matheus-santos-souza/gokafka/ (2)

github.com/matheusteodoro01/go-clean-arch/src/infra/providers
github.com/mathpresso/milvus/pkg/mq/msgstream/mqwrapper/kafka

github.com/matsuboshi/hexagonal-architecture-with-go-and-kafka/ (2)

github.com/mattfanto/kafkaops-controller/pkg/resources/kafkaops
github.com/matthewmcneely/graphql-go-tools/v2/examples/kafka_pubsub/transactional_producer
github.com/matthogan/polypully-events

github.com/maurouberti/go-homebroker (3)

github.com/maxhariel/gateway/ (2)

github.com/maxim-kuderko/coeus/Io
github.com/mazitovt/fintechapp/server/cmd

github.com/mazyn/fullcycle-imersao-abril-2022-codepix/ (2)

github.com/mbcordeiro/send-email-go-kafka-connect-ms/ (2)

github.com/mbecker/apisixkafkaupstream/plugins

github.com/mchirico/k8skafka/ (3)

github.com/mdettling/confluent-kafka-go/ (3)

github.com/mediakovda/go-parallel-consumer/ (2)

github.com/mehmetcantas/go-kafka-debezium

github.com/mehnazb3/e2e-kafka-flow/ (2)

github.com/merlinapp/queues-go/kafka

github.com/metadb-project/metadb/ (3)

github.com/mgrzybek/go-kafka-to-s3/kafka

github.com/mi6ule/goboy/ (3)

github.com/michaelprice232/image-processor-api/internal/validate-profile

github.com/michelsantos282/clean-api/ (2)

github.com/micheltank/crypto-price-alert/notification-service/cmd/app

github.com/milena-mognon/go-kafka/ (2)

github.com/milindl/confluent-kafka-go/v2/kafka/go_rdkafka_generr

github.com/milvus-io/milvus/ (3)

github.com/mindaugasrmn/distributed-cowboys/ (5)

github.com/mindwingx/graph-aggregator/driver
github.com/minhphu0304/dumbo/producer

github.com/mithunril/kafka-message-scheduler/ (6)

github.com/mkvy/movies-app/ (2)

github.com/mmkader85/learn-kafka-golang/kafka

github.com/modern-era-devs/ (2)

github.com/mohamedtaher567/ (6)

github.com/mohitarora1/gallery/controller

github.com/monasca/monasca-aggregator (2)

github.com/mordp1/espetinhodekafka/kafka-lab/debezium

github.com/moritztng/codelense/ (9)

github.com/morka17/flare

github.com/morozovcookie/atlant/ (2)

github.com/mrdiniz88/imersaofsfc-simulator (3)

github.com/msilvaspa/fc2-gokafka/cmd/producer

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

github.com/murilera/delivera (3)

github.com/muriloabranches/fc-ms-walletcore/ (2)

github.com/murphybytes/gots/ (4)

github.com/musictopeople/go-confluent-kafka

github.com/mwives/ (9)

github.com/mwives/event-driven-architecture-fc-3.0/ (5)

github.com/mwives/golang-kafka-fc-3.0/ (2)

github.com/mwives/microservices-fc-walletcore/ (2)

github.com/mycujoo/go-kafka-avro (2)

github.com/myfintech/ark/src/go/lib/ark/cqrs/protocols/kafka

github.com/mykube-run/keel/ (2)

github.com/mytn1992/ebd-carpark-availability-consumer

github.com/n-kazachuk/ (3)

github.com/n-kazachuk/go_parser/ (2)

github.com/n-kazachuk/go_tg_bot/internal/app/adapters/secondary/kafka-adapter-publisher

github.com/nakji-network/connector (2)

github.com/nalyx1/exchange-server/ (2)

github.com/namikmesic/kafka/lib

github.com/nancyli0637/ (2)

github.com/nbwoodward/confluent-kafka-go/ (22)

github.com/nearmeng/mango-go/plugin/mq/kafka
github.com/neo-v2/gokafka/Consumer

github.com/neptoess/confluent-kafka-go/ (2)

github.com/netoudi/ (3)

github.com/netoudi/codebank-transaction/infrastructure/kafka

github.com/netoudi/codepay-process-transaction (2)

github.com/netrebel/kafka-with-go/ (2)

github.com/nguyencuong382/go-message-router/mkafka

github.com/nicholasscabral/homebroker/ (2)

github.com/nidhish1/ (2)

github.com/nikhilbhide/ (2)

github.com/nikhilsbhat/confluent-kafka-client
github.com/nilangekarss/trykafka
github.com/nilsyadv/ShopBillBuddy/common/pkg/queue
github.com/ninglg/golang-example/kafka/consumer2

github.com/nironwp/ms-wallet/ (2)

github.com/nobletooth/dotanet/eventservice
github.com/nowfred/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/nurali-techie/ (3)

github.com/nurali-techie/meetup-golang/go-kafka

github.com/nurali-techie/microservices/ (2)

github.com/nxgtw/confluent-kafka-go/ (11)

github.com/oassuncao/kafka-retry/ (5)

github.com/octarinesec/confluent-kafka-go/ (7)

github.com/olimpias/go-kafka-client (2)

github.com/onlyreynaldo/immersao-simulator (3)

github.com/onurozerdal/hepsiburada-case/stream-reader/consumer
github.com/opencybersec/goflowtosyslog
github.com/opensds/multi-cloud/s3/pkg/messagebus/kafka
github.com/orochyy/confkafka/kaffka

github.com/oscarhealth/confluent-kafka-go/ (7)

github.com/osframework/confluent-kafka-go-ext/ (3)

github.com/osmariojunior/codepix/ (2)

github.com/osnirmaster/go-event-carried-state-transfer
github.com/ovh/public-cloud-databases-training-examples/databases/kafka/go/hello-world
github.com/owenliang/bigpipe/src/bigpipe/kafka

github.com/ozlemugur/go-cqrs-event-sourcing-tt/ (2)

github.com/ozoncp/ocp-issue-api/internal/events

github.com/p12s/ (10)

github.com/p12s/furniture-store/ (2)

github.com/p12s/okko-video-converter/api/pkg/broker

github.com/p12s/uber-popug/ (7)

github.com/pagrus7/kafka-fwd/ (2)

github.com/palomasoftware/msds434_module_eight_kafka_demo
github.com/panutat-p/learn-kafka

github.com/papawattu/ (2)

github.com/paroar/ (2)

github.com/patrick-east/kubecon-na-2020/custom-opa/plugins/logger
github.com/patrickrhamon/codebank/infrastructure/kafka
github.com/paulcager/kcat

github.com/paulodutra/golang-hexagonal-architecture/ (2)

github.com/paulohenrique22/imersaofsfc2-simulator (3)

github.com/pauloricardo2019/kafkagolang/ (2)

github.com/paulosarmento/ (4)

github.com/paulosarmento/codepix/ (2)

github.com/paulosarmento/imersao16/ (2)

github.com/pcvolkmer/rwdp-obds-cleanup

github.com/pe-gomes/codepix-go/ (2)

github.com/peaceman/kafka-rnd-go/ (4)

github.com/peak/confluent-kafka-go/ (19)

github.com/pedroagribeiro/go_kafka/ (4)

github.com/pedropereiraassis/full-cycle/ (6)

github.com/pellared/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka

github.com/perkdrew/media-transcoder/ (2)

github.com/peterP1998/notification-system/libs/notification/producer

github.com/petini96/live/ (2)

github.com/petrostrak/xm-companies (2)

github.com/petrushub/go-kafka
github.com/phbrgnomo/imersao_fullcycle/simulador-mercado/internal/market/infra/kafka
github.com/pietroaragona/golang-kafka-confluent-poc
github.com/pigeatgarlic/goedf/chassis/util/event/provider/kafka
github.com/pinebiotechorg/trkir-watchers/experiments

github.com/ping-cloudnative/moonlight-utils/ (2)

github.com/piqba/common/pkg/broker/kafka
github.com/pjcalvo/go-cache/utils

github.com/plinioaugusto/simulator-full-cycle-immersion-2023 (3)

github.com/podengo-project/idmsvc-backend/ (10)

github.com/poga/spacer/pkg
github.com/pointsarebad/pab-api/services/kafka
github.com/polyglotDataNerd/curio-producer/kafka
github.com/poncos/go-things/kafka-samples/internal/kafka
github.com/pragmaticpi/go-kafka-mongodb
github.com/prajat/go-kafka

github.com/pranjalmohansaxena/TKPModellingTechWorkshop (2)

github.com/presencelearning/rhq-go-cmn/pubsub

github.com/protsack-stephan/ (3)

github.com/protsack-stephan/schema-registry-example/bridge

github.com/protsack-stephan/wme-architecture-poc/ (2)

github.com/psridhark/goatq/cmd/perfbench
github.com/qalexandre/imersaofsfc2-simulator/infra/kafka

github.com/qdegraaf/kafka-twitter-producer/ (2)

github.com/qframe/handler-kafka

github.com/qml-123/AppService/ (2)

github.com/qntfy/frafka

github.com/quangdangfit/kafka-elasticsearch (2)

github.com/quanghuynguyen1902/job-schedule/internal/kafka
github.com/qudj/fly_lib/confluent_kafka

github.com/r-avellar/gointensivo2/ (2)

github.com/r-souza/imersao-fullstack-fullcycle/ (3)

github.com/radekg/karapace-demo

github.com/rafaelb4rros/fullcycle-07/ (2)

github.com/rafaeldblima/requests-tracing-poc (4)

github.com/rafalskolasinski/kafctl/ (4)

github.com/raffops/chat/ (2)

github.com/raghuveer01/golang_fundamentals/go_workspace/kafka_demo
github.com/ragnarula/go-kafka-redis
github.com/ragul28/kafka-cli/queue

github.com/rajatvyadav/learn-kafka/ (2)

github.com/rajsinghtech/fleet-telemetry-consumer

github.com/rakeshchauhan-dev/gokafka (3)

github.com/rakhmadbudiono/code-scanner/ (2)

github.com/ramazan-makhanov/golang-kafka/kafka-to-db

github.com/ramonmpacheco/poc-go-kafka/ (2)

github.com/ramseyjiang/go_mid_to_senior/ (2)

github.com/raphaelmb/ (6)

github.com/raphaelmb/fullcycle-go-kafka/ (2)

github.com/raphaelmb/fullcycle-walletcore/ (2)

github.com/raphaelmb/invest-platform/ (2)

github.com/rattapon001/ (6)

github.com/rattapon001/porter-management-demo/ (2)

github.com/rattapon001/porter-management/ (4)

github.com/rayokota/ (23)

github.com/rayokota/confluent-kafka-go/ (22)

github.com/rayokota/go-kcache/kcache

github.com/rayonnunes/imersaofsfc/ (3)

github.com/raystack/raccoon/ (2)

github.com/razorpay/metro/pkg/messagebroker
github.com/razz99/kafka-go

github.com/rbicca/simulator (3)

github.com/rcttavares/codepix/ (2)

github.com/rd-robin-senftleben/scanner-messaging/pkg/message/kafkabackend

github.com/redBorder/ (4)

github.com/redBorder/dswatcher/ (2)

github.com/redBorder/events-counter/ (2)

github.com/redborder/ (4)

github.com/redborder/dswatcher/ (2)

github.com/redborder/events-counter/ (2)

github.com/redhat-italy/redhat-sc23-eda/eda-edge-automation/engine-monitor

github.com/redhat-partner-ecosystem/ (3)

github.com/redhat-partner-ecosystem/openshift-skunkworks/examples/kafka-listener

github.com/redhat-partner-ecosystem/shadowcar/ (2)

github.com/redhatinsights/ (7)

github.com/redhatinsights/edge-api/ (3)

github.com/redhatinsights/export-service-go/ (3)

github.com/redhatinsights/payload-tracker-go/internal/kafka

github.com/reecerussell/kafka-ui/listener
github.com/renatoaguimaraes/go-mongo-kafka-protobuf/kafka

github.com/renatoosaka/ (4)

github.com/renatoosaka/codepix/ (2)

github.com/renatoosaka/imersao-kafka/ (2)

github.com/renatospaka/fc2.0-imersao3-map-tracker (3)

github.com/reshiadavan/cryptgo/ (5)

github.com/rewati/gdsb

github.com/rfaguiar/codepix/ (2)

github.com/rhadamez/simulator-aluno (3)

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

github.com/rhizomplatform/golib/ (3)

github.com/ri-nat/kafka-proto-monitor/ (2)

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

github.com/ricardo-ltm/fullcycle5-microservice/ (2)

github.com/ricardomaricato/gokafka/ (2)

github.com/rideziro/go-messaging/kafka

github.com/rifqi-xq/detik-alibaba/ (4)

github.com/rigelbm/confluent-kafka-go/ (14)

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

github.com/rjar2020/post-delivery/ (2)

github.com/rkpattnaik780/rhoas-poc/ (2)

github.com/rkritchat/grkafka
github.com/robbinhan/go-kafka-topic

github.com/robertheory/imersao-fs-fc/ (2)

github.com/robertomorel/gokafka/cmd/consumer

github.com/roblaszczak/gooddd/ (2)

github.com/roblesdotdev/movies-ms/ (2)

github.com/roblopes7/imersao5-gateway/ (2)

github.com/robsantossilva/intensivao-golang-6/ (2)

github.com/rodolforomera/fc2-gokafka/ (2)

github.com/rodolfosouzamenezes/shipping-calculator-server/ (2)

github.com/rodrigoazv/go-bank/infra/kafka

github.com/rodrigoengelberg/imersao-fullcycle-7/ (2)

github.com/rodrigojustinodevs/tracking-driver/ (2)

github.com/rodrigorssa/codebank/infra

github.com/rodrigoschaer/homebroker/ (2)

github.com/rodvieira/code-pix-go/ (2)

github.com/rogeriocassares/fullcycle-homebroker-service-go/infra/kafka
github.com/rohanchauhan02/recommendation-engine/pkg/transporter/kafka
github.com/roman-munteanu/kafka-go-demo/confuent

github.com/romanceresnak/kafka/ (2)

github.com/ronylucca/go-multithreading-kafka/ (2)

github.com/roopeshsn/log-ingestor/log-ingestor/server
github.com/rootameen/kafka-sse-stream
github.com/roserossi/proyecto-ds-iii/kafka-server/go/kafkaPlugin

github.com/roshankumar18/event-booking/ (3)

github.com/rradu-dev/ecommerce-pdm-microservice/internal/common/bus/consumer

github.com/ruhancs/ (3)

github.com/ruhancs/card_transaction/infra/kafka

github.com/ruhancs/gateway-pagamento/ (2)

github.com/rutanioka/Projeto-Cartola-2022/ (3)

github.com/rvaid/kafka_clients_go
github.com/rverma-nsl/kafka-schemaregistry-protobuf
github.com/rwynn/route81

github.com/ryanjoy0000/yt-notifier/ (2)

github.com/ryanpfalz/go-openapi/ (3)

github.com/ryatsuga/codepix-go/ (2)

github.com/rzfhlv/go-kafka

github.com/s-larionov/async-kafka (2)

github.com/saanvijay/weathernotify/ (2)

github.com/sabariramc/goserverbase/ (3)

github.com/sadahal/mygodir/kafka
github.com/safedep/gateway/services/pkg/common/messaging

github.com/sahilsk11/fingest/ (2)

github.com/sainipankaj15/kafka-producer-in-golang

github.com/salamandery/imersao12-go-esquenta/ (2)

github.com/salesof7/ (9)

github.com/salesof7/go_homebroker-fc/ (2)

github.com/salesof7/go_kafka-fs/ (2)

github.com/salesof7/go_kafka-simulator-fs (3)

github.com/salesof7/go_walletcore-fc/ (2)

github.com/samsul96maarif/auth-service/ (2)

github.com/samutayuga/sam-twitter-go/ (2)

github.com/sanaipey/kafka/ (2)

github.com/sandipb/go-kafka-counter/cmd/kafka-count
github.com/sandronister/go_broker/pkg/broker/broker_kafka
github.com/santhoshvempali/simplebank/kafka

github.com/santosant/codepix/ (2)

github.com/saravase/golang_mongo_kafka/data
github.com/saufiroja/sosmed-app/auth-service/pkg/messaging
github.com/scliangx/webServerTools/internal/kafka
github.com/sdx13/csv2kafka/cmd/kafka2csv

github.com/seldonio/seldon-core/ (3)

github.com/sercancelenk/kafkathena-gox

github.com/serenissimus/confluent-kafka-go/ (18)

github.com/sergera/ (3)

github.com/serhii-koshlatyi/test_kafka/ (2)

github.com/sermojohn/otelkafka

github.com/serozaki/extensions/ (3)

github.com/sgraham785/kafka-consumer-job-dispatcher/internal
github.com/shandysiswandi/learn-golang/kafka/confluentinc-confluent-kafka-go
github.com/sharop/gosandbox/kafka
github.com/shashank-mugiwara/laughingtale/client

github.com/shift-alt-del/play-confluent-go-client-sr/ (4)

github.com/shobenhou/monitor/ (4)

github.com/shooghr/codepix_desafio_2/ (2)

github.com/shubhamguptafp/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/shubhamsonal/pub-sub-system/pub-sub/worker

github.com/shumt90/go-education-meanless/ (2)

github.com/sibedge-llc/dp-services/eventer/internal/kafka

github.com/signalfx/ (2)

github.com/silva4dev/golang-kafka-example/ (2)

github.com/simnotes/confluent-kafka-go/ (11)

github.com/sinhaparth5/go-kafka-grpc-server

github.com/siralfbaez/ (6)

github.com/siralfbaez/go-kafka-docker/ (3)

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

github.com/sith0008/nyc-tlc-data-pipeline/ (2)

github.com/sivaone/go-kafka-websocket
github.com/skapfer/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

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

github.com/sko00o/benchmark-kafka-go-clients

github.com/skroutz/ (2)

github.com/slinkydeveloper/kafka-go-clients-benchmarks/confluent-kafka-go
github.com/smallnest/kafka-go-examples/confluent-kafka-go

github.com/smmile18/kafka-go-docker-quickstart/ (3)

github.com/software-engr-full-stack/vaskafka

github.com/solutioncrafting/kafkaandgo/ (2)

github.com/sosalejandro/kafka-x-go/ (3)

github.com/sotigr/go-core/brokers

github.com/soulwill1/estudos/ (2)

github.com/sourcefellows/confluent-kafka-go/ (22)

github.com/sousacruz/fc-apache-kafka/ (2)

github.com/sousaprogramador/gokafka/ (2)

github.com/souvik150/supplychain-hackathon-proj/ (2)

github.com/soyacen/easypubsub/ckafka/example

github.com/spantik/azureblobtokafka/ (2)

github.com/splunk/kafka-mq-go/ (9)

github.com/sponomis/confluent-kafka-go/ (19)

github.com/squareup/pranadb/kafka

github.com/starius/confluent-kafka-go/ (22)

github.com/stb2132/confluent-kafka-go/ (22)

github.com/stephenamsel/samsel-high-performance-proxy

github.com/stevehebert/k2edge/ (2)

github.com/stevemns/confluent-kafka-go/ (23)

github.com/stolostron/ (12)

github.com/stolostron/hub-of-hubs-agent/ (3)

github.com/stolostron/hub-of-hubs-kafka-transport/ (3)

github.com/stolostron/hub-of-hubs-manager/ (2)

github.com/stolostron/hub-of-hubs-spec-transport-bridge/pkg/transport/kafka
github.com/stolostron/hub-of-hubs-status-transport-bridge/pkg/transport/kafka
github.com/stolostron/leaf-hub-spec-sync/pkg/transport/kafka
github.com/stolostron/leaf-hub-status-sync/pkg/transport/kafka

github.com/strangedev/ (4)

github.com/strangedev/kafka-golang/ (3)

github.com/strangedev/kafka-schema/pkg

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

github.com/stwrtrio/coffee-shop/pkg/kafka

github.com/suhail34/pdf-compressor/ (2)

github.com/suiguo/hwlib/kafka
github.com/sumitroajiprabowo/go-kafka-docker
github.com/sunnykrgupta/k8s-hpa-custom-autoscaling-kafka-metrics/go-kafka

github.com/super-collider/ (4)

github.com/super-collider/event-api/ (2)

github.com/super-collider/event-router/ (2)

github.com/super-valter/imersaofullcycle/ (2)

github.com/supersherm5/movie-app/ (2)

github.com/supnobita/learn-go
github.com/supwr/saga-pattern/pkg/kafka
github.com/suyghur/go-toolkit/ckafka
github.com/svennjegac/opentelemetry-go-contrib/instrumentation/github.com/confluentinc/confluent-kafka-go/kafka/otelkafka
github.com/swkkd/budget-google/APIUrlToIndex
github.com/sysfivecom/kafka-cli

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

github.com/taekoelias/imersao-fullcycle-9/codebank/infrastructure/kafka

github.com/takecy/confluent-kafka-go/ (7)

github.com/tarvip/confluent-kafka-go/ (14)

github.com/taturazova/ (2)

github.com/tdyas/pants-go-testing/kafka

github.com/team-triage/triage/ (6)

github.com/techmaster/learngo/Kafka
github.com/tengattack/dandelion/mq
github.com/tengzbiao/go-delayqueue/delay_queue
github.com/tetriscode/commander/queue

github.com/tgkzz/notification/ (3)

github.com/th3g00dc0d3r/codebank/infrastructure/kafka

github.com/thaiiabreu/imersao-fullstack-fullcycle/ (3)

github.com/thalesmacedo1/ (5)

github.com/thalesmacedo1/code-delivery/ (3)

github.com/thalesmacedo1/go-apache-kafka/ (2)

github.com/thanhlam2110/iccs-object-management-svc/ (2)

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

github.com/thauska/imersao-fullstack-fullcycle/ (2)

github.com/theboyisno-1/go-redis-kafka-docker-demo/pkg/kafka

github.com/thefuga/go-poc/ (3)

github.com/thgbianeck/bnck-gokafka/ (2)

github.com/thiagoalvesfoz/codepix/ (2)

github.com/thiagorm28/code-bank/infrastructure/kafka

github.com/thiagotilid/goframework (2)

github.com/third-place/ (10)

github.com/third-place/community-service/ (3)

github.com/third-place/image-service/ (3)

github.com/third-place/notification-service/internal/kafka

github.com/third-place/user-service/ (3)

github.com/thomas91310/confluent-kafka-go/ (7)

github.com/thor77/kafka-stress-go

github.com/tiagomelo/realtime-data-kafka/ (3)

github.com/tidepool-org/workscheduler/ (2)

github.com/tiksup/tiksup-kafka-worker/ (3)

github.com/timvw/ (6)

github.com/timvw/go-kafka-avro-schemaregistry/ (2)

github.com/timvw/gokafkaavro/ (2)

github.com/timvw/kafkaavro/ (2)

github.com/tkeech1/kafka-sasl
github.com/tl-framework/goframework

github.com/tobg8/ (4)

github.com/tobg8/crypto-viz-consumer/ (2)

github.com/tobg8/crypto-viz/ (2)

github.com/todoapps2021/telegrambot/internal/kafka/producer
github.com/tomassar/microservices-with-kafka
github.com/tommzn/hdb-message-agent

github.com/tonnytg/lightbank/ (2)

github.com/topfreegames/ (11)

github.com/topfreegames/extensions/ (6)

github.com/topfreegames/marathon/interfaces

github.com/topfreegames/pusher/ (4)

github.com/torwig/playground/ (2)

github.com/traff1k/demo-kafka-producer/kafka
github.com/trsustme/kafka-lab/cmd

github.com/tsel-ticketmaster/ (11)

github.com/tsel-ticketmaster/tm-event/ (3)

github.com/tsel-ticketmaster/tm-notification/ (4)

github.com/tsel-ticketmaster/tm-order/ (2)

github.com/tsel-ticketmaster/tm-user/ (2)

github.com/tthiagopereira/produce-consumer-kafka/ (2)

github.com/tubenhirn/kafka-example

github.com/tuliofergulha/stock-exchange/ (2)

github.com/tx7do/go-kafka-example/confluent
github.com/uber/aresdb/subscriber/common/consumer/kafka
github.com/ugol/mockafka/cmd
github.com/ugurcancaykara/odd-service/cmd/ratingingester

github.com/uiratan/ (3)

github.com/uiratan/fullcycle-archdev-event-driven-architecture/balances/cmd/balances

github.com/uiratan/fullcycle-archdev-kafka/ (2)

github.com/ujka/golang-kafka (3)

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

github.com/unifyi/creme-brulee/ (2)

github.com/unionai/splunk-otel-go/instrumentation/github.com/confluentinc/confluent-kafka-go/kafka/splunkkafka
github.com/unkiwii/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
github.com/urban-1/gopipe/input

github.com/v8tix/zemoga/ (2)

github.com/valdirmendesdev/fullcycle-gokafka/ (2)

github.com/vanillaverse/guardian/pkg/types

github.com/vantamm27/libs/ (2)

github.com/vavas/workchan/ (5)

github.com/vctrl/async-architecture/ (11)

github.com/velann21/ (2)

github.com/vemta/mvc (3)

github.com/vflopes/slime/pkg/adapters/kafka-driver

github.com/vhfuly/codepix-go/ (2)

github.com/vicbvs/codepix/ (2)

github.com/victor-perov/confluent-kafka-go/ (2)

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

github.com/victordev13/fullcycle-codepix/ (2)

github.com/victorlss/go-examples/cmd/kafka
github.com/vieiravitor/codebank/queue
github.com/vieirinhasantana/kafka-go/pkg/kafka

github.com/viktorbarzin/webhook-handler/ (2)

github.com/vinicius-gandini/imersao-fullstack-fullcycle/ (2)

github.com/viniciusarambul/study-go/ (2)

github.com/viniciusjose/imersao12-go-esquenta/ (2)

github.com/viniciusrsouza/projeto-soa/order/gateways/events

github.com/vinigracindo/codepix-desafio02/ (2)

github.com/viniqrz/broker-microservice/ (2)

github.com/vinisbitten/learning-kafka/ (4)

github.com/virb30/fc-simulator-go (3)

github.com/vitor7001/simulator (3)

github.com/vitordelfino/fullcycle/ (2)

github.com/vlab-research/ (2)

github.com/vniche/collective/ (3)

github.com/vnscriptkid/ (26)

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

github.com/vnscriptkid/sd-payment-system/retryable

github.com/vnscriptkid/sd-socialmedia/ (2)

github.com/vnscriptkid/sd-topk-videos/ (3)

github.com/vulpes-ferrilata/catan-service/infrastructure

github.com/vyctor/fc-apache-kafka/ (2)

github.com/vynnydev/homebroker/ (2)

github.com/w6d-io/x/kafkax

github.com/wahed-tech/confluent-kafka-go/ (2)

github.com/waldandrade/fullcycle_delivery (3)

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

github.com/wangbokun/go/transfer/kafka

github.com/warubert/imersaofc2-simulator (3)

github.com/weberdantas/codebank/infrastructure/kafka

github.com/weiqiangxu/ (2)

github.com/wellingtonlira/simulator (3)

github.com/welly87/ (2)

github.com/wendylau87/warungpintar2021/inventorysvc/infrastructure/kafkahandler
github.com/wheresalice/kerf/cmd
github.com/whj1990/go-core/store
github.com/wikimedia-enterprise/health-checker/health

github.com/wil-g2/gokafka/ (2)

github.com/wilcatarino/labs-go/src/apache-kafka

github.com/wilferraciolli/fullCycle-homeBroker/ (2)

github.com/will3g/golang-boilerplates/ (2)

github.com/williamtrevisan/gokafka/ (2)

github.com/willian2s/ (4)

github.com/willian2s/calculate-tax/ (2)

github.com/willian2s/codepix/ (2)

github.com/wilsonfsouza/home-broker/ (2)

github.com/wlcmtunknwndth/messagio_test/backend/internal/broker/kafka

github.com/woodliu/prometheusWriter/ (2)

github.com/wordnet-world/ (2)

github.com/woshidama323/LearningGolang/kafka

github.com/wpkenpachii/matching-maker-stock-market/ (2)

github.com/wprosdocimo/imersao-fullstack-fullcycle/ (2)

github.com/wrmn/kafkaprod (2)

github.com/wundergraph/graphql-go-tools/ (3)

github.com/xiaoweihong/deepgo/ (2)

github.com/xushuhui/ (2)

github.com/xyproto/kafkastatus

github.com/yagoinacio/home-broker-trade-matcher/ (2)

github.com/yahya077/email-microservice/services/eventService

github.com/yangfan1224/ (2)

github.com/yansb/imersao-full-cycle/ (4)

github.com/yapo-chile/ (2)

github.com/ydessouky/kafkaexporter
github.com/yeshan333/go-kafka-demo

github.com/ynsgnr/scribo/ (11)

github.com/yohanaff/fc-home-broker/ (2)

github.com/yossisp/csv-to-spotify/pkg/kafkahelper
github.com/youknowwhoiam1990/go_programming
github.com/youssefkhdessouky/enmsAnalyticsExporter10
github.com/ysbarney/datasyncer/kafka
github.com/ytakaya/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/yujin-dev/kafka-streaming/kafka-tcp

github.com/yulken/fsfc-gps-simulator (3)

github.com/yumyudai/misttools/internal/pubsub
github.com/yurii-vyrovyi/kafkalib

github.com/yurimalaquias/imersao12-go-esquenta/ (2)

github.com/yushizhao/mercury (2)

github.com/yusufpapurcu/confluent-kafka-test (3)

github.com/yyliziqiu/ (3)

github.com/zakhaev26/microservices-go/ (2)

github.com/zakirkun/kafka-otp-email/ (2)

github.com/zengyifan/ops/pkg/kafka

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

github.com/zeroskullx/imersao13/ (2)

github.com/zhangjianweibj/monasca-transformdata

github.com/zhas-off/movie-service-2/ (2)

github.com/zilliztech/milvus-cdc/core/writer
github.com/zleague/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka

github.com/zoninnik89/messenger/ (11)

github.com/zooptwopointone/gdsb

gitlab.4lapy.ru/4lapy-shared/ (3)

gitlab.com/deepakgarg9121/mood-test/utile-develop
gitlab.com/dotpe/mindbenders/corel
gitlab.com/egeneralov/wait4services/internal/services/kafka
gitlab.com/go-lang-tools/events/kafka

gitlab.com/gtsh77-shared/kafka-mq-go/ (9)

gitlab.com/jc88/jager/messagebroker/kafkax

gitlab.com/learn-micorservices/ (4)

gitlab.com/learn-micorservices/auth-service (2)

gitlab.com/learn-micorservices/user-service (2)

gitlab.com/nariflix/libraries/kafka-client/consumer
gitlab.com/otavio3/go-tracer/contrib/confluentinc/confluent-kafka-go/kafka
gitlab.com/prostu/backend/common/kafka
gitlab.com/ptflp/gopubsub/kafkamq

gitlab.com/ragcoon/services/ (2)

gitlab.com/wagnerDeveloper/gotransaction/ (2)

gitlab.helcim.com/library/ (4)

gitlab.lanhuapp.com/gopkgs/ikafka/confluent

gitlab2.helcim.net/library/ (2)

gopkg.in/CodapeWild/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka
gopkg.in/DataDog/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka

gopkg.in/confluentinc/ (45)

gopkg.in/confluentinc/confluent-kafka-go.v0/ (11)

gopkg.in/confluentinc/confluent-kafka-go.v1/ (22)

gopkg.in/confluentinc/confluent-kafka-go.v100/ (12)

gopkg.in/flocasts/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka

gopkg.in/wshirey/confluent-kafka-go.v1/ (14)

vcs-git.ourstudio.dev/vcs-libraries/ (4)

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