Go to main page
Known importers: 3,064 (displaying 3,446 packages, including internal and invalid packages)
- 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/connect
- gitee.com/fatzeng/srf_switch_expansion_package/extend_config
- gitee.com/fatzeng/srf_switch_expansion_package/extend_operator/kafka_operator
- gitee.com/fatzeng/srf_switch_expansion_package/extend_param_builder
- gitee.com/fatzeng/srf_switch_expansion_package/extend_parser
- github.com/0angelic0/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/0michalsokolowski0/watermill/message/infrastructure/kafka
- github.com/1123/golang-kafka-client-kubernetes
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter02-microservices/2.2-microservices-types/02-consumer-service
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter02-microservices/2.2-microservices-types/03-batch-consumer-service
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter02-microservices/2.2-microservices-types/05-asynctask-service
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter02-microservices/2.2-microservices-types/06-paralleltask-service
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter02-microservices/2.3-service-startup-teardown
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter03-deploy-scale-services/3.1-deploy-services
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter03-deploy-scale-services/3.2-healthcheck-readiness
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter03-deploy-scale-services/3.3-scale-services
- github.com/3dsinteractive/automation-scalable-technology-with-golang-and-k8s-part-1/chapter04-implement-reallife-app/4.2-tcir-application
- github.com/3dsinteractive/automation-technology/chapter02-microservices/2.2-microservices-types/02-consumer-service
- github.com/3dsinteractive/automation-technology/chapter02-microservices/2.2-microservices-types/03-batch-consumer-service
- github.com/3dsinteractive/automation-technology/chapter02-microservices/2.2-microservices-types/05-asynctask-service
- github.com/3dsinteractive/automation-technology/chapter02-microservices/2.2-microservices-types/06-paralleltask-service
- github.com/3dsinteractive/automation-technology/chapter02-microservices/2.3-service-startup-teardown
- github.com/3dsinteractive/automation-technology/chapter03-deploy-scale-services/3.1-deploy-services
- github.com/3dsinteractive/automation-technology/chapter03-deploy-scale-services/3.2-healthcheck-readiness
- github.com/3dsinteractive/automation-technology/chapter03-deploy-scale-services/3.3-scale-services
- github.com/3dsinteractive/automation-technology/chapter04-implement-reallife-app/4.2-tcir-application
- github.com/3dsinteractive/automation-technology/chapter06-ci-cd/6.5-devopsctl/05-build-devopsctl
- github.com/3dsinteractive/automation-technology/chapter07-automate-test/7.1-unit-test
- github.com/3dsinteractive/automation-technology/chapter08-monitoring-alerting/8.2-node-metrics
- github.com/3dsinteractive/automation-technology/chapter08-monitoring-alerting/8.3-alerting
- github.com/3dsinteractive/tcir-app
- github.com/84codes/cloudkafka-benchmarks
- github.com/8xmx8/easier/pkg/amqp/confluent
- github.com/Abbas-gheydi/kafka-tiny-tools/internal/kafkat
- github.com/AlexsJones/frontier/components/kafka
- github.com/ArnaudGallardo/rocktest-core
- github.com/BaianorASR/ifc2-simulator/infra/kafka
- github.com/Basic-Components/connecthelper/kafkahelper
- github.com/Beeketing/confluent-kafka-go/examples/admin_create_topic
- github.com/Beeketing/confluent-kafka-go/examples/admin_delete_topics
- github.com/Beeketing/confluent-kafka-go/examples/admin_describe_config
- github.com/Beeketing/confluent-kafka-go/examples/confluent_cloud_example
- github.com/Beeketing/confluent-kafka-go/examples/consumer_channel_example
- github.com/Beeketing/confluent-kafka-go/examples/consumer_example
- github.com/Beeketing/confluent-kafka-go/examples/go-kafkacat
- github.com/Beeketing/confluent-kafka-go/examples/producer_channel_example
- github.com/Beeketing/confluent-kafka-go/examples/producer_example
- github.com/Beeketing/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/Beeketing/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/Boklazhenko/kafka
- github.com/BroadbandForum/obbaa-477/common/kafkaHandler
- github.com/ChAngLEx/Myproject/common
- github.com/CheesecakeLabs/token-factory-v2/backend/pkg/kafka
- github.com/Corner-W/sk/mque/kfk
- github.com/Cray-HPE/hms-msgbus
- github.com/CrowdStrike/kafka-replicator/pkg/compaction
- github.com/CrowdStrike/kafka-replicator/pkg/core
- github.com/CrowdStrike/kafka-replicator/pkg/egress
- github.com/CrowdStrike/kafka-replicator/pkg/ingress
- github.com/CrowdStrike/kafka-replicator/pkg/kafka
- github.com/CrowdStrike/kafka-replicator/pkg/stores
- github.com/CrowdStrike/kafka-replicator/tests
- github.com/CyberhavenInc/confluent-kafka-go/examples/admin_create_topic
- github.com/CyberhavenInc/confluent-kafka-go/examples/admin_delete_topics
- github.com/CyberhavenInc/confluent-kafka-go/examples/admin_describe_config
- github.com/CyberhavenInc/confluent-kafka-go/examples/confluent_cloud_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/consumer_channel_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/consumer_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/CyberhavenInc/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/go-kafkacat
- github.com/CyberhavenInc/confluent-kafka-go/examples/idempotent_producer_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/library-version
- github.com/CyberhavenInc/confluent-kafka-go/examples/oauthbearer_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/producer_channel_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/producer_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/stats_example
- github.com/CyberhavenInc/confluent-kafka-go/examples/transactions_example
- github.com/CyberhavenInc/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/CyberhavenInc/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/CyberhavenInc/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/CyberhavenInc/confluent-kafka-go/soaktest
- github.com/CyberhavenInc/confluent-kafka-go/soaktest/soakclient
- github.com/CyberhavenInc/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/DanTulovsky/web-static/server
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/admin/config_describe
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/consumer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/consumer/channel/channel_consumer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/producer
- github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/producer/channel
- github.com/DataDog/confluent-kafka-go/examples/consumer_channel_example
- github.com/DataDog/confluent-kafka-go/examples/consumer_example
- github.com/DataDog/confluent-kafka-go/examples/go-kafkacat
- github.com/DataDog/confluent-kafka-go/examples/producer_channel_example
- github.com/DataDog/confluent-kafka-go/examples/producer_example
- github.com/DataDog/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/DataDog/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/DataDog/data-streams-go/integrations/kafka
- github.com/DevotedHealth/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/EBWi11/AgentSmith-HIDS/agent_golang/common
- github.com/Enflick/statemachine2
- github.com/EvertonLMsilva/api-avulso/internal/infra/akafka
- github.com/Gabriel962008/code-delivery/simulador/infra/kafka
- github.com/GenEars/kafka2websocket/k2ws
- github.com/Goboolean/fetch-system.infrastructure/pkg/kafka
- 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/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/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/MajotraderLucky/Kafka-FIO-Listener/checker
- github.com/MihasBel/test-transactions-service/adapters/broker
- github.com/MohitArora1/gallery/controller
- 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/PharbersDeveloper/bp-go-lib/kafka
- github.com/RafaelDalarosa/fc-bank/infra/kafka
- github.com/SardorSaidov8084/restaurant-payment-service/src/application/integration_events/handlers/card_created
- github.com/SerkanKutlu/orderService/pkg/kafka
- github.com/SourceFellows/confluent-kafka-go/examples/admin_create_topic
- github.com/SourceFellows/confluent-kafka-go/examples/admin_delete_topics
- github.com/SourceFellows/confluent-kafka-go/examples/admin_describe_config
- github.com/SourceFellows/confluent-kafka-go/examples/confluent_cloud_example
- github.com/SourceFellows/confluent-kafka-go/examples/consumer_channel_example
- github.com/SourceFellows/confluent-kafka-go/examples/consumer_example
- github.com/SourceFellows/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/SourceFellows/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/SourceFellows/confluent-kafka-go/examples/go-kafkacat
- github.com/SourceFellows/confluent-kafka-go/examples/idempotent_producer_example
- github.com/SourceFellows/confluent-kafka-go/examples/library-version
- github.com/SourceFellows/confluent-kafka-go/examples/oauthbearer_example
- github.com/SourceFellows/confluent-kafka-go/examples/producer_channel_example
- github.com/SourceFellows/confluent-kafka-go/examples/producer_example
- github.com/SourceFellows/confluent-kafka-go/examples/stats_example
- github.com/SourceFellows/confluent-kafka-go/examples/transactions_example
- github.com/SourceFellows/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/SourceFellows/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/SourceFellows/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/SourceFellows/confluent-kafka-go/soaktest
- github.com/SourceFellows/confluent-kafka-go/soaktest/soakclient
- github.com/SourceFellows/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/TechMaster/LearnGo/Kafka
- github.com/Telefonica/prometheus-kafka-adapter
- 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/examples/kafka_pubsub/transactional_producer
- 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/ch03-producers/01-simple-examples
- github.com/aaron-zeisler/kafka-the-definitive-guide/ch03-producers/02-avro
- github.com/aaron-zeisler/kafka-the-definitive-guide/ch03-producers/03-partitions
- github.com/aaron-zeisler/kafka-the-definitive-guide/ch04-consumers
- github.com/aayush-agarwal1/kafka
- github.com/abhaynpai/go-benchmark-kafka-api/producer
- github.com/abhirajranjan/spaces/chat/config
- github.com/abhirajranjan/spaces/chat/internal/consumer
- github.com/abhirajranjan/spaces/chat/internal/consumerlistener
- github.com/abhirajranjan/spaces/chat/internal/eventHandler/CreateRoom
- github.com/abhirajranjan/spaces/chat/internal/eventHandler/DeleteChat
- github.com/abhirajranjan/spaces/chat/internal/eventHandler/DeleteRoom
- github.com/abhirajranjan/spaces/chat/internal/eventHandler/NewChat
- github.com/abhirajranjan/spaces/chat/internal/eventHandler/ReadChat
- github.com/abhirajranjan/spaces/chat/internal/eventHandler/RegisterUser
- github.com/abhirajranjan/spaces/chat/internal/producer
- github.com/abhirajranjan/spaces/chat/internal/producerlogger
- github.com/abhirajranjan/spaces/chat/pkg/logger
- github.com/abhirajranjan/spaces/community/config
- github.com/abhirajranjan/spaces/community/internal/consumer
- github.com/abhirajranjan/spaces/community/internal/consumerlistener
- github.com/abhirajranjan/spaces/community/internal/eventHandler/GetCommunity
- github.com/abhirajranjan/spaces/community/internal/eventHandler/NewCommunity
- github.com/abhirajranjan/spaces/community/internal/eventHandler/SearchCommunity
- github.com/abhirajranjan/spaces/community/internal/eventHandler/UpdateCommunity
- github.com/abhirajranjan/spaces/community/internal/eventHandler/UpdateSpaces
- github.com/abhirajranjan/spaces/community/internal/producer
- github.com/abhirajranjan/spaces/community/internal/producerlogger
- github.com/abhirajranjan/spaces/community/pkg/logger
- github.com/aboronilov/go-kafka-microservices/data_receiver
- github.com/accuknox/auto-policy-discovery/src/feedconsumer
- github.com/aclk/goblog/common/kafka
- github.com/acmutd/bsg/central-service/services
- github.com/adaickalavan/machine-learning-deployment-extended/govideo
- github.com/adaickalavan/scalable-deployment-kubernetes-extended/govideo
- github.com/adamatti/sandboxgo/Kafka
- github.com/addodelgrossi/kc
- 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/adryhappier/gin-kafka-mongo/src/handlers/job
- github.com/afandylamusu/go-boilerplate
- github.com/agis/confluent-interceptor-segfault
- github.com/ahmadfajar92/flexible-plate/go/src
- github.com/aifaniyi/kafkaclient
- github.com/airingone/air-kafkaclient
- github.com/ajlima/go-ms-arch-example/cmd
- github.com/akalmyk/kafker
- github.com/akolybelnikov/xm-exercise/internal/kafka
- github.com/aleksbgs/ambassador/src/controllers
- github.com/alex-bezverkhniy/calltester/pkg/services
- github.com/alexdsayandexru/sorm/internal/kafka
- github.com/alfredyang1986/blackmirror/bmkafka
- github.com/aliforever/gocom/pubsub
- github.com/alifpay/training/kafka
- github.com/alistairking/confluent-kafka-go/examples/admin_create_topic
- github.com/alistairking/confluent-kafka-go/examples/admin_delete_topics
- github.com/alistairking/confluent-kafka-go/examples/admin_describe_config
- github.com/alistairking/confluent-kafka-go/examples/confluent_cloud_example
- github.com/alistairking/confluent-kafka-go/examples/consumer_channel_example
- github.com/alistairking/confluent-kafka-go/examples/consumer_example
- github.com/alistairking/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/alistairking/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/alistairking/confluent-kafka-go/examples/go-kafkacat
- github.com/alistairking/confluent-kafka-go/examples/idempotent_producer_example
- github.com/alistairking/confluent-kafka-go/examples/library-version
- github.com/alistairking/confluent-kafka-go/examples/oauthbearer_example
- github.com/alistairking/confluent-kafka-go/examples/producer_channel_example
- github.com/alistairking/confluent-kafka-go/examples/producer_example
- github.com/alistairking/confluent-kafka-go/examples/stats_example
- github.com/alistairking/confluent-kafka-go/examples/transactions_example
- github.com/alistairking/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/alistairking/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/alistairking/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/alkoenig09/confluent-kafka-go/examples/admin_create_topic
- github.com/alkoenig09/confluent-kafka-go/examples/admin_delete_topics
- github.com/alkoenig09/confluent-kafka-go/examples/admin_describe_config
- github.com/alkoenig09/confluent-kafka-go/examples/confluent_cloud_example
- github.com/alkoenig09/confluent-kafka-go/examples/consumer_channel_example
- github.com/alkoenig09/confluent-kafka-go/examples/consumer_example
- github.com/alkoenig09/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/alkoenig09/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/alkoenig09/confluent-kafka-go/examples/go-kafkacat
- github.com/alkoenig09/confluent-kafka-go/examples/idempotent_producer_example
- github.com/alkoenig09/confluent-kafka-go/examples/library-version
- github.com/alkoenig09/confluent-kafka-go/examples/oauthbearer_example
- github.com/alkoenig09/confluent-kafka-go/examples/producer_channel_example
- github.com/alkoenig09/confluent-kafka-go/examples/producer_example
- github.com/alkoenig09/confluent-kafka-go/examples/stats_example
- github.com/alkoenig09/confluent-kafka-go/examples/transactions_example
- github.com/alkoenig09/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/alkoenig09/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/alkoenig09/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/alokic/queue/app/dispatcher/queue/kafka
- github.com/alphazero/confluent-kafka-go/examples/consumer_channel_example
- github.com/alphazero/confluent-kafka-go/examples/consumer_example
- github.com/alphazero/confluent-kafka-go/examples/go-kafkacat
- github.com/alphazero/confluent-kafka-go/examples/producer_channel_example
- github.com/alphazero/confluent-kafka-go/examples/producer_example
- github.com/alphazero/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/alphazero/confluent-kafka-go/kafkatest/go_verifiable_producer
- 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/amrHassanAbdallah/notificationaway/test
- github.com/amruthpremjith/kafka-consumer-test/consumer
- github.com/andiveloper/eventor/pkg
- github.com/andrew-hillier/protocol-buffers
- github.com/andsleonardo/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/animber-coder/gokafka
- github.com/antalakas/stream-structs
- github.com/anthonyhartanto/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/antifuchs/mz-certificate-transparency
- github.com/architecture-it/go-platform/AMQStream
- github.com/ariandi/kilat-be-go1
- github.com/aristofaneslira/curso-fullcycle/go/internal/market/entity/infra/kafka
- github.com/arriqaaq/gkc
- github.com/artembudaiev/feeder/internal/kafka
- github.com/ashishbabar/go-eth-api-contract-service/utils
- github.com/asiragusa/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/autoluck/go-kafka/test
- github.com/avisiedo/go-microservice-1/internal/interface/presenter/event
- github.com/bacamargo/invest-dash-with-home-broker/go/internal/infra/kafka
- 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/bcowtech/lib-kafka
- github.com/beeketing/confluent-kafka-go/examples/admin_create_topic
- github.com/beeketing/confluent-kafka-go/examples/admin_delete_topics
- github.com/beeketing/confluent-kafka-go/examples/admin_describe_config
- github.com/beeketing/confluent-kafka-go/examples/confluent_cloud_example
- github.com/beeketing/confluent-kafka-go/examples/consumer_channel_example
- github.com/beeketing/confluent-kafka-go/examples/consumer_example
- github.com/beeketing/confluent-kafka-go/examples/go-kafkacat
- github.com/beeketing/confluent-kafka-go/examples/producer_channel_example
- github.com/beeketing/confluent-kafka-go/examples/producer_example
- github.com/beeketing/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/beeketing/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/bengtrj/simple-kafka-producer
- github.com/bioform/go-web-app-template/config
- github.com/blacklane/go-libs/otel/examples
- github.com/blacklane/go-libs/otel/examples/cmd/events
- github.com/blacklane/go-libs/otel/examples/cmd/http
- github.com/blacklane/go-libs/x/events
- github.com/blacklane/go-libs/x/events/examples/oauth/consumer
- github.com/blacklane/go-libs/x/events/examples/oauth/producer
- github.com/blacklane/go-libs/x/events/examples/without-auth/consumer
- github.com/blacklane/go-libs/x/events/examples/without-auth/producer
- github.com/blendle/go-streamprocessor/streamclient/kafkaclient
- github.com/blendle/go-streamprocessor/streamconfig
- github.com/blendle/go-streamprocessor/streamconfig/kafkaconfig
- github.com/blendle/go-streamprocessor/v3/streamclient/kafkaclient
- github.com/blendle/go-streamprocessor/v3/streamconfig
- github.com/blendle/go-streamprocessor/v3/streamconfig/kafkaconfig
- github.com/blendle/pg2kafka
- github.com/bondzai/portfolio-backend/pkg/kafka
- github.com/bookrun-go/guiche
- github.com/box-delivery/kafka-go
- github.com/brettcodling/kafkalib
- github.com/briansorahan/kafka-admin
- github.com/bro-n-bro/spacebox-writer/adapter/broker
- github.com/btubbs/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/bytemoves/toll-calculator/distance_calculator
- github.com/callistaenterprise/goblog/common/kafka
- github.com/caoloss/-serverless-event-gateway-connectorpy/sources/kafka
- github.com/carstenmichel/godmpkfk
- github.com/carwale/golibraries/kafka
- github.com/chandresh-pancholi/edith/pkg/kafka/admin
- github.com/changlex/myproject/common
- github.com/chow1937/confluent-kafka-go/examples/consumer_channel_example
- github.com/chow1937/confluent-kafka-go/examples/consumer_example
- github.com/chow1937/confluent-kafka-go/examples/go-kafkacat
- github.com/chow1937/confluent-kafka-go/examples/producer_channel_example
- github.com/chow1937/confluent-kafka-go/examples/producer_example
- github.com/chow1937/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/chow1937/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/christian-elsee/kafka/pkg
- github.com/christianvozar/hex-example/internal/adapter/kafka
- github.com/chuahjw/kafka-prometheus-exporter
- github.com/ciblele/siemens-energy/Rascunhos
- github.com/clferracin/minientregas-simulator/infra/kafka
- github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mcis/collector
- github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mcis/collector/k8s_collector
- github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mck8s/collector
- github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mck8s/collector/k8s_collector
- 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/colivi/confluent-kafka-go/examples/admin_create_topic
- github.com/colivi/confluent-kafka-go/examples/admin_delete_topics
- github.com/colivi/confluent-kafka-go/examples/admin_describe_config
- github.com/colivi/confluent-kafka-go/examples/confluent_cloud_example
- github.com/colivi/confluent-kafka-go/examples/consumer_channel_example
- github.com/colivi/confluent-kafka-go/examples/consumer_example
- github.com/colivi/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/colivi/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/colivi/confluent-kafka-go/examples/go-kafkacat
- github.com/colivi/confluent-kafka-go/examples/idempotent_producer_example
- github.com/colivi/confluent-kafka-go/examples/library-version
- github.com/colivi/confluent-kafka-go/examples/oauthbearer_example
- github.com/colivi/confluent-kafka-go/examples/producer_channel_example
- github.com/colivi/confluent-kafka-go/examples/producer_example
- github.com/colivi/confluent-kafka-go/examples/stats_example
- github.com/colivi/confluent-kafka-go/examples/transactions_example
- github.com/colivi/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/colivi/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/colivi/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/common-go/kafka/confluent
- github.com/confluentinc/confluent-kafka-go-dev/examples/admin_create_topic
- github.com/confluentinc/confluent-kafka-go-dev/examples/admin_delete_topics
- github.com/confluentinc/confluent-kafka-go-dev/examples/admin_describe_config
- github.com/confluentinc/confluent-kafka-go-dev/examples/confluent_cloud_example
- github.com/confluentinc/confluent-kafka-go-dev/examples/consumer_channel_example
- github.com/confluentinc/confluent-kafka-go-dev/examples/consumer_example
- github.com/confluentinc/confluent-kafka-go-dev/examples/idempotent_producer_example
- github.com/confluentinc/confluent-kafka-go-dev/examples/oauthbearer_example
- github.com/confluentinc/confluent-kafka-go-dev/examples/producer_channel_example
- github.com/confluentinc/confluent-kafka-go-dev/examples/producer_example
- github.com/confluentinc/confluent-kafka-go-dev/examples/stats_example
- github.com/confluentinc/confluent-kafka-go-dev/kafkatest/go_verifiable_consumer
- github.com/confluentinc/confluent-kafka-go-dev/kafkatest/go_verifiable_producer
- github.com/confluentinc/confluent-kafka-go-example
- github.com/confluentinc/confluent-kafka-go/examples/admin_alter_consumer_group_offsets
- github.com/confluentinc/confluent-kafka-go/examples/admin_create_acls
- github.com/confluentinc/confluent-kafka-go/examples/admin_create_topic
- github.com/confluentinc/confluent-kafka-go/examples/admin_delete_acls
- github.com/confluentinc/confluent-kafka-go/examples/admin_delete_consumer_groups
- github.com/confluentinc/confluent-kafka-go/examples/admin_delete_topics
- github.com/confluentinc/confluent-kafka-go/examples/admin_describe_acls
- github.com/confluentinc/confluent-kafka-go/examples/admin_describe_config
- github.com/confluentinc/confluent-kafka-go/examples/admin_describe_consumer_groups
- github.com/confluentinc/confluent-kafka-go/examples/admin_list_consumer_group_offsets
- github.com/confluentinc/confluent-kafka-go/examples/admin_list_consumer_groups
- github.com/confluentinc/confluent-kafka-go/examples/avro_generic_consumer_example
- github.com/confluentinc/confluent-kafka-go/examples/avro_generic_producer_example
- github.com/confluentinc/confluent-kafka-go/examples/avro_specific_consumer_example
- github.com/confluentinc/confluent-kafka-go/examples/avro_specific_producer_example
- github.com/confluentinc/confluent-kafka-go/examples/confluent_cloud_example
- github.com/confluentinc/confluent-kafka-go/examples/consumer_example
- github.com/confluentinc/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/confluentinc/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/confluentinc/confluent-kafka-go/examples/go-kafkacat
- github.com/confluentinc/confluent-kafka-go/examples/idempotent_producer_example
- github.com/confluentinc/confluent-kafka-go/examples/json_consumer_example
- github.com/confluentinc/confluent-kafka-go/examples/json_producer_example
- github.com/confluentinc/confluent-kafka-go/examples/legacy/consumer_channel_example
- github.com/confluentinc/confluent-kafka-go/examples/legacy/producer_channel_example
- github.com/confluentinc/confluent-kafka-go/examples/library-version
- github.com/confluentinc/confluent-kafka-go/examples/mockcluster_example
- github.com/confluentinc/confluent-kafka-go/examples/oauthbearer_consumer_example
- github.com/confluentinc/confluent-kafka-go/examples/oauthbearer_oidc_example
- github.com/confluentinc/confluent-kafka-go/examples/oauthbearer_producer_example
- github.com/confluentinc/confluent-kafka-go/examples/producer_custom_channel_example
- github.com/confluentinc/confluent-kafka-go/examples/producer_example
- github.com/confluentinc/confluent-kafka-go/examples/protobuf_consumer_example
- github.com/confluentinc/confluent-kafka-go/examples/protobuf_producer_example
- github.com/confluentinc/confluent-kafka-go/examples/stats_example
- github.com/confluentinc/confluent-kafka-go/examples/transactions_example
- github.com/confluentinc/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/confluentinc/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/confluentinc/confluent-kafka-go/soaktest
- github.com/confluentinc/confluent-kafka-go/soaktest/soakclient
- github.com/confluentinc/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/confluentinc/schema-deletion-tool/pkg
- github.com/contrerasarf03/kafka-client
- github.com/cornelia247/nyxfilms/rating/internal/ingester/kafka
- github.com/covaw/kafka-go/kafkatool
- github.com/cpustejovsky/franz
- github.com/criistiiandm/kafka-server/go/kafkaPlugin
- 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/examples/admin_create_topic
- github.com/cyberhaveninc/confluent-kafka-go/examples/admin_delete_topics
- github.com/cyberhaveninc/confluent-kafka-go/examples/admin_describe_config
- github.com/cyberhaveninc/confluent-kafka-go/examples/confluent_cloud_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/consumer_channel_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/consumer_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/cyberhaveninc/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/go-kafkacat
- github.com/cyberhaveninc/confluent-kafka-go/examples/idempotent_producer_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/library-version
- github.com/cyberhaveninc/confluent-kafka-go/examples/oauthbearer_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/producer_channel_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/producer_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/stats_example
- github.com/cyberhaveninc/confluent-kafka-go/examples/transactions_example
- github.com/cyberhaveninc/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/cyberhaveninc/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/cyberhaveninc/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/cyberhaveninc/confluent-kafka-go/soaktest
- github.com/cyberhaveninc/confluent-kafka-go/soaktest/soakclient
- github.com/cyberhaveninc/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/d7561985/confluent-kafka-go/examples/admin_create_topic
- github.com/d7561985/confluent-kafka-go/examples/admin_delete_topics
- github.com/d7561985/confluent-kafka-go/examples/admin_describe_config
- github.com/d7561985/confluent-kafka-go/examples/confluent_cloud_example
- github.com/d7561985/confluent-kafka-go/examples/consumer_channel_example
- github.com/d7561985/confluent-kafka-go/examples/consumer_example
- github.com/d7561985/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/d7561985/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/d7561985/confluent-kafka-go/examples/go-kafkacat
- github.com/d7561985/confluent-kafka-go/examples/idempotent_producer_example
- github.com/d7561985/confluent-kafka-go/examples/library-version
- github.com/d7561985/confluent-kafka-go/examples/oauthbearer_example
- github.com/d7561985/confluent-kafka-go/examples/producer_channel_example
- github.com/d7561985/confluent-kafka-go/examples/producer_example
- github.com/d7561985/confluent-kafka-go/examples/stats_example
- github.com/d7561985/confluent-kafka-go/examples/transactions_example
- github.com/d7561985/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/d7561985/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/d7561985/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/d7561985/kafka-ab/adapter/conf-kafka
- github.com/daib/confluent-kafka-go/examples/admin_create_topic
- github.com/daib/confluent-kafka-go/examples/admin_delete_topics
- github.com/daib/confluent-kafka-go/examples/admin_describe_config
- github.com/daib/confluent-kafka-go/examples/confluent_cloud_example
- github.com/daib/confluent-kafka-go/examples/consumer_channel_example
- github.com/daib/confluent-kafka-go/examples/consumer_example
- github.com/daib/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/daib/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/daib/confluent-kafka-go/examples/go-kafkacat
- github.com/daib/confluent-kafka-go/examples/idempotent_producer_example
- github.com/daib/confluent-kafka-go/examples/library-version
- github.com/daib/confluent-kafka-go/examples/oauthbearer_example
- github.com/daib/confluent-kafka-go/examples/producer_channel_example
- github.com/daib/confluent-kafka-go/examples/producer_example
- github.com/daib/confluent-kafka-go/examples/stats_example
- github.com/daib/confluent-kafka-go/examples/transactions_example
- github.com/daib/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/daib/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/daib/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/daib/confluent-kafka-go/soaktest
- github.com/daib/confluent-kafka-go/soaktest/soakclient
- github.com/daib/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/dalbarracin/kafka-golang-example/internal/kafka
- github.com/danielamazonas/imersao-fullstack-fullcycle/consumer
- github.com/danielmunro/otto-notification-service/internal/kafka
- github.com/daniil-kzn/graphql-go-tools/examples/kafka_pubsub/transactional_producer
- github.com/danilobandeira29/ms-wallet-balance/internal/kafka
- github.com/danyukod/chave-pix-utils/pkg/kafka
- github.com/danyukod/wallet-core-go/cmd/walletcore
- github.com/darccio/dd-trace-go/v2/contrib/confluentinc/confluent-kafka-go/kafka
- 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/examples/consumer_channel_example
- github.com/datadog/confluent-kafka-go/examples/consumer_example
- github.com/datadog/confluent-kafka-go/examples/go-kafkacat
- github.com/datadog/confluent-kafka-go/examples/producer_channel_example
- github.com/datadog/confluent-kafka-go/examples/producer_example
- github.com/datadog/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/datadog/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/datasage-io/datasage/src/integrations
- github.com/dawei101/gor/rkafka
- github.com/db-sara/kafkake
- github.com/dbi-digital-analytics/fungjai/webhook/producer
- github.com/debman/blacklog-exporter/internal/kafkaclient
- github.com/dedihartono801/go-clean-architecture/infrastructure/kafka
- github.com/deepfence/PacketStreamer/pkg/plugins/kafka
- github.com/deeptiman/go-cache-kubernetes/kafka
- github.com/deni1688/exercise_tracker/mykafka
- github.com/denniskern/kafka-producer-test
- github.com/derekyu332/goii/frame/kafka
- github.com/devfans/net-kafka-repeater/repeater
- 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/dianhadi/mq/pkg/mq/kafka
- github.com/diasjuniorr/code-commerce/codebank/infrastructure/kafka
- github.com/diegopacheco/go-playground/kafka
- github.com/digvijaywagh22/trial
- github.com/diogofgomespinheiro/fc-go-kafka-example/cmd/producer
- github.com/discomco/go-cart/sdk/drivers/kafka
- github.com/disturb16/kafkaclient
- github.com/dkienzle/network-monitor/pcap_kafka
- github.com/dmkorzh/history-service/cmd/call-collector
- github.com/dongrv/baselib/rabbitmq
- github.com/doublegrey/rest2kafka
- github.com/doziestar/kaftu/kafgo/pkg
- github.com/dphhyland/louisiana/ssf
- github.com/dragondarkon/go-docker
- github.com/dumunari/codebank/infrastructure/kafka
- github.com/duyanh1904/learn-docker-go/worker
- github.com/ebilsanta/social-network/backend/complex_services/follower_complex_service/services
- github.com/edfungus/eevee
- github.com/ednelsonap/gokafka/cmd/producer
- github.com/egravert/kafka-samples/manual-commit
- github.com/eko/confluent-kafka-go/examples/admin_create_topic
- github.com/eko/confluent-kafka-go/examples/admin_delete_topics
- github.com/eko/confluent-kafka-go/examples/admin_describe_config
- github.com/eko/confluent-kafka-go/examples/confluent_cloud_example
- github.com/eko/confluent-kafka-go/examples/consumer_channel_example
- github.com/eko/confluent-kafka-go/examples/consumer_example
- github.com/eko/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/eko/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/eko/confluent-kafka-go/examples/go-kafkacat
- github.com/eko/confluent-kafka-go/examples/idempotent_producer_example
- github.com/eko/confluent-kafka-go/examples/library-version
- github.com/eko/confluent-kafka-go/examples/oauthbearer_example
- github.com/eko/confluent-kafka-go/examples/producer_channel_example
- github.com/eko/confluent-kafka-go/examples/producer_example
- github.com/eko/confluent-kafka-go/examples/stats_example
- github.com/eko/confluent-kafka-go/examples/transactions_example
- github.com/eko/confluent-kafka-go/instrumentation/otel
- github.com/eko/confluent-kafka-go/instrumentation/otel/internal
- github.com/eko/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/eko/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/eko/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/ellofae/payment-system-kafka/payment-system/processor/cmd/system
- github.com/ellofae/payment-system-kafka/payment-system/processor/internal/processing
- github.com/ellofae/payment-system-kafka/payment-system/producer/internal/app
- github.com/ellofae/payment-system-kafka/payment-system/producer/internal/producing
- github.com/eltonfonseca/codebank/infra/kafka
- github.com/enkodio/pkg-outbox/internal/pkg/config/entity
- github.com/entropyx/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/erikurbanski/codebank/infrastructure/kafka
- github.com/ernestrc/logd-go/lua
- github.com/ervitis/go-kafka-client
- github.com/ethanhosier/go-kafka
- github.com/ewencp/confluent-kafka-go/examples/consumer_channel_example
- github.com/ewencp/confluent-kafka-go/examples/consumer_example
- github.com/ewencp/confluent-kafka-go/examples/go-kafkacat
- github.com/ewencp/confluent-kafka-go/examples/producer_channel_example
- github.com/ewencp/confluent-kafka-go/examples/producer_example
- github.com/ewencp/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/ewencp/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/exherb/confluent-kafka-go/examples/admin_create_topic
- github.com/exherb/confluent-kafka-go/examples/admin_delete_topics
- github.com/exherb/confluent-kafka-go/examples/admin_describe_config
- github.com/exherb/confluent-kafka-go/examples/consumer_channel_example
- github.com/exherb/confluent-kafka-go/examples/consumer_example
- github.com/exherb/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/exherb/confluent-kafka-go/examples/go-kafkacat
- github.com/exherb/confluent-kafka-go/examples/idempotent_producer_example
- github.com/exherb/confluent-kafka-go/examples/oauthbearer_example
- github.com/exherb/confluent-kafka-go/examples/producer_channel_example
- github.com/exherb/confluent-kafka-go/examples/producer_example
- github.com/exherb/confluent-kafka-go/examples/stats_example
- github.com/exherb/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/exherb/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/fabiojapa/saka-golang-kafka-producer
- github.com/fairyhunter13/kafkaclient
- github.com/felipeagger/kafka-golang/producer
- github.com/fiddeb/fwpolicymetrics/cmd
- github.com/figma/confluent-kafka-go-dev/examples/admin_create_topic
- github.com/figma/confluent-kafka-go-dev/examples/admin_delete_topics
- github.com/figma/confluent-kafka-go-dev/examples/admin_describe_config
- github.com/figma/confluent-kafka-go-dev/examples/confluent_cloud_example
- github.com/figma/confluent-kafka-go-dev/examples/consumer_channel_example
- github.com/figma/confluent-kafka-go-dev/examples/consumer_example
- github.com/figma/confluent-kafka-go-dev/examples/idempotent_producer_example
- github.com/figma/confluent-kafka-go-dev/examples/oauthbearer_example
- github.com/figma/confluent-kafka-go-dev/examples/producer_channel_example
- github.com/figma/confluent-kafka-go-dev/examples/producer_example
- github.com/figma/confluent-kafka-go-dev/examples/stats_example
- github.com/figma/confluent-kafka-go-dev/kafkatest/go_verifiable_consumer
- github.com/figma/confluent-kafka-go-dev/kafkatest/go_verifiable_producer
- github.com/figmagit/confluent-kafka-go-dev/examples/admin_create_topic
- github.com/figmagit/confluent-kafka-go-dev/examples/admin_delete_topics
- github.com/figmagit/confluent-kafka-go-dev/examples/admin_describe_config
- github.com/figmagit/confluent-kafka-go-dev/examples/confluent_cloud_example
- github.com/figmagit/confluent-kafka-go-dev/examples/consumer_channel_example
- github.com/figmagit/confluent-kafka-go-dev/examples/consumer_example
- github.com/figmagit/confluent-kafka-go-dev/examples/idempotent_producer_example
- github.com/figmagit/confluent-kafka-go-dev/examples/oauthbearer_example
- github.com/figmagit/confluent-kafka-go-dev/examples/producer_channel_example
- github.com/figmagit/confluent-kafka-go-dev/examples/producer_example
- github.com/figmagit/confluent-kafka-go-dev/examples/stats_example
- github.com/figmagit/confluent-kafka-go-dev/kafkatest/go_verifiable_consumer
- github.com/figmagit/confluent-kafka-go-dev/kafkatest/go_verifiable_producer
- github.com/finncolman/confluent-kafka-go/examples/admin_create_topic
- github.com/finncolman/confluent-kafka-go/examples/admin_delete_topics
- github.com/finncolman/confluent-kafka-go/examples/admin_describe_config
- github.com/finncolman/confluent-kafka-go/examples/confluent_cloud_example
- github.com/finncolman/confluent-kafka-go/examples/consumer_channel_example
- github.com/finncolman/confluent-kafka-go/examples/consumer_example
- github.com/finncolman/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/finncolman/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/finncolman/confluent-kafka-go/examples/go-kafkacat
- github.com/finncolman/confluent-kafka-go/examples/idempotent_producer_example
- github.com/finncolman/confluent-kafka-go/examples/library-version
- github.com/finncolman/confluent-kafka-go/examples/oauthbearer_example
- github.com/finncolman/confluent-kafka-go/examples/producer_channel_example
- github.com/finncolman/confluent-kafka-go/examples/producer_example
- github.com/finncolman/confluent-kafka-go/examples/stats_example
- github.com/finncolman/confluent-kafka-go/examples/transactions_example
- github.com/finncolman/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/finncolman/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/finncolman/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/flushentitypacket/kafka-playground
- github.com/fogcloud-io/fn-amqp-to-kafka
- github.com/forzyz/gokafffka
- github.com/fparareda/go-producer-kafka
- github.com/freel/go-kafka-rest
- github.com/frizkey/gocom/pubsub
- github.com/gabselbach/fullcycle10/infra/kafka
- github.com/galactichiker/asteroid/src/internal/logmill
- github.com/galvital/flux/eventstore
- github.com/gdfragoso/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/genears/kafka2websocket/k2ws
- github.com/geoffwilliams/kscanner/cmd/main
- github.com/georgeerickson/confluent-kafka-go/examples/consumer_channel_example
- github.com/georgeerickson/confluent-kafka-go/examples/consumer_example
- github.com/georgeerickson/confluent-kafka-go/examples/go-kafkacat
- github.com/georgeerickson/confluent-kafka-go/examples/producer_channel_example
- github.com/georgeerickson/confluent-kafka-go/examples/producer_example
- github.com/georgeerickson/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/georgeerickson/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/ggrrrr/notification-system/common-lib/eventbus
- 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/gleb-tocarenco/assistant_go
- github.com/go-bamboo/contrib/client/confluent
- github.com/gojekfarm/xtools/examples/xkafka
- github.com/gosom/kit/es/kafka
- github.com/gtsh77/kafka-mq-go/pkg/kafka
- github.com/gtsh77/kafka-mq-go/pkg/kafka/mocks
- github.com/gtsh77/kafka-mq-go/queue
- github.com/gtsh77/kafka-mq-go/queue/internal
- github.com/gtsh77/kafka-mq-go/queue/internal/mocks
- github.com/gtsh77/kafka-mq-go/queue/mocks
- github.com/gtsh77/kafka-mq-go/queue/redelivery
- github.com/gtsh77/kafka-mq-go/queue/redelivery/mocks
- github.com/gtsh77/kafka-mq-go/tests
- github.com/guil95/split-entrypoints/config/brokers/kafka
- github.com/guilherme-luvi/go-queue-worker/internal/queue
- github.com/guilhermefaleiros/codestream/video-processing/internal/infrastructure/kafka
- github.com/guilhermemrnd/codepix/application/kafka
- github.com/guipalm4/tracking-simulator/simulator/infra/kafka
- github.com/gunsluo/go-example/kafka
- github.com/gustavobretas/fullcycle/simulador/infra/kafka
- github.com/gwilym/confluent-kafka-go/examples/consumer_channel_example
- github.com/gwilym/confluent-kafka-go/examples/consumer_example
- github.com/gwilym/confluent-kafka-go/examples/go-kafkacat
- github.com/gwilym/confluent-kafka-go/examples/producer_channel_example
- github.com/gwilym/confluent-kafka-go/examples/producer_example
- github.com/gwilym/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/gwilym/confluent-kafka-go/kafkatest/go_verifiable_producer
- 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/herlloncardoso/gokafka/cmd/producer
- github.com/hewenyu/toolspackage/kafka_plus
- github.com/hexa00/confluent-kafka-go/examples/admin_create_topic
- github.com/hexa00/confluent-kafka-go/examples/admin_delete_topics
- github.com/hexa00/confluent-kafka-go/examples/admin_describe_config
- github.com/hexa00/confluent-kafka-go/examples/confluent_cloud_example
- github.com/hexa00/confluent-kafka-go/examples/consumer_channel_example
- github.com/hexa00/confluent-kafka-go/examples/consumer_example
- github.com/hexa00/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/hexa00/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/hexa00/confluent-kafka-go/examples/go-kafkacat
- github.com/hexa00/confluent-kafka-go/examples/idempotent_producer_example
- github.com/hexa00/confluent-kafka-go/examples/library-version
- github.com/hexa00/confluent-kafka-go/examples/oauthbearer_example
- github.com/hexa00/confluent-kafka-go/examples/producer_channel_example
- github.com/hexa00/confluent-kafka-go/examples/producer_example
- github.com/hexa00/confluent-kafka-go/examples/stats_example
- github.com/hexa00/confluent-kafka-go/examples/transactions_example
- github.com/hexa00/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/hexa00/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/hexa00/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/hoptical/grafana-kafka-datasource/pkg/kafka_client
- 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/examples/admin_create_topic
- github.com/huanggx-sea/confluent-kafka-go/examples/admin_delete_topics
- github.com/huanggx-sea/confluent-kafka-go/examples/admin_describe_config
- github.com/huanggx-sea/confluent-kafka-go/examples/confluent_cloud_example
- github.com/huanggx-sea/confluent-kafka-go/examples/consumer_channel_example
- github.com/huanggx-sea/confluent-kafka-go/examples/consumer_example
- github.com/huanggx-sea/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/huanggx-sea/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/huanggx-sea/confluent-kafka-go/examples/go-kafkacat
- github.com/huanggx-sea/confluent-kafka-go/examples/idempotent_producer_example
- github.com/huanggx-sea/confluent-kafka-go/examples/library-version
- github.com/huanggx-sea/confluent-kafka-go/examples/oauthbearer_example
- github.com/huanggx-sea/confluent-kafka-go/examples/producer_channel_example
- github.com/huanggx-sea/confluent-kafka-go/examples/producer_example
- github.com/huanggx-sea/confluent-kafka-go/examples/stats_example
- github.com/huanggx-sea/confluent-kafka-go/examples/transactions_example
- github.com/huanggx-sea/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/huanggx-sea/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/huanggx-sea/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/hugolhafner/wendigo/internal/services/kafka
- github.com/humanitas03/go-practice/go-kafka-consumer
- github.com/hunken/go-toolkit/pkg/kafka
- github.com/iamviniciuss/wallet-core-eda/balance-api/internal/infra/broker
- github.com/iamviniciuss/wallet-core-eda/balance-api/pkg/kafka
- github.com/iamviniciuss/wallet-core-eda/wallet-core/cmd/walletcore
- github.com/iamviniciuss/wallet-core-eda/wallet-core/pkg/kafka
- github.com/iamviniciuss/wallet-core-eda/wallet-core/scripts/database
- github.com/ignalina/templated_generator
- github.com/ijsong/farseer/pkg/kafka
- github.com/illenko/gofr-issue-replication
- github.com/inkochetkov/brokers-check/kafka
- github.com/instantpun/kafka-consumer
- github.com/intfish123/confluent-kafka-go/examples/admin_create_topic
- github.com/intfish123/confluent-kafka-go/examples/admin_delete_topics
- github.com/intfish123/confluent-kafka-go/examples/admin_describe_config
- github.com/intfish123/confluent-kafka-go/examples/confluent_cloud_example
- github.com/intfish123/confluent-kafka-go/examples/consumer_channel_example
- github.com/intfish123/confluent-kafka-go/examples/consumer_example
- github.com/intfish123/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/intfish123/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/intfish123/confluent-kafka-go/examples/go-kafkacat
- github.com/intfish123/confluent-kafka-go/examples/idempotent_producer_example
- github.com/intfish123/confluent-kafka-go/examples/library-version
- github.com/intfish123/confluent-kafka-go/examples/oauthbearer_example
- github.com/intfish123/confluent-kafka-go/examples/producer_channel_example
- github.com/intfish123/confluent-kafka-go/examples/producer_example
- github.com/intfish123/confluent-kafka-go/examples/stats_example
- github.com/intfish123/confluent-kafka-go/examples/transactions_example
- github.com/intfish123/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/intfish123/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/intfish123/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/intfish123/confluent-kafka-go/soaktest
- github.com/intfish123/confluent-kafka-go/soaktest/soakclient
- github.com/intfish123/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/iqbaludinm/hr-microservice/auth-service
- github.com/iqbaludinm/hr-microservice/auth-service/config
- github.com/iqbaludinm/hr-microservice/auth-service/service/producers
- github.com/iqbaludinm/hr-microservice/profile-service
- github.com/iqbaludinm/hr-microservice/profile-service/config
- github.com/iqbaludinm/hr-microservice/profile-service/service/producers
- github.com/iqbaludinm/hr-microservice/user-service
- github.com/iqbaludinm/hr-microservice/user-service/config
- github.com/iqbaludinm/hr-microservice/user-service/service/producers
- github.com/iwanjunaid/basesvc/adapter/repository/event
- github.com/iwanjunaid/basesvc/cmd
- github.com/iwanjunaid/basesvc/infrastructure/consumer
- github.com/iwanjunaid/basesvc/infrastructure/datastore
- github.com/iwanjunaid/basesvc/infrastructure/mokabox
- github.com/iwanjunaid/basesvc/infrastructure/rest
- github.com/iwanjunaid/basesvc/internal/kafka
- github.com/iwanjunaid/basesvc/registry
- github.com/izaakdale/kafka-client
- github.com/izzanzahrial/test-kafka
- github.com/jacsonrsasse/imersao-full-cycle/codebank/infra/kafka
- github.com/jadoint/micro/pkg/msgqueue
- github.com/jakopako/dnstap-sensor
- github.com/jami/kafka-eb-collector/src
- github.com/jandro-es/merlin/consumers
- 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/jhq0113/gochat/lib/pubsub
- github.com/jiaying2001/agent/kafka
- github.com/joaolevi/golang_projects/pkg/kafka
- github.com/joaoprds/project_bank/infrastructure/kafka
- github.com/joelsantos-js/home-breaker/internal/marktet/infra/kafka
- github.com/johncylee/jiji
- github.com/joseluis8906/project-layout/pkg/kafka
- github.com/joseluiszuflores/kafka-examples/confluent
- github.com/josenaldo/fc-gokafka/cmd/producer
- github.com/joshchu00/finance-go-common/kafka
- github.com/josvisser66/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/journeymidnight/yig/messagebus/kafka
- github.com/jspc/rp-consumer/produce
- 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/karidea/release-changelog
- github.com/kartpop/connector-api/pkg/data/kafkaq
- github.com/kata-ai/messagebus-golang-kafka/messagebus
- github.com/kbehouse/go-kafka-ksql
- github.com/keigodasu/kafka-tail/lib
- github.com/ken-house/go-scaffold/utils/prototype/broker/xkafka
- github.com/ken-house/go-scaffold/utils/prototype/example/server/cmd
- github.com/ken-house/go-scaffold/utils/prototype/pkg/client/kafka
- github.com/ken-house/go-scaffold/utils/prototype/test/kafka/consumer
- github.com/ken-house/go-scaffold/utils/prototype/test/kafka/producer
- github.com/kentus/automotivetechnologysolutions/go
- github.com/kirankumardg/kafkaexp
- github.com/kjansson/skyffel-kafka
- github.com/kkHAIKE/confluent-kafka-go/examples/admin_create_topic
- github.com/kkHAIKE/confluent-kafka-go/examples/admin_delete_topics
- github.com/kkHAIKE/confluent-kafka-go/examples/admin_describe_config
- github.com/kkHAIKE/confluent-kafka-go/examples/confluent_cloud_example
- github.com/kkHAIKE/confluent-kafka-go/examples/consumer_channel_example
- github.com/kkHAIKE/confluent-kafka-go/examples/consumer_example
- github.com/kkHAIKE/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/kkHAIKE/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/kkHAIKE/confluent-kafka-go/examples/go-kafkacat
- github.com/kkHAIKE/confluent-kafka-go/examples/idempotent_producer_example
- github.com/kkHAIKE/confluent-kafka-go/examples/library-version
- github.com/kkHAIKE/confluent-kafka-go/examples/oauthbearer_example
- github.com/kkHAIKE/confluent-kafka-go/examples/producer_channel_example
- github.com/kkHAIKE/confluent-kafka-go/examples/producer_example
- github.com/kkHAIKE/confluent-kafka-go/examples/stats_example
- github.com/kkHAIKE/confluent-kafka-go/examples/transactions_example
- github.com/kkHAIKE/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/kkHAIKE/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/kkHAIKE/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/kkHAIKE/confluent-kafka-go/soaktest
- github.com/kkHAIKE/confluent-kafka-go/soaktest/soakclient
- github.com/kkHAIKE/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/kkeker/go-kafka-source-http
- github.com/kkhaike/confluent-kafka-go/examples/admin_create_topic
- github.com/kkhaike/confluent-kafka-go/examples/admin_delete_topics
- github.com/kkhaike/confluent-kafka-go/examples/admin_describe_config
- github.com/kkhaike/confluent-kafka-go/examples/confluent_cloud_example
- github.com/kkhaike/confluent-kafka-go/examples/consumer_channel_example
- github.com/kkhaike/confluent-kafka-go/examples/consumer_example
- github.com/kkhaike/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/kkhaike/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/kkhaike/confluent-kafka-go/examples/go-kafkacat
- github.com/kkhaike/confluent-kafka-go/examples/idempotent_producer_example
- github.com/kkhaike/confluent-kafka-go/examples/library-version
- github.com/kkhaike/confluent-kafka-go/examples/oauthbearer_example
- github.com/kkhaike/confluent-kafka-go/examples/producer_channel_example
- github.com/kkhaike/confluent-kafka-go/examples/producer_example
- github.com/kkhaike/confluent-kafka-go/examples/stats_example
- github.com/kkhaike/confluent-kafka-go/examples/transactions_example
- github.com/kkhaike/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/kkhaike/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/kkhaike/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/kkhaike/confluent-kafka-go/soaktest
- github.com/kkhaike/confluent-kafka-go/soaktest/soakclient
- github.com/kkhaike/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/kyma-incubator/knative-kafka/pkg/channel/message
- github.com/kyma-incubator/knative-kafka/pkg/channel/producer
- github.com/kyma-incubator/knative-kafka/pkg/channel/test
- github.com/kyma-incubator/knative-kafka/pkg/common/kafka/admin
- github.com/kyma-incubator/knative-kafka/pkg/common/kafka/consumer
- github.com/kyma-incubator/knative-kafka/pkg/common/kafka/producer
- github.com/kyma-incubator/knative-kafka/pkg/common/kafka/util
- github.com/kyma-incubator/knative-kafka/pkg/controller/kafkachannel
- github.com/kyma-incubator/knative-kafka/pkg/controller/test
- github.com/kyma-incubator/knative-kafka/pkg/dispatcher/dispatcher
- 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/lcrownover/lazycmd/internal/lazycmd
- github.com/leocomelli/kafka-ssl-example/go-client-app
- github.com/linedevth/echo-kafka-producer-example/producer
- 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/liusuxian/go-toolkit/gtkkafka
- 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/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/lovelydett/my_ieee/internel/components
- github.com/lrweck/todo/internal/publisher/kafka
- github.com/lsgndln/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/luansapelli/kafka-producer
- github.com/lucasviniciosfs/codebank/infrastructure/kafka
- github.com/luiscetta/codebank/infrastructure/kafka
- github.com/luizgribeiro/kafka-bbb-poc/src
- github.com/luopengift/pkg/kafka2
- github.com/luyenw/tech-training/go-kafka
- github.com/m0-ar/ambassador-microsevices-golang/admin/src/events
- github.com/maan19/golang-eventdriven-microservices
- github.com/macmessa/imersao-fullcycle3/codebank/infrastructure/message_broker
- github.com/madridwan/kafka/kafka/confluent
- 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/auth-service/infrastructure/queue
- github.com/malytinKonstantin/go-messenger-mono/auth-service/infrastructure/server
- github.com/malytinKonstantin/go-messenger-mono/friendship-service/infrastructure/queue
- github.com/malytinKonstantin/go-messenger-mono/friendship-service/infrastructure/server
- github.com/malytinKonstantin/go-messenger-mono/friendship-service/internal/delivery/grpc
- github.com/malytinKonstantin/go-messenger-mono/messaging-service/infrastructure/queue
- github.com/malytinKonstantin/go-messenger-mono/messaging-service/infrastructure/server
- github.com/malytinKonstantin/go-messenger-mono/messaging-service/internal/usecase/message
- github.com/malytinKonstantin/go-messenger-mono/notification-service/infrastructure/queue
- github.com/malytinKonstantin/go-messenger-mono/notification-service/infrastructure/server
- github.com/malytinKonstantin/go-messenger-mono/user-service/infrastructure/queue
- github.com/mamalmaleki/go-movie/cmd/ratingingester
- github.com/mansi-rajora09/zbpkafka
- github.com/marcelofabianov/contract_management_service_go/pkg/kafka
- github.com/mark-christiansen/go-kafka/confluent
- github.com/matheusteodoro01/go-clean-arch/src/infra/providers
- github.com/mathpresso/milvus/pkg/mq/msgstream/mqwrapper/kafka
- 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/maxim-kuderko/coeus/Io
- github.com/mazitovt/fintechapp/server/cmd
- github.com/mbecker/apisixkafkaupstream/plugins
- github.com/mehmetcantas/go-kafka-debezium
- github.com/merlinapp/queues-go/kafka
- github.com/mgrzybek/go-kafka-to-s3/kafka
- github.com/michaelprice232/image-processor-api/internal/validate-profile
- github.com/micheltank/crypto-price-alert/notification-service/cmd/app
- github.com/milindl/confluent-kafka-go/v2/kafka/go_rdkafka_generr
- github.com/milvus-io/milvus/pkg/mq/msgstream/mqwrapper/kafka
- github.com/mindwingx/graph-aggregator/driver
- github.com/minhphu0304/dumbo/producer
- github.com/mithunril/kafka-message-scheduler/clientlib
- github.com/mithunril/kafka-message-scheduler/config
- github.com/mithunril/kafka-message-scheduler/internal/test
- github.com/mithunril/kafka-message-scheduler/runner/kafka
- github.com/mithunril/kafka-message-scheduler/schedule/kafka
- github.com/mithunril/kafka-message-scheduler/store/kafka
- github.com/mmkader85/learn-kafka-golang/kafka
- github.com/mohitarora1/gallery/controller
- github.com/mordp1/espetinhodekafka/kafka-lab/debezium
- github.com/moritztng/codelense/backend/messaging
- github.com/moritztng/codelense/backend/services/github_load
- github.com/moritztng/codelense/backend/services/github_load_events
- github.com/moritztng/codelense/backend/services/github_load_organization
- github.com/moritztng/codelense/backend/services/github_load_organization/test
- github.com/moritztng/codelense/backend/services/github_load_organizations
- github.com/moritztng/codelense/backend/services/github_load_scheduler
- github.com/moritztng/codelense/backend/services/github_store
- github.com/moritztng/codelense/backend/util
- github.com/morka17/flare
- github.com/msilvaspa/fc2-gokafka/cmd/producer
- github.com/musictopeople/go-confluent-kafka
- github.com/mwives/event-driven-architecture-fc-3.0/walletcore-balance/cmd/walletcore-balance
- github.com/mwives/event-driven-architecture-fc-3.0/walletcore-balance/internal/event/handler
- github.com/mwives/event-driven-architecture-fc-3.0/walletcore-balance/pkg/kafka
- github.com/mwives/event-driven-architecture-fc-3.0/walletcore/cmd/walletcore
- github.com/mwives/event-driven-architecture-fc-3.0/walletcore/pkg/kafka
- github.com/myfintech/ark/src/go/lib/ark/cqrs/protocols/kafka
- github.com/mytn1992/ebd-carpark-availability-consumer
- github.com/namikmesic/kafka/lib
- github.com/nbwoodward/confluent-kafka-go/examples/admin_create_topic
- github.com/nbwoodward/confluent-kafka-go/examples/admin_delete_topics
- github.com/nbwoodward/confluent-kafka-go/examples/admin_describe_config
- github.com/nbwoodward/confluent-kafka-go/examples/confluent_cloud_example
- github.com/nbwoodward/confluent-kafka-go/examples/consumer_channel_example
- github.com/nbwoodward/confluent-kafka-go/examples/consumer_example
- github.com/nbwoodward/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/nbwoodward/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/nbwoodward/confluent-kafka-go/examples/go-kafkacat
- github.com/nbwoodward/confluent-kafka-go/examples/idempotent_producer_example
- github.com/nbwoodward/confluent-kafka-go/examples/library-version
- github.com/nbwoodward/confluent-kafka-go/examples/oauthbearer_example
- github.com/nbwoodward/confluent-kafka-go/examples/producer_channel_example
- github.com/nbwoodward/confluent-kafka-go/examples/producer_example
- github.com/nbwoodward/confluent-kafka-go/examples/stats_example
- github.com/nbwoodward/confluent-kafka-go/examples/transactions_example
- github.com/nbwoodward/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/nbwoodward/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/nbwoodward/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/nbwoodward/confluent-kafka-go/soaktest
- github.com/nbwoodward/confluent-kafka-go/soaktest/soakclient
- github.com/nbwoodward/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/nearmeng/mango-go/plugin/mq/kafka
- github.com/neo-v2/gokafka/Consumer
- github.com/netoudi/codebank-transaction/infrastructure/kafka
- github.com/nguyencuong382/go-message-router/mkafka
- 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/nobletooth/dotanet/eventservice
- github.com/nowfred/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/nurali-techie/meetup-golang/go-kafka
- github.com/nxgtw/confluent-kafka-go/examples/admin_create_topic
- github.com/nxgtw/confluent-kafka-go/examples/admin_delete_topics
- github.com/nxgtw/confluent-kafka-go/examples/admin_describe_config
- github.com/nxgtw/confluent-kafka-go/examples/confluent_cloud_example
- github.com/nxgtw/confluent-kafka-go/examples/consumer_channel_example
- github.com/nxgtw/confluent-kafka-go/examples/consumer_example
- github.com/nxgtw/confluent-kafka-go/examples/go-kafkacat
- github.com/nxgtw/confluent-kafka-go/examples/producer_channel_example
- github.com/nxgtw/confluent-kafka-go/examples/producer_example
- github.com/nxgtw/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/nxgtw/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/octarinesec/confluent-kafka-go/examples/consumer_channel_example
- github.com/octarinesec/confluent-kafka-go/examples/consumer_example
- github.com/octarinesec/confluent-kafka-go/examples/go-kafkacat
- github.com/octarinesec/confluent-kafka-go/examples/producer_channel_example
- github.com/octarinesec/confluent-kafka-go/examples/producer_example
- github.com/octarinesec/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/octarinesec/confluent-kafka-go/kafkatest/go_verifiable_producer
- 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/examples/consumer_channel_example
- github.com/oscarhealth/confluent-kafka-go/examples/consumer_example
- github.com/oscarhealth/confluent-kafka-go/examples/go-kafkacat
- github.com/oscarhealth/confluent-kafka-go/examples/producer_channel_example
- github.com/oscarhealth/confluent-kafka-go/examples/producer_example
- github.com/oscarhealth/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/oscarhealth/confluent-kafka-go/kafkatest/go_verifiable_producer
- 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/ozoncp/ocp-issue-api/internal/events
- github.com/p12s/okko-video-converter/api/pkg/broker
- github.com/p12s/uber-popug/analitycs/pkg/broker
- github.com/p12s/uber-popug/auth/pkg/broker
- github.com/p12s/uber-popug/auth/pkg/handler
- github.com/p12s/uber-popug/billing/pkg/broker
- github.com/p12s/uber-popug/billing/pkg/handler
- github.com/p12s/uber-popug/task/pkg/broker
- github.com/p12s/uber-popug/task/pkg/handler
- github.com/palomasoftware/msds434_module_eight_kafka_demo
- github.com/panutat-p/learn-kafka
- github.com/patrick-east/kubecon-na-2020/custom-opa/plugins/logger
- github.com/patrickrhamon/codebank/infrastructure/kafka
- github.com/paulcager/kcat
- github.com/pcvolkmer/rwdp-obds-cleanup
- github.com/peak/confluent-kafka-go/examples/admin_create_topic
- github.com/peak/confluent-kafka-go/examples/admin_delete_topics
- github.com/peak/confluent-kafka-go/examples/admin_describe_config
- github.com/peak/confluent-kafka-go/examples/confluent_cloud_example
- github.com/peak/confluent-kafka-go/examples/consumer_channel_example
- github.com/peak/confluent-kafka-go/examples/consumer_example
- github.com/peak/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/peak/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/peak/confluent-kafka-go/examples/go-kafkacat
- github.com/peak/confluent-kafka-go/examples/idempotent_producer_example
- github.com/peak/confluent-kafka-go/examples/library-version
- github.com/peak/confluent-kafka-go/examples/oauthbearer_example
- github.com/peak/confluent-kafka-go/examples/producer_channel_example
- github.com/peak/confluent-kafka-go/examples/producer_example
- github.com/peak/confluent-kafka-go/examples/stats_example
- github.com/peak/confluent-kafka-go/examples/transactions_example
- github.com/peak/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/peak/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/peak/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/pedropereiraassis/full-cycle/kafka/go/cmd/consumer
- github.com/pedropereiraassis/full-cycle/kafka/go/cmd/producer
- github.com/pedropereiraassis/full-cycle/microsservices/balances/cmd/balances
- github.com/pedropereiraassis/full-cycle/microsservices/balances/pkg/kafka
- github.com/pedropereiraassis/full-cycle/microsservices/cmd/walletcore
- github.com/pedropereiraassis/full-cycle/microsservices/pkg/kafka
- github.com/pellared/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/peterP1998/notification-system/libs/notification/producer
- 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/piqba/common/pkg/broker/kafka
- github.com/pjcalvo/go-cache/utils
- github.com/podengo-project/idmsvc-backend/internal/api/event
- github.com/podengo-project/idmsvc-backend/internal/handler/impl
- github.com/podengo-project/idmsvc-backend/internal/infrastructure/event
- github.com/podengo-project/idmsvc-backend/internal/infrastructure/event/adapter
- github.com/podengo-project/idmsvc-backend/internal/infrastructure/event/handler
- github.com/podengo-project/idmsvc-backend/internal/infrastructure/event/producer
- github.com/podengo-project/idmsvc-backend/internal/interface/event
- github.com/podengo-project/idmsvc-backend/internal/test/mock/infrastructure/event
- github.com/podengo-project/idmsvc-backend/internal/test/mock/infrastructure/event/handler
- github.com/podengo-project/idmsvc-backend/internal/test/mock/interface/event
- 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/presencelearning/rhq-go-cmn/pubsub
- github.com/protsack-stephan/schema-registry-example/bridge
- github.com/psridhark/goatq/cmd/perfbench
- github.com/qalexandre/imersaofsfc2-simulator/infra/kafka
- github.com/qframe/handler-kafka
- github.com/qntfy/frafka
- github.com/quanghuynguyen1902/job-schedule/internal/kafka
- github.com/qudj/fly_lib/confluent_kafka
- github.com/radekg/karapace-demo
- github.com/raghuveer01/golang_fundamentals/go_workspace/kafka_demo
- github.com/ragnarula/go-kafka-redis
- github.com/ragul28/kafka-cli/queue
- github.com/rajsinghtech/fleet-telemetry-consumer
- github.com/ramazan-makhanov/golang-kafka/kafka-to-db
- github.com/rayokota/confluent-kafka-go/examples/admin_create_topic
- github.com/rayokota/confluent-kafka-go/examples/admin_delete_topics
- github.com/rayokota/confluent-kafka-go/examples/admin_describe_config
- github.com/rayokota/confluent-kafka-go/examples/confluent_cloud_example
- github.com/rayokota/confluent-kafka-go/examples/consumer_channel_example
- github.com/rayokota/confluent-kafka-go/examples/consumer_example
- github.com/rayokota/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/rayokota/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/rayokota/confluent-kafka-go/examples/go-kafkacat
- github.com/rayokota/confluent-kafka-go/examples/idempotent_producer_example
- github.com/rayokota/confluent-kafka-go/examples/library-version
- github.com/rayokota/confluent-kafka-go/examples/oauthbearer_example
- github.com/rayokota/confluent-kafka-go/examples/producer_channel_example
- github.com/rayokota/confluent-kafka-go/examples/producer_example
- github.com/rayokota/confluent-kafka-go/examples/stats_example
- github.com/rayokota/confluent-kafka-go/examples/transactions_example
- github.com/rayokota/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/rayokota/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/rayokota/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/rayokota/confluent-kafka-go/soaktest
- github.com/rayokota/confluent-kafka-go/soaktest/soakclient
- github.com/rayokota/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/rayokota/go-kcache/kcache
- github.com/razorpay/metro/pkg/messagebroker
- github.com/razz99/kafka-go
- github.com/rd-robin-senftleben/scanner-messaging/pkg/message/kafkabackend
- github.com/redhat-italy/redhat-sc23-eda/eda-edge-automation/engine-monitor
- github.com/redhat-partner-ecosystem/openshift-skunkworks/examples/kafka-listener
- github.com/redhatinsights/payload-tracker-go/internal/kafka
- github.com/reecerussell/kafka-ui/listener
- github.com/renatoaguimaraes/go-mongo-kafka-protobuf/kafka
- github.com/rewati/gdsb
- github.com/rideziro/go-messaging/kafka
- github.com/rigelbm/confluent-kafka-go/examples/admin_create_topic
- github.com/rigelbm/confluent-kafka-go/examples/admin_delete_topics
- github.com/rigelbm/confluent-kafka-go/examples/admin_describe_config
- github.com/rigelbm/confluent-kafka-go/examples/consumer_channel_example
- github.com/rigelbm/confluent-kafka-go/examples/consumer_example
- github.com/rigelbm/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/rigelbm/confluent-kafka-go/examples/go-kafkacat
- github.com/rigelbm/confluent-kafka-go/examples/idempotent_producer_example
- github.com/rigelbm/confluent-kafka-go/examples/oauthbearer_example
- github.com/rigelbm/confluent-kafka-go/examples/producer_channel_example
- github.com/rigelbm/confluent-kafka-go/examples/producer_example
- github.com/rigelbm/confluent-kafka-go/examples/stats_example
- github.com/rigelbm/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/rigelbm/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/rkritchat/grkafka
- github.com/robbinhan/go-kafka-topic
- github.com/robertomorel/gokafka/cmd/consumer
- github.com/rodrigoazv/go-bank/infra/kafka
- github.com/rodrigorssa/codebank/infra
- 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/roopeshsn/log-ingestor/log-ingestor/server
- github.com/rootameen/kafka-sse-stream
- github.com/roserossi/proyecto-ds-iii/kafka-server/go/kafkaPlugin
- github.com/rradu-dev/ecommerce-pdm-microservice/internal/common/bus/consumer
- github.com/ruhancs/card_transaction/infra/kafka
- github.com/rvaid/kafka_clients_go
- github.com/rverma-nsl/kafka-schemaregistry-protobuf
- github.com/rwynn/route81
- github.com/rzfhlv/go-kafka
- github.com/sadahal/mygodir/kafka
- github.com/safedep/gateway/services/pkg/common/messaging
- github.com/sainipankaj15/kafka-producer-in-golang
- 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/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/serenissimus/confluent-kafka-go/examples/admin_create_topic
- github.com/serenissimus/confluent-kafka-go/examples/admin_delete_topics
- github.com/serenissimus/confluent-kafka-go/examples/admin_describe_config
- github.com/serenissimus/confluent-kafka-go/examples/confluent_cloud_example
- github.com/serenissimus/confluent-kafka-go/examples/consumer_channel_example
- github.com/serenissimus/confluent-kafka-go/examples/consumer_example
- github.com/serenissimus/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/serenissimus/confluent-kafka-go/examples/go-kafkacat
- github.com/serenissimus/confluent-kafka-go/examples/idempotent_producer_example
- github.com/serenissimus/confluent-kafka-go/examples/library-version
- github.com/serenissimus/confluent-kafka-go/examples/oauthbearer_example
- github.com/serenissimus/confluent-kafka-go/examples/producer_channel_example
- github.com/serenissimus/confluent-kafka-go/examples/producer_example
- github.com/serenissimus/confluent-kafka-go/examples/stats_example
- github.com/serenissimus/confluent-kafka-go/examples/transactions_example
- github.com/serenissimus/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/serenissimus/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/serenissimus/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/sermojohn/otelkafka
- 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/shubhamguptafp/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/shubhamsonal/pub-sub-system/pub-sub/worker
- github.com/sibedge-llc/dp-services/eventer/internal/kafka
- github.com/simnotes/confluent-kafka-go/examples/admin_create_topic
- github.com/simnotes/confluent-kafka-go/examples/admin_delete_topics
- github.com/simnotes/confluent-kafka-go/examples/admin_describe_config
- github.com/simnotes/confluent-kafka-go/examples/confluent_cloud_example
- github.com/simnotes/confluent-kafka-go/examples/consumer_channel_example
- github.com/simnotes/confluent-kafka-go/examples/consumer_example
- github.com/simnotes/confluent-kafka-go/examples/go-kafkacat
- github.com/simnotes/confluent-kafka-go/examples/producer_channel_example
- github.com/simnotes/confluent-kafka-go/examples/producer_example
- github.com/simnotes/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/simnotes/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/sinhaparth5/go-kafka-grpc-server
- github.com/sivaone/go-kafka-websocket
- github.com/skapfer/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/sko00o/benchmark-kafka-go-clients
- github.com/slinkydeveloper/kafka-go-clients-benchmarks/confluent-kafka-go
- github.com/smallnest/kafka-go-examples/confluent-kafka-go
- github.com/software-engr-full-stack/vaskafka
- github.com/sotigr/go-core/brokers
- github.com/sourcefellows/confluent-kafka-go/examples/admin_create_topic
- github.com/sourcefellows/confluent-kafka-go/examples/admin_delete_topics
- github.com/sourcefellows/confluent-kafka-go/examples/admin_describe_config
- github.com/sourcefellows/confluent-kafka-go/examples/confluent_cloud_example
- github.com/sourcefellows/confluent-kafka-go/examples/consumer_channel_example
- github.com/sourcefellows/confluent-kafka-go/examples/consumer_example
- github.com/sourcefellows/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/sourcefellows/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/sourcefellows/confluent-kafka-go/examples/go-kafkacat
- github.com/sourcefellows/confluent-kafka-go/examples/idempotent_producer_example
- github.com/sourcefellows/confluent-kafka-go/examples/library-version
- github.com/sourcefellows/confluent-kafka-go/examples/oauthbearer_example
- github.com/sourcefellows/confluent-kafka-go/examples/producer_channel_example
- github.com/sourcefellows/confluent-kafka-go/examples/producer_example
- github.com/sourcefellows/confluent-kafka-go/examples/stats_example
- github.com/sourcefellows/confluent-kafka-go/examples/transactions_example
- github.com/sourcefellows/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/sourcefellows/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/sourcefellows/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/sourcefellows/confluent-kafka-go/soaktest
- github.com/sourcefellows/confluent-kafka-go/soaktest/soakclient
- github.com/sourcefellows/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/soyacen/easypubsub/ckafka/example
- github.com/splunk/kafka-mq-go/pkg/kafka
- github.com/splunk/kafka-mq-go/pkg/kafka/mocks
- github.com/splunk/kafka-mq-go/queue
- github.com/splunk/kafka-mq-go/queue/internal
- github.com/splunk/kafka-mq-go/queue/internal/mocks
- github.com/splunk/kafka-mq-go/queue/mocks
- github.com/splunk/kafka-mq-go/queue/redelivery
- github.com/splunk/kafka-mq-go/queue/redelivery/mocks
- github.com/splunk/kafka-mq-go/tests
- github.com/sponomis/confluent-kafka-go/examples/admin_create_topic
- github.com/sponomis/confluent-kafka-go/examples/admin_delete_topics
- github.com/sponomis/confluent-kafka-go/examples/admin_describe_config
- github.com/sponomis/confluent-kafka-go/examples/confluent_cloud_example
- github.com/sponomis/confluent-kafka-go/examples/consumer_channel_example
- github.com/sponomis/confluent-kafka-go/examples/consumer_example
- github.com/sponomis/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/sponomis/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/sponomis/confluent-kafka-go/examples/go-kafkacat
- github.com/sponomis/confluent-kafka-go/examples/idempotent_producer_example
- github.com/sponomis/confluent-kafka-go/examples/library-version
- github.com/sponomis/confluent-kafka-go/examples/oauthbearer_example
- github.com/sponomis/confluent-kafka-go/examples/producer_channel_example
- github.com/sponomis/confluent-kafka-go/examples/producer_example
- github.com/sponomis/confluent-kafka-go/examples/stats_example
- github.com/sponomis/confluent-kafka-go/examples/transactions_example
- github.com/sponomis/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/sponomis/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/sponomis/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/squareup/pranadb/kafka
- github.com/starius/confluent-kafka-go/examples/admin_create_topic
- github.com/starius/confluent-kafka-go/examples/admin_delete_topics
- github.com/starius/confluent-kafka-go/examples/admin_describe_config
- github.com/starius/confluent-kafka-go/examples/confluent_cloud_example
- github.com/starius/confluent-kafka-go/examples/consumer_channel_example
- github.com/starius/confluent-kafka-go/examples/consumer_example
- github.com/starius/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/starius/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/starius/confluent-kafka-go/examples/go-kafkacat
- github.com/starius/confluent-kafka-go/examples/idempotent_producer_example
- github.com/starius/confluent-kafka-go/examples/library-version
- github.com/starius/confluent-kafka-go/examples/oauthbearer_example
- github.com/starius/confluent-kafka-go/examples/producer_channel_example
- github.com/starius/confluent-kafka-go/examples/producer_example
- github.com/starius/confluent-kafka-go/examples/stats_example
- github.com/starius/confluent-kafka-go/examples/transactions_example
- github.com/starius/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/starius/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/starius/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/starius/confluent-kafka-go/soaktest
- github.com/starius/confluent-kafka-go/soaktest/soakclient
- github.com/starius/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/stb2132/confluent-kafka-go/examples/admin_create_topic
- github.com/stb2132/confluent-kafka-go/examples/admin_delete_topics
- github.com/stb2132/confluent-kafka-go/examples/admin_describe_config
- github.com/stb2132/confluent-kafka-go/examples/confluent_cloud_example
- github.com/stb2132/confluent-kafka-go/examples/consumer_channel_example
- github.com/stb2132/confluent-kafka-go/examples/consumer_example
- github.com/stb2132/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/stb2132/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/stb2132/confluent-kafka-go/examples/go-kafkacat
- github.com/stb2132/confluent-kafka-go/examples/idempotent_producer_example
- github.com/stb2132/confluent-kafka-go/examples/library-version
- github.com/stb2132/confluent-kafka-go/examples/oauthbearer_example
- github.com/stb2132/confluent-kafka-go/examples/producer_channel_example
- github.com/stb2132/confluent-kafka-go/examples/producer_example
- github.com/stb2132/confluent-kafka-go/examples/stats_example
- github.com/stb2132/confluent-kafka-go/examples/transactions_example
- github.com/stb2132/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/stb2132/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/stb2132/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/stb2132/confluent-kafka-go/soaktest
- github.com/stb2132/confluent-kafka-go/soaktest/soakclient
- github.com/stb2132/confluent-kafka-go/soaktest/soakclient_transaction
- github.com/stephenamsel/samsel-high-performance-proxy
- github.com/stevemns/confluent-kafka-go/examples/admin_create_topic
- github.com/stevemns/confluent-kafka-go/examples/admin_delete_topics
- github.com/stevemns/confluent-kafka-go/examples/admin_describe_config
- github.com/stevemns/confluent-kafka-go/examples/confluent_cloud_example
- github.com/stevemns/confluent-kafka-go/examples/consumer_channel_example
- github.com/stevemns/confluent-kafka-go/examples/consumer_example
- github.com/stevemns/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/stevemns/confluent-kafka-go/examples/cooperative_consumer_example
- github.com/stevemns/confluent-kafka-go/examples/go-kafkacat
- github.com/stevemns/confluent-kafka-go/examples/idempotent_producer_example
- github.com/stevemns/confluent-kafka-go/examples/library-version
- github.com/stevemns/confluent-kafka-go/examples/mockcluster_example
- github.com/stevemns/confluent-kafka-go/examples/oauthbearer_example
- github.com/stevemns/confluent-kafka-go/examples/producer_channel_example
- github.com/stevemns/confluent-kafka-go/examples/producer_example
- github.com/stevemns/confluent-kafka-go/examples/stats_example
- github.com/stevemns/confluent-kafka-go/examples/transactions_example
- github.com/stevemns/confluent-kafka-go/kafka/go_rdkafka_generr
- github.com/stevemns/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/stevemns/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/stevemns/confluent-kafka-go/soaktest
- github.com/stevemns/confluent-kafka-go/soaktest/soakclient
- github.com/stevemns/confluent-kafka-go/soaktest/soakclient_transaction
- 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/stwrtrio/coffee-shop/pkg/kafka
- github.com/suiguo/hwlib/kafka
- github.com/sumitroajiprabowo/go-kafka-docker
- github.com/sunnykrgupta/k8s-hpa-custom-autoscaling-kafka-metrics/go-kafka
- 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/taekoelias/imersao-fullcycle-9/codebank/infrastructure/kafka
- github.com/takecy/confluent-kafka-go/examples/consumer_channel_example
- github.com/takecy/confluent-kafka-go/examples/consumer_example
- github.com/takecy/confluent-kafka-go/examples/go-kafkacat
- github.com/takecy/confluent-kafka-go/examples/producer_channel_example
- github.com/takecy/confluent-kafka-go/examples/producer_example
- github.com/takecy/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/takecy/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/tarvip/confluent-kafka-go/examples/admin_create_topic
- github.com/tarvip/confluent-kafka-go/examples/admin_delete_topics
- github.com/tarvip/confluent-kafka-go/examples/admin_describe_config
- github.com/tarvip/confluent-kafka-go/examples/consumer_channel_example
- github.com/tarvip/confluent-kafka-go/examples/consumer_example
- github.com/tarvip/confluent-kafka-go/examples/consumer_offset_metadata
- github.com/tarvip/confluent-kafka-go/examples/go-kafkacat
- github.com/tarvip/confluent-kafka-go/examples/idempotent_producer_example
- github.com/tarvip/confluent-kafka-go/examples/oauthbearer_example
- github.com/tarvip/confluent-kafka-go/examples/producer_channel_example
- github.com/tarvip/confluent-kafka-go/examples/producer_example
- github.com/tarvip/confluent-kafka-go/examples/stats_example
- github.com/tarvip/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/tarvip/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/tdyas/pants-go-testing/kafka
- github.com/techmaster/learngo/Kafka
- github.com/tengattack/dandelion/mq
- github.com/tengzbiao/go-delayqueue/delay_queue
- github.com/tetriscode/commander/queue
- github.com/th3g00dc0d3r/codebank/infrastructure/kafka
- github.com/theboyisno-1/go-redis-kafka-docker-demo/pkg/kafka
- github.com/thiagorm28/code-bank/infrastructure/kafka
- github.com/thiagotilid/goframework
- github.com/third-place/notification-service/internal/kafka
- github.com/thomas91310/confluent-kafka-go/examples/consumer_channel_example
- github.com/thomas91310/confluent-kafka-go/examples/consumer_example
- github.com/thomas91310/confluent-kafka-go/examples/go-kafkacat
- github.com/thomas91310/confluent-kafka-go/examples/producer_channel_example
- github.com/thomas91310/confluent-kafka-go/examples/producer_example
- github.com/thomas91310/confluent-kafka-go/kafkatest/go_verifiable_consumer
- github.com/thomas91310/confluent-kafka-go/kafkatest/go_verifiable_producer
- github.com/thor77/kafka-stress-go
- github.com/tkeech1/kafka-sasl
- github.com/tl-framework/goframework
- github.com/todoapps2021/telegrambot/internal/kafka/producer
- github.com/tomassar/microservices-with-kafka
- github.com/tommzn/hdb-message-agent
- github.com/topfreegames/marathon/interfaces
- github.com/traff1k/demo-kafka-producer/kafka
- github.com/trsustme/kafka-lab/cmd
- github.com/tubenhirn/kafka-example
- 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/fullcycle-archdev-event-driven-architecture/balances/cmd/balances
- 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/vanillaverse/guardian/pkg/types
- github.com/vctrl/async-architecture/popug-billing/cmd/popug-billing-app
- github.com/vctrl/async-architecture/popug-billing/internal/model
- github.com/vctrl/async-architecture/popug-tasks/cmd/popug-tasks
- github.com/vctrl/async-architecture/popug-tasks/internal/api
- github.com/vctrl/async-architecture/popug-tasks/internal/model
- github.com/vctrl/async-architecture/week_2/popug-auth/cmd/popug-auth
- github.com/vctrl/async-architecture/week_2/popug-auth/internal/api
- github.com/vctrl/async-architecture/week_2/popug-auth/internal/model
- github.com/vctrl/async-architecture/week_2/popug-tasks/cmd/popug-tasks
- github.com/vctrl/async-architecture/week_2/popug-tasks/internal/api
- github.com/vctrl/async-architecture/week_2/popug-tasks/internal/model
- github.com/vflopes/slime/pkg/adapters/kafka-driver
- github.com/victorlss/go-examples/cmd/kafka
- github.com/vieiravitor/codebank/queue
- github.com/vieirinhasantana/kafka-go/pkg/kafka
- github.com/viniciusrsouza/projeto-soa/order/gateways/events
- github.com/vnscriptkid/kafka-fluency/consumer-group/failover/consumer-error
- github.com/vnscriptkid/kafka-fluency/consumer-group/failover/consumer-healthy
- github.com/vnscriptkid/kafka-fluency/consumer-group/failover/producer
- github.com/vnscriptkid/kafka-fluency/consumer-group/message-key/consumer
- github.com/vnscriptkid/kafka-fluency/consumer-group/message-key/producer
- github.com/vnscriptkid/kafka-fluency/consumer-group/multi-consumers-diff-group/consumer
- github.com/vnscriptkid/kafka-fluency/consumer-group/multi-consumers-diff-group/producer
- github.com/vnscriptkid/kafka-fluency/consumer-group/multi-consumers-same-group/consumer
- github.com/vnscriptkid/kafka-fluency/consumer-group/multi-consumers-same-group/producer
- github.com/vnscriptkid/kafka-fluency/error-handling/blocking-retry-consumer
- github.com/vnscriptkid/kafka-fluency/error-handling/blocking-retry-consumer-dlq
- github.com/vnscriptkid/kafka-fluency/error-handling/non-blocking-retry
- github.com/vnscriptkid/kafka-fluency/idempotent-consumers/consumers-pg
- github.com/vnscriptkid/kafka-fluency/idempotent-consumers/consumers-redis
- github.com/vnscriptkid/kafka-fluency/kafka-config/consumer-offset/consumer
- github.com/vnscriptkid/kafka-fluency/kafka-config/consumer-offset/producer
- github.com/vnscriptkid/kafka-fluency/multi-event-types/consumer
- github.com/vnscriptkid/kafka-fluency/multi-event-types/producer
- github.com/vnscriptkid/kafka-fluency/retry/consumer
- github.com/vnscriptkid/kafka-fluency/retry/producer
- github.com/vnscriptkid/sd-payment-system/retryable
- github.com/vulpes-ferrilata/catan-service/infrastructure
- github.com/w6d-io/x/kafkax
- github.com/wangbokun/go/transfer/kafka
- github.com/weberdantas/codebank/infrastructure/kafka
- github.com/wendylau87/warungpintar2021/inventorysvc/infrastructure/kafkahandler
- github.com/wheresalice/kerf/cmd
- github.com/whj1990/go-core/store
- github.com/wilcatarino/labs-go/src/apache-kafka
- github.com/wlcmtunknwndth/messagio_test/backend/internal/broker/kafka
- github.com/woshidama323/LearningGolang/kafka
- github.com/wwfyde/go-examples/kafka
- github.com/wx11055/goms/common/kafka
- github.com/xdire/go-kafka-api/queue
- github.com/xyproto/kafkastatus
- github.com/yahya077/email-microservice/services/eventService
- github.com/ydessouky/kafkaexporter
- github.com/yeshan333/go-kafka-demo
- github.com/ynsgnr/scribo/backend/common/schema/golang/event
- github.com/ynsgnr/scribo/backend/file-converter
- github.com/ynsgnr/scribo/backend/file-converter/internal/service
- github.com/ynsgnr/scribo/backend/gateway
- github.com/ynsgnr/scribo/backend/gateway/internal/commander
- github.com/ynsgnr/scribo/backend/sync-device
- github.com/ynsgnr/scribo/backend/sync-device/internal/service
- github.com/ynsgnr/scribo/backend/sync-kindle
- github.com/ynsgnr/scribo/backend/sync-kindle/internal/service
- github.com/ynsgnr/scribo/backend/sync-mail
- github.com/ynsgnr/scribo/backend/sync-mail/internal/service
- 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/yumyudai/misttools/internal/pubsub
- github.com/yurii-vyrovyi/kafkalib
- github.com/zengyifan/ops/pkg/kafka
- github.com/zhangjianweibj/monasca-transformdata
- github.com/zilliztech/milvus-cdc/core/writer
- github.com/zleague/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
- github.com/zoninnik89/messenger/chat-client/internal/producer
- github.com/zoninnik89/messenger/chat-client/internal/service
- github.com/zoninnik89/messenger/chat-history/consumer
- github.com/zoninnik89/messenger/chat-history/service
- github.com/zoninnik89/messenger/chat-history/types
- github.com/zoninnik89/messenger/pub-sub/internal/app/grpc
- github.com/zoninnik89/messenger/pub-sub/internal/consumer
- github.com/zoninnik89/messenger/pub-sub/internal/service
- github.com/zoninnik89/messenger/pub-sub/internal/types
- github.com/zoninnik89/messenger/pub-sub/tests/suite
- github.com/zoninnik89/messenger/pub-sub/tests/suite/mock-kafka-producer
- github.com/zooptwopointone/gdsb
- 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/pkg/kafka
- gitlab.com/gtsh77-shared/kafka-mq-go/pkg/kafka/mocks
- gitlab.com/gtsh77-shared/kafka-mq-go/queue
- gitlab.com/gtsh77-shared/kafka-mq-go/queue/internal
- gitlab.com/gtsh77-shared/kafka-mq-go/queue/internal/mocks
- gitlab.com/gtsh77-shared/kafka-mq-go/queue/mocks
- gitlab.com/gtsh77-shared/kafka-mq-go/queue/redelivery
- gitlab.com/gtsh77-shared/kafka-mq-go/queue/redelivery/mocks
- gitlab.com/gtsh77-shared/kafka-mq-go/tests
- gitlab.com/jc88/jager/messagebroker/kafkax
- 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.lanhuapp.com/gopkgs/ikafka/confluent
- 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/confluent-kafka-go.v0/examples/admin_create_topic
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/admin_delete_topics
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/admin_describe_config
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/confluent_cloud_example
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/consumer_channel_example
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/consumer_example
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/go-kafkacat
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/producer_channel_example
- gopkg.in/confluentinc/confluent-kafka-go.v0/examples/producer_example
- gopkg.in/confluentinc/confluent-kafka-go.v0/kafkatest/go_verifiable_consumer
- gopkg.in/confluentinc/confluent-kafka-go.v0/kafkatest/go_verifiable_producer
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/admin_create_topic
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/admin_delete_topics
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/admin_describe_config
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/confluent_cloud_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/consumer_channel_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/consumer_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/consumer_offset_metadata
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/cooperative_consumer_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/go-kafkacat
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/idempotent_producer_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/library-version
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/oauthbearer_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/producer_channel_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/producer_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/stats_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/examples/transactions_example
- gopkg.in/confluentinc/confluent-kafka-go.v1/kafka/go_rdkafka_generr
- gopkg.in/confluentinc/confluent-kafka-go.v1/kafkatest/go_verifiable_consumer
- gopkg.in/confluentinc/confluent-kafka-go.v1/kafkatest/go_verifiable_producer
- gopkg.in/confluentinc/confluent-kafka-go.v1/soaktest
- gopkg.in/confluentinc/confluent-kafka-go.v1/soaktest/soakclient
- gopkg.in/confluentinc/confluent-kafka-go.v1/soaktest/soakclient_transaction
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/admin_create_topic
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/admin_delete_topics
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/admin_describe_config
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/confluent_cloud_example
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/consumer_channel_example
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/consumer_example
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/go-kafkacat
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/producer_channel_example
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/producer_example
- gopkg.in/confluentinc/confluent-kafka-go.v100/examples/stats_example
- gopkg.in/confluentinc/confluent-kafka-go.v100/kafkatest/go_verifiable_consumer
- gopkg.in/confluentinc/confluent-kafka-go.v100/kafkatest/go_verifiable_producer
- gopkg.in/flocasts/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/admin_create_topic
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/admin_delete_topics
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/admin_describe_config
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/consumer_channel_example
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/consumer_example
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/consumer_offset_metadata
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/go-kafkacat
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/idempotent_producer_example
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/oauthbearer_example
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/producer_channel_example
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/producer_example
- gopkg.in/wshirey/confluent-kafka-go.v1/examples/stats_example
- gopkg.in/wshirey/confluent-kafka-go.v1/kafkatest/go_verifiable_consumer
- gopkg.in/wshirey/confluent-kafka-go.v1/kafkatest/go_verifiable_producer