pkg.gl

Categorygithub.com/segmentio/kafka-go

modulepackage

0.4.47

Repository: https://github.com/segmentio/kafka-go.git

Documentation: pkg.go.dev

github.com/frain-dev/convoy/internal/pkg/pubsub/kafka

github.com/pingcap/ticdc/pkg/sink/kafka/v2

github.com/pingcap/tiflow/pkg/sink/kafka/v2/mock

github.com/pingcap/tiflow/pkg/sink/kafka/v2

github.com/pingcap/tiflow/pkg/sink/kafka/v2/mock

github.com/seznam/slo-exporter/pkg/kafka_ingester

github.com/ODIN-PROTOCOL/odin-core/hooks/emitter

github.com/pingcap/tiflow/pkg/sink/kafka/v2/mock

github.com/pingcap/tiflow/pkg/sink/kafka/v2

github.com/sabariramc/goserverbase/v6/instrumentation/contrib/otel

github.com/sabariramc/goserverbase/v6/kafka

github.com/sabariramc/goserverbase/v6/app/server/kafkaclient

github.com/sabariramc/goserverbase/v6/instrumentation/contrib/ddtrace

github.com/sabariramc/goserverbase/v5/kafka/api

github.com/sabariramc/goserverbase/v5/kafka

github.com/sabariramc/goserverbase/v5/instrumentation/contrib/ddtrace

github.com/sabariramc/goserverbase/v5/app/server/kafkaconsumer

github.com/sabariramc/goserverbase/v5/instrumentation/contrib/otel

github.com/go-micro/microwire-plugins/broker/segmentio/v5

github.com/sabariramc/goserverbase/v4/kafka/api

github.com/sabariramc/goserverbase/v4/kafka

github.com/sabariramc/goserverbase/v4/app/server/kafkaconsumer

github.com/asim/go-micro/plugins/broker/segmentio/v4

github.com/kentik/ktranslate/pkg/sinks/kafka

github.com/AccelByte/eventstream-go-sdk/v3

github.com/AccelByte/eventstream-go-sdk/v3/pkg/kafkaprometheus

github.com/sabariramc/goserverbase/v3/kafka/api

github.com/sabariramc/goserverbase/v3/kafka

github.com/sabariramc/goserverbase/v3/app/server/kafkaconsumer

github.com/brocaar/chirpstack-application-server/internal/integration/kafka

github.com/shopmonkeyus/eds/internal/drivers/kafka

github.com/desnia/eventstream-go-sdk/v3

github.com/EricWorld/eventstream-go-sdk/v3

github.com/keepchen/go-sail/v3/sail

github.com/keepchen/go-sail/v3/lib/logger

github.com/keepchen/go-sail/v3/lib/kafka

github.com/samwang0723/jarvis/internal/kafka/mocks

github.com/samwang0723/jarvis/internal/kafka

github.com/samwang0723/jarvis/internal/common/remotetest

github.com/openshift/assisted-service/pkg/kafka

github.com/cs3org/reva/v2/pkg/storage/fs/posix/tree

github.com/kedacore/keda/v2/pkg/scalers

github.com/streamdal/plumber/backends/kafka/types

github.com/streamdal/plumber/test-assets/producer

github.com/streamdal/plumber/relay

github.com/streamdal/plumber/backends/kafka

github.com/housepower/clickhouse_sinker/input

github.com/lileio/pubsub/v2/providers/kafka

github.com/wind-c/comqtt/v2/plugin/bridge/kafka

github.com/samber/slog-kafka/v2

github.com/samber/slog-kafka/v2/example

github.com/dimall-id/lumos/v2/event

github.com/alibaba/pairec/v2/datasource/kafka

github.com/Trendyol/kafka-konsumer/v2

github.com/cattlebot/test-mirror/pkg/controllers/user/logging/utils

github.com/kentik/ktranslate/pkg/sinks/kafka

github.com/megaease/easeprobe/probe/client/kafka

github.com/better0332/rancher/pkg/controllers/user/logging/utils

github.com/sunmi-OS/gocore/v2/mq/gokafka

github.com/sunmi-OS/gocore/v2/mq/gokafka.v2

github.com/shopmonkeyus/eds/internal/drivers/kafka

github.com/frain-dev/convoy-go/v2

github.com/frain-dev/convoy-go/v2/example/kafka

github.com/san-services/kafkaclient/v2

github.com/teng231/kafclient/v2

github.com/veritone/go-messaging-lib/kafka

github.com/infraboard/mcube/v2/ioc/config/kafka

github.com/devexps/go-micro/broker/kafka/v2

github.com/unbxd/go-base/v2/transport/kafka

github.com/devexps/go-micro/transport/kafka/v2

github.com/DOs0x12/TeleBot/client/v2/broker/producer

github.com/DOs0x12/TeleBot/client/v2/broker/topic

github.com/DOs0x12/TeleBot/client/v2/broker/consumer

github.com/DOs0x12/TeleBot/server/v2/internal/infrastructure/broker/topic

github.com/DOs0x12/TeleBot/server/v2/internal/infrastructure/broker/consumer

github.com/DOs0x12/TeleBot/server/v2/internal/infrastructure/broker/producer

github.com/fadhillahentino/eventstream-go/v2

github.com/samwang0723/stock-crawler/internal/kafka

github.com/omec-project/smf/metrics

github.com/bosima/ylog

github.com/samwang0723/jarvis/internal/kafka

github.com/bosima/ylog/examples

github.com/EdlanioJ/kbu-store/app/infrastructure/kafka

github.com/okex/exchain/app/logevents

github.com/AccelByte/eventstream-go-sdk/v2

github.com/owncloud/reva/v2/pkg/storage/fs/posix/tree

github.com/okex/exchain/app/rpc/pendingtx

github.com/maxim-panchuk/go-version/kafka

github.com/lf-edge/ekuiper/v2/extensions/impl/kafka

github.com/byt3-m3/goutils/ikafka/publisher

github.com/byt3-m3/goutils/ikafka/consumer

github.com/hahahannes/e2e-go-utils/lib/streaming/kafka

github.com/DataDog/dd-trace-go/instrumentation/internal/namingschematest/v2

github.com/SyaibanAhmadRamadhan/event-bus/kafka

gopkg.in/DataDog/dd-trace-go.v1/contrib/segmentio/kafka.go.v0

github.com/Vonage/gosrvlib/pkg/kafka

github.com/skapfer/dd-trace-go/contrib/segmentio/kafka.go.v0

github.com/nowfred/dd-trace-go/contrib/segmentio/kafka.go.v0

github.com/lannguyen-c0x12c/dd-trace-go/contrib/segmentio/kafka.go.v0

github.com/txix-open/isp-kit/kafkax/publisher

github.com/txix-open/isp-kit/kafkax/consumer

github.com/txix-open/isp-kit/test/kafkat

github.com/txix-open/isp-kit/kafkax

github.com/liquidm/dd-trace-go/contrib/segmentio/kafka.go.v0

github.com/gihyunk/dd-trace-go/contrib/segmentio/kafka.go.v0

github.com/AliceO2Group/Control/core/integration/kafka

github.com/AliceO2Group/Control/common/event

github.com/infinilabs/gateway/proxy/output/kafka/example

github.com/infinilabs/gateway/proxy/output/kafka

github.com/artie-labs/transfer/processes/consumer

github.com/artie-labs/transfer/lib/kafkalib

github.com/artie-labs/transfer/lib/artie

github.com/rafaelsouzaribeiro/producer/pkg/kafka

github.com/rafaelsouzaribeiro/consumer/pkg/kafka

github.com/siklol/zinc/plugins/kafka

github.com/siklol/zinc/plugins/kafkaconfigurator

github.com/segmentio/topicctl/pkg/admin

github.com/segmentio/topicctl/cmd/topicctl/subcmd

github.com/segmentio/topicctl/pkg/create

github.com/segmentio/topicctl/pkg/util

github.com/segmentio/topicctl/pkg/cli

github.com/segmentio/topicctl/pkg/groups

github.com/segmentio/topicctl/pkg/messages

github.com/segmentio/topicctl/pkg/apply

github.com/segmentio/topicctl/pkg/acl

github.com/segmentio/topicctl/pkg/config

github.com/americanas-go/ignite/segmentio/kafka-go.v0

github.com/batchcorp/plumber/backends/kafka

github.com/batchcorp/plumber/backends/kafka/types

github.com/batchcorp/plumber/test-assets/producer

github.com/batchcorp/plumber/relay

github.com/jummyliu/pkg/db/kafkabuilder

github.com/infraboard/mcube/ioc/config/kafka

github.com/gzorm/common/core/go-queue/kq

github.com/housepower/clickhouse_sinker/input

github.com/iddqdeika/kafka-adapter

github.com/integration-system/isp-event-lib/kafka

github.com/megaease/easeprobe/probe/client/kafka

github.com/Trendyol/kafka-konsumer

github.com/bigzhuk/kafka-adapter

github.com/abulo/ratel/kafka

github.com/okex/exchain/app/rpc/pendingtx

github.com/okex/exchain/app/logevents

github.com/soerenschneider/sc-agent/internal/services/components/reboot_manager/checkers

github.com/xh-dev-go/xhUtils/xhKafka/KWildcard

github.com/xh-dev-go/xhUtils/xhKafka/K

github.com/xh-dev-go/xhUtils/xhKafka/KProducer

github.com/xh-dev-go/xhUtils/xhKafka/KHeader

github.com/nkien0204/lets-go/samples/network/kafka/consumer

github.com/nkien0204/lets-go/samples/network/kafka/producer

github.com/delanri/commonutil/messaging/kafka

github.com/omec-project/smf/metrics

github.com/crowdsecurity/crowdsec/pkg/acquisition/modules/kafka

github.com/pushwoosh/infra/kafka

github.com/marmotedu/iam/internal/pump/pumps

github.com/netobserv/flowlogs-pipeline/pkg/pipeline/ingest

github.com/netobserv/flowlogs-pipeline/pkg/test/e2e/kafka

github.com/netobserv/netobserv-ebpf-agent/pkg/exporter

github.com/netobserv/netobserv-ebpf-agent/pkg/agent

github.com/netobserv/flowlogs-pipeline/pkg/pipeline/encode

github.com/byt3-m3/goutils/ikafka/consumer

github.com/byt3-m3/goutils/ikafka/publisher

github.com/rsachdeva/illuminatingdeposits-grpc/interestcal

github.com/linkingthing/clxone-dhcp/pkg/dhcp/services

github.com/soerenschneider/conditional-reboot/internal/checkers

github.com/rsachdeva/illuminatingdeposits-grpc/kafkawriter

github.com/novabankapp/golang.common.infrastructure/kafka

github.com/rsachdeva/illuminatingdeposits-grpc/cmd/server

github.com/sunmi-OS/gocore/gokafka

github.com/fdamador/kapacitor/services/kafka

github.com/Trendyol/kafka-cronsumer/pkg/kafka

github.com/Trendyol/kafka-cronsumer/internal

github.com/94peter/sterna/kafka

github.com/thingio/kapacitor/services/kafka

github.com/xiao4er/kapacitor/services/kafka

github.com/xigang/kapacitor/services/kafka

github.com/rbaderts/kapacitor/services/kafka

github.com/sdomino/kapacitor/services/kafka

github.com/Tuhis/edge-receiver/pkg/kafkawrapper

github.com/omec-project/metricfunc/internal/reader

github.com/aspring/kapacitor/services/kafka

github.com/backend-timedoor/gtimekeeper-framework/base/contracts

github.com/backend-timedoor/gtimekeeper-framework/base/kafka

github.com/heyitsfranky/MyLog

github.com/omec-project/amf/metrics

github.com/loggie-io/loggie/pkg/sink/kafka

github.com/loggie-io/loggie/pkg/source/kafka

github.com/meshplus/gosdk/rpc

github.com/diadata-org/diadata/pkg/dia/helpers/kafkaHelper

github.com/diadata-org/diadata/pkg/dia/scraper/exchange-scrapers

github.com/2276282419/gocore/gokafka

github.com/tsmweb/go-helper-api/kafka

github.com/hieronimusbudi/go-bookstore-utils/events

github.com/ettec/otp-common/ordermanagement

github.com/ettec/otp-common/orderstore

github.com/aaabigfish/gopkg/mq/kafka

github.com/chaos-mesh/chaosd/pkg/server/chaosd

github.com/soerenschneider/hermes/internal/events/kafka

github.com/fcristovao/await

github.com/novabankapp/common.infrastructure/kafka

github.com/ea67/gocore/gokafka

github.com/gowins/dionysus/example/opentelemetry

github.com/gowins/dionysus/example/kafka

github.com/gowins/dionysus/kafka

github.com/lsgndln/dd-trace-go/contrib/segmentio/kafka.go.v0

github.com/rezaAmiri123/edat/kafka

github.com/hahahannes/e2e-go-utils/lib/streaming/kafka

github.com/LeeZXin/zsf/mq/kafkamq

github.com/LeeZXin/zsf/logger

github.com/tx7do/kratos-transport/broker/kafka

github.com/tx7do/kratos-transport/transport/kafka

github.com/kenSevLeb/go-framework/component/kafka

github.com/0xrawsec/golang-evtx/output

github.com/unbxd/go-base/kit/transport/kafka

github.com/core-go/core/health/kafka-go

github.com/bandprotocol/bandchain/chain/emitter

github.com/everFinance/arseeding

github.com/quangtran88/anifni-base/libs/services

github.com/gw123/gutils/kafka

github.com/zutim/ego/component/kafka

github.com/shipperizer/kilo-franz/config

github.com/zeromicro/go-queue/kq

github.com/mactynow/commonutil/messaging/kafka

github.com/shipperizer/kilo-franz/publisher

github.com/zeromicro/go-queue/kq/internal

github.com/shipperizer/kilo-franz/subscriber

github.com/shipperizer/kilo-franz/core

github.com/JailtonJunior94/devkit-go/pkg/messaging/kafka

github.com/ebar-go/ego/component/kafka

github.com/onno-vos-dev/await

github.com/jamieaitken/promred/kafka

github.com/common-go/health/kafka

github.com/core-go/mq/kafka

github.com/litegravity-developer/apm-agent

github.com/rafaelsouzaribeiro/apm-kafkago/pkg

github.com/core-go/health/kafka

github.com/AccelByte/eventstream-go-sdk

github.com/go-micro/plugins/v4/broker/segmentio

github.com/soerenschneider/fetcharr/internal/events/kafka

github.com/Trendyol/go-dcp-kafka/config

github.com/Trendyol/go-dcp-kafka

github.com/Trendyol/go-dcp-kafka/kafka

github.com/Trendyol/go-dcp-kafka/kafka/message

github.com/Trendyol/go-dcp-kafka/kafka/metadata

github.com/Trendyol/go-dcp-kafka/kafka/producer

github.com/relax-space/rtc-api/cmd

github.com/sandwich-go/gnomock/preset/kafka

github.com/gargath/pleiades/pkg/aggregator/kafka

github.com/gargath/pleiades/pkg/ingester/publisher/kafka

github.com/Chronicle20/atlas-kafka/producer

github.com/Chronicle20/atlas-kafka/consumer

github.com/kukkar/common-golang/pkg/factory/kafka

github.com/Chronicle20/atlas-kafka/handler

github.com/safetyculture/kafka_client

github.com/Chronicle20/atlas-kafka/message

github.com/dityuiri/go-adapter/kafka/consumer

github.com/dityuiri/go-adapter/kafka/producer

github.com/kade-chen/library/ioc/config/kafka

github.com/matt-abi/abi-micro/mq

github.com/feynman-go/workshop/message/kafka

github.com/zeromicro/cds/pkg/tube

github.com/shengwenjin/auxiliary/common/kafka

github.com/visforest/windy/kq

github.com/americanas-go/faas/kafka

github.com/blind-oracle/psql-streamer/source/kafka

github.com/sonntuet1997/medical-chain-utils/messaging

github.com/lognitor/entrypoint/internal/transport/kafka

github.com/blind-oracle/psql-streamer/sink/kafka

github.com/jinleibill/message-go/kafka

github.com/Reach-Industries/lumi-audit-reporter

github.com/shengwenjin/auxiliary/kafka

github.com/sodafoundation/controller/pkg/controller/metrics/adapters

github.com/Egor123qwe/logs-storage/internal/broker/kafka/producer

github.com/Egor123qwe/logs-storage/internal/broker/kafka/consumer

github.com/lognitor/entrypoint/internal/worker

github.com/Egor123qwe/logs-storage/internal/broker/kafka

github.com/ManyakRus/starter/kafka_connect

github.com/yhyzgn/goat/kafka

github.com/ability-sh/abi-micro/mq

github.com/hanapedia/hexagon/internal/service-unit/infrastructure/adapters/secondary/producer/kafka

github.com/hanapedia/hexagon/internal/service-unit/infrastructure/telemetry/tracing/kafka

github.com/hanapedia/hexagon/internal/service-unit/infrastructure/adapters/primary/consumer/kafka

github.com/diadata-org/nfttracker/pkg/helper/kafkaHelper

github.com/SENERGY-Platform/device-command/pkg/configuration

github.com/SENERGY-Platform/event-worker/pkg/configuration

github.com/SENERGY-Platform/event-worker/pkg/consumer/cloud

github.com/SENERGY-Platform/event-worker/pkg/tests/docker

github.com/nicexiaonie/gkafka

github.com/nicexiaonie/gkafka/test

github.com/SENERGY-Platform/process-io-worker/pkg/tests/docker

github.com/SENERGY-Platform/process-io-worker/pkg/kafka

github.com/erda-project/erda-infra/providers/kafkav2

github.com/gs-mblock/mbgo/lib/mq/kafka/demo2/consume

github.com/gs-mblock/mbgo/lib/mq/kafka/demo2/consume-mongo

github.com/versity/versitygw/s3event

github.com/gs-mblock/mbgo/lib/mq/kafka/demo2/produce

github.com/alibaba/pairec/datasource

github.com/liushuojia/go-sdk/kafka

github.com/ego-component/ekafka

github.com/ego-component/ekafka/examples/trace

github.com/ego-component/ekafka/examples/consumerservertrace

github.com/ego-component/ekafka/examples/consumerserver

github.com/maxim-panchuk/go-version/kafka

github.com/ego-component/ekafka/examples

github.com/Zeb-D/go-util/mq

github.com/ego-component/ekafka/consumerserver

github.com/dongzhouzhoudz/gotools/pkg

github.com/gditsec/crawlab-go-sdk/database

github.com/simiancreative/simiango/examples/services/kafka/ingest

github.com/simiancreative/simiango/messaging/kafka

github.com/saperliu/common-tool/middleware/kafka_client

github.com/BitofferHub/pkg/middlewares/mq

github.com/notickets/datamining

github.com/ashleighj/kafkaclient

github.com/qosimmax/pubsub/pkg/kafka

github.com/common-go/kafka

github.com/shipa988/banner_rotator/internal/data/controllers/queueservice/kafkaservice

github.com/core-go/kafka

github.com/robertobadjio/tgtime-aggregator/internal/kafka

github.com/2se/dolphin/core/outbox

github.com/quanghung97/kafka-go

github.com/sko00o/kafka/consumer/kafkago

github.com/sko00o/kafka/producer/kafkago

github.com/soedev/soego-component/ekafka/examples/trace

github.com/smallfish-root/eventhorizon/eventbus/kafka

github.com/Aris-haryanto/pubsage/stack/kafka

github.com/ccamel/go-graphql-subscription-example/server

github.com/micro-easy/go-queue/kq

github.com/soedev/soego-component/ekafka/examples

github.com/Aris-haryanto/pubsage/discourse

github.com/soedev/soego-component/ekafka/examples/consumerserver

github.com/Aris-haryanto/pubsage

github.com/go-micro/plugins/v3/broker/segmentio

github.com/yoyo-inc/yoyo/services

github.com/4ND3R50N/testsetup/container

github.com/soedev/soego-component/ekafka

github.com/soedev/soego-component/ekafka/examples/consumerservertrace

github.com/soedev/soego-component/ekafka/consumerserver

github.com/fadhillahentino/eventstream-go

github.com/evoblockchain/evochain/app/logevents

github.com/samber/slog-kafka/example

github.com/c0olix/goChan/kafka/middleware

github.com/heyitsfranky/MyEmail

github.com/comradequinn/klient/kafio

github.com/agitdevcenter/gopkg/transport/example/kafka/service

github.com/shinhagunn/service-deliver/services

github.com/mosajjal/dnsmonster/internal/output

github.com/open-micro/plugins/v5/broker/segmentio

github.com/gekatateam/neptunus/plugins/outputs/kafka

github.com/gekatateam/neptunus/plugins/common/kafka

github.com/cloud01-wu/cgsl/kafkax

github.com/gekatateam/neptunus/plugins/common/metrics

github.com/kentik/ktranslate/pkg/sinks/kafka

github.com/augustus281/trackingcoin/internal/service/notification

github.com/augustus281/trackingcoin/internal/service/trades

github.com/dmachard/go-dnscollector/workers

github.com/samber/slog-kafka

github.com/fourstring/sheetfs/common_journal

github.com/appootb/plugins/queue/backend/kafka

github.com/ihezebin/go-template-ddd/component/pubsub

github.com/jvitoroc/ignite/segmentio/kafka-go.v0

github.com/gunsluo/go-example/kafka

github.com/DOs0x12/TeleBot/client/broker

github.com/RedHatInsights/kafka-zerolog/kafkazerolog

github.com/toventang/debezium-client/internal/consumer

github.com/AchmadRifai/kafka-go-consumer

github.com/konstellation-io/kai-processes/kafka-trigger

github.com/bandprotocol/chain/hooks/emitter

github.com/0angelic0/dd-trace-go/contrib/segmentio/kafka.go.v0

github.com/augustus281/trackingcoin/internal/kafka/producer

github.com/yvvlee/delay-kafka/internal/core

github.com/evoblockchain/evochain/app/rpc/pendingtx

github.com/c0olix/goChan/kafka

github.com/DOs0x12/TeleBot/server/internal/infrastructure/broker

github.com/augustus281/trackingcoin/internal/kafka/consumer

github.com/augustus281/trackingcoin/global

github.com/zhangsq-ax/aws-msk-helper-go

github.com/musobarlab/kafka-cli

github.com/gekatateam/neptunus/plugins/inputs/kafka

github.com/diki-haryadi/govega/event/kafka

github.com/influxdata/flux/stdlib/kafka

github.com/InfluxCommunity/flux/stdlib/kafka

github.com/wolffcm/flux/stdlib/kafka

github.com/AliceO2Group/Control/core/integration/kafka

github.com/viant/endly/service/testing/msg

github.com/dmachard/go-dnscollector/workers

github.com/lerenn/asyncapi-codegen/pkg/extensions/brokers/kafka

github.com/batchcorp/plumber/backends/kafka/types

github.com/rudderlabs/rudder-go-kit/kafkaclient/testutil

github.com/batchcorp/plumber/relay

github.com/batchcorp/plumber/test-assets/producer

github.com/batchcorp/plumber/backends/kafka

github.com/batchcorp/plumber/printer

github.com/rudderlabs/rudder-go-kit/kafkaclient

github.com/bangumi/server/canal

github.com/orlangure/gnomock/preset/kafka

github.com/deepshore/xk6-kafka

github.com/telenornms/skogul/receiver

github.com/telenornms/skogul/sender

github.com/rl404/fairy/pubsub/kafka

github.com/mostafa/xk6-kafka

github.com/obouchet/asyncapi-codegen/pkg/extensions/brokers/kafka

github.com/justtrackio/gosoline/pkg/kafka/consumer/mocks

github.com/justtrackio/gosoline/pkg/stream

github.com/justtrackio/gosoline/pkg/kafka/producer/mocks

github.com/justtrackio/gosoline/pkg/kafka/producer

github.com/justtrackio/gosoline/pkg/kafka/connection

github.com/justtrackio/gosoline/pkg/kafka/consumer

github.com/turfaa/vmedis-proxy-api/drug

github.com/turfaa/vmedis-proxy-api/cmd

github.com/daylikon/xk6-kafka

github.com/Clarilab/eventhorizon/eventbus/kafka

github.com/okex/exchain/app/rpc/pendingtx

github.com/okex/exchain/x/stream/kafkaclient

github.com/94peter/sterna/kafka

github.com/goto/optimus/ext/transport/kafka

github.com/opensibyl/sibyl2/pkg/server/queue

github.com/looplab/eventhorizon/eventbus/kafka

github.com/2908755265/eventhorizon/eventbus/kafka

github.com/arquivei/goduck/impl/implstream/kafkasegmentio

github.com/windvalley/gf2-demo/internal/pkg/kafka

github.com/DoNewsCode/core/otkafka

github.com/bendbennett/go-api-demo/internal/consume

github.com/bendbennett/go-api-demo/internal/metrics

github.com/bendbennett/go-api-demo/internal/config

github.com/aacfactory/fns-contrib/message-queues/kafka

github.com/sodafoundation/controller/pkg/controller/metrics/adapters

github.com/openconfig/gnmi-gateway/gateway/exporters/kafka

github.com/raystack/meteor/plugins/sinks/kafka

github.com/raystack/meteor/plugins/extractors/kafka

github.com/goto/meteor/plugins/extractors/kafka

github.com/goto/meteor/plugins/sinks/kafka

github.com/cgrates/cgrates/engine

github.com/cgrates/cgrates/ers

github.com/stundzia/hermann/kafka

github.com/1pkg/gohalt

github.com/guacsec/guac/pkg/handler/collector/s3/messaging

github.com/ShatteredRealms/go-common-service/pkg/bus

github.com/ShatteredRealms/go-common-service/pkg/repository

github.com/adityaeka26/go-pkg/kafka

github.com/mosajjal/dnsmonster/internal/output

github.com/team-cymru/vflow/producer

github.com/songshubing/vflow/producer

github.com/EdgeCast/vflow/producer

github.com/ThoronicLLC/collector/internal/integrations/kafka

github.com/ThoronicLLC/collector/internal/input/kafka

github.com/goto/stencil/changeEventProducer/kafka

github.com/anexia-it/tyk-pump/pumps

github.com/easonchen147/foundation/kafka

github.com/livepeer/go-livepeer/monitor

github.com/tillkuhn/rubin/cmd/polly

github.com/tillkuhn/rubin/pkg/polly

github.com/philips-software/gautocloud-connectors/hsdp

github.com/milvus-io/milvus-operator/pkg/external

github.com/core-go/core/health/kafka-go

github.com/brave/tokenizer

github.com/ajruckman/vflow/producer

github.com/raystack/optimus/ext/transport/kafka

github.com/RumbiaID/pkg-library/app/pkg/broker/kafkaservice

github.com/deflect-ca/banjax/internal

github.com/navikt/go-leesah

github.com/core-go/mq/kafka

github.com/feelgood-inc/flgd-gommon/adapters

github.com/feelgood-inc/flgd-gommon/utils/kafka

github.com/seymac/xk6-kafka

github.com/Trendyol/kafka-cronsumer/pkg/kafka

github.com/Trendyol/kafka-cronsumer/internal

github.com/crawlab-team/crawlab-core/utils

github.com/crawlab-team/crawlab-core/ds

github.com/yorkie-team/yorkie/server/backend/messagebroker

github.com/nwpc-oper/nwpc-message-client/common/sender

github.com/nwpc-oper/nwpc-message-client/common/consumer

github.com/bangunindo/trap2json/forwarder

github.com/0xcregis/easynode/taskapi/service

github.com/0xcregis/easynode/store/service

github.com/0xcregis/easynode/collect

github.com/0xcregis/easynode/task

github.com/0xcregis/easynode/blockchain/service

github.com/0xcregis/easynode/common/kafka

github.com/0xcregis/easynode/store/chain

github.com/0xcregis/easynode/collect/service/cmd

github.com/0xcregis/easynode/collect/service/db

github.com/0xcregis/easynode/collect/service/monitor

github.com/0xcregis/easynode/task/service/taskcreate

github.com/0xcregis/easynode/task/service/taskcreate/db

github.com/core-go/health/kafka

github.com/common-go/health/kafka

github.com/pecigonzalo/terraform-provider-kafka/internal/provider

github.com/kishaningithub/kafka-console-avro-without-schema-registry

github.com/chenquan/go-queue/kafka

github.com/GeoDB-Limited/odin-core/hooks/emitter

github.com/feynman-go/workshop/message/kafka

github.com/tarent/kafkaadmin

github.com/kazhuravlev/kafka/producer

github.com/kazhuravlev/kafka/consumer

github.com/kazhuravlev/kafka/admin

github.com/segmentio/kafka-go/topics

github.com/azarakovskiy/kafka-go/topics

github.com/liftoffio/skafka/topics

github.com/djkazic/kafka-go/topics

github.com/microdevs/missy/messaging

github.com/ShatteredRealms/chat-service/pkg/service

github.com/ShatteredRealms/chat-service/pkg/model/chat

github.com/bugrakocabay/konsume/pkg/queue/kafka

github.com/bugrakocabay/konsume/test/e2e

github.com/nlnwa/gowarcserver/index

github.com/souz9/kafka-topic

github.com/goal-web/queue/drivers

github.com/zmon-deploy/zmon-common-go/pubsub

github.com/andrewwormald/workflow/adapters/kafkastreamer

github.com/HXSecurity/DongTai-agent-go/core/kafkaGo/kafkaWriter

github.com/gotomicro/ego-component/ekafka/examples

github.com/qvantel/nerd/cmd/nerd

github.com/viru-tech/clickhouse_sinker/input

github.com/gotomicro/ego-component/ekafka/consumerserver

github.com/qvantel/nerd/internal/series

github.com/gotomicro/ego-component/ekafka

github.com/qvantel/nerd/pkg/producer

github.com/gotomicro/ego-component/ekafka/examples/trace

github.com/gotomicro/ego-component/ekafka/examples/consumerservertrace

github.com/gotomicro/ego-component/ekafka/examples/consumerserver

github.com/iacuity/datastore-connector/kafka

github.com/mwsbkru/broker-bridge/internal/kafka

github.com/simiancreative/simiango/messaging/kafka

github.com/simiancreative/simiango/examples/services/kafka/ingest

github.com/moleculer-go/moleculer/transit/kafka

github.com/wekb/kafka-go/gzip

github.com/wekb/kafka-go/lz4

github.com/netobserv/netobserv-ebpf-agent/pkg/exporter

github.com/databendcloud/bend-ingest-kafka

github.com/netobserv/netobserv-ebpf-agent/pkg/agent

github.com/shrimpsizemoose/trekker/infra

github.com/celerway/metamorphosis/bridge/kafka

github.com/sko00o/kafka/example-kafka-go/consumer

github.com/sko00o/kafka/example-kafka-go/test-latency

github.com/sko00o/kafka/example-kafka-go/producer

github.com/c0olix/goChan/kafka/middleware

github.com/c0olix/goChan/kafka

github.com/gekatateam/neptunus/plugins/outputs/kafka

github.com/gekatateam/neptunus/plugins/common/kafka

github.com/gekatateam/neptunus/plugins/inputs/kafka

github.com/kubediag/kubediag/pkg/kafka

github.com/kubediag/kubediag/pkg/pagerdutyeventer

github.com/kevinyjn/gocom/mq/kafka

github.com/gekatateam/neptunus/plugins/common/metrics

github.com/GRMrGecko/freeipa-health-metrics

github.com/katallaxie/streams/kafka/sink

github.com/katallaxie/streams/examples/worker

github.com/katallaxie/streams/kafka/source

github.com/katallaxie/streams/examples/producer

github.com/katallaxie/streams/kafka/writer

github.com/sellsuki/kafka-go-worker/handler

github.com/sellsuki/kafka-go-worker/kafka_consumer

github.com/sellsuki/kafka-go-worker

github.com/katallaxie/streams/kafka/table

github.com/katallaxie/streams/kafka/utils

go.ntppool.org/common/kafka

github.com/katallaxie/streams/kafka/reader/mock

github.com/xataio/pgstream/pkg/kafka

github.com/katallaxie/streams/examples/simple

github.com/katallaxie/streams/kafka/reader

github.com/katallaxie/streams/kafka/writer/mocks

github.com/gingfrederik/eventhorizon/eventbus/kafka

github.com/jlu-cow-studio/common/dal/mq

github.com/webediads/adsgolib/wconnectors

github.com/mapgoo-lab/atreus/pkg/log

github.com/SENERGY-Platform/device-repository/lib/controller/publisher

github.com/SENERGY-Platform/device-repository/lib/tests/docker

github.com/ionos-cloud/streams/kafka/reader/mock

github.com/ionos-cloud/streams/kafka/writer/mocks

github.com/ionos-cloud/streams/kafka/table

github.com/ionos-cloud/streams/kafka/sink

github.com/ionos-cloud/streams/kafka/utils

github.com/ionos-cloud/streams/examples/worker

github.com/ionos-cloud/streams/examples/producer

github.com/ionos-cloud/streams/kafka/source

github.com/ionos-cloud/streams/kafka/reader

github.com/ionos-cloud/streams/examples/simple

github.com/ionos-cloud/streams/kafka/writer

github.com/core-go/kafka

github.com/owlify/sparrow/consumer

github.com/common-go/kafka

github.com/owlify/sparrow/producer

github.com/oddbit-project/blueprint/provider/kafka

github.com/DoNewsCode/core-processor

github.com/danielunderwood/feed-ingress

github.com/Leila-Codes/events-io/source

github.com/Leila-Codes/events-io/sink

github.com/nlnwa/hermetic/cmd/verify/reject

github.com/nlnwa/hermetic/cmd/verify/confirm

github.com/fvosberg/kafka-go/lz4

github.com/fvosberg/kafka-go/gzip

github.com/danmaxdanilov/zts.shared/pkg/kafka

github.com/DoNewsCode/core-kit/kitkafka

github.com/nlnwa/hermetic/cmd/acquisition

github.com/nlnwa/hermetic/cmd/send

github.com/nlnwa/hermetic/internal/dps

github.com/fvosberg/kafka-go/snappy

github.com/danmaxdanilov/zts.shared/pkg/messaging

github.com/danmaxdanilov/zts.shared/pkg/tracing

github.com/DoodleScheduling/k8skafka-controller/kafka

github.com/samber/slog-kafka/example

github.com/firejh/kafka-go/gzip

github.com/plexifyTech/kaplex

github.com/joelsonrocha/pkg

github.com/superproj/onex/internal/pump

github.com/superproj/onex/internal/usercenter/auth

github.com/xiaocok/go-tools/pkg/kafka

github.com/handofgod94/kafkatail/kafkatest

github.com/handofgod94/kafkatail/consumer

github.com/jefflinse/eh-kafka-eventbus/eventbus/kafka

github.com/hyperyuri/logg/writer

github.com/samber/slog-kafka

github.com/firejh/kafka-go/lz4

github.com/firejh/kafka-go/snappy

github.com/onexstack/onex/internal/usercenter/pkg/auth

github.com/superproj/onex/pkg/streams/connector/kafka

github.com/onexstack/onex/internal/pump

github.com/dev-mockingbird/events

github.com/onexstack/onex/pkg/streams/connector/kafka

github.com/superproj/onex/pkg/options

github.com/xhyonline/xutil/kmq

github.com/artie-labs/reader/lib/kafkalib

github.com/toniz/gosuit/queue/kafka

github.com/kneu-messenger-pigeon/client-framework

github.com/ignalina/thund/bundledImpl

github.com/kneu-messenger-pigeon/events

github.com/kneu-messenger-pigeon/events/mocks

github.com/doubunv/common-pkg/amqp/kafka/config

github.com/doubunv/common-pkg/amqp/kafka/v1

github.com/netobserv/flowlogs-pipeline/pkg/test/e2e/kafka

github.com/netobserv/flowlogs-pipeline/pkg/pipeline/encode

github.com/netobserv/flowlogs-pipeline/pkg/pipeline/ingest

github.com/0xanonymeow/kafka-go/message

github.com/0xanonymeow/kafka-go

github.com/108356037/common-lib/mq

github.com/0xanonymeow/kafka-go/testings/mock_kafka

github.com/0xanonymeow/kafka-go/kafka

github.com/0xanonymeow/kafka-go/client

github.com/sonntuet1997/medical-chain-utils/messaging

github.com/libsv/go-bdd-common/godog

github.com/okx/okbchain/app/logevents

github.com/okx/okbchain/app/rpc/pendingtx

github.com/DmitriiDobr/kafkaNotification/pkg

github.com/squareup/pranadb/msggen

github.com/squareup/pranadb/kafkatest

github.com/RedHatInsights/haberdasher/emitters

github.com/Trendyol/chaki/modules/otel/kafka

github.com/Trendyol/chaki/modules/kafka/consumer

github.com/NickTaporuk/gigamock/src/scenarioType

github.com/zusux/gokit/kafka

github.com/gagangoku/kafka-tasker

github.com/kl7sn/toolkit/kkafka

github.com/tal-tech/cds/pkg/tube

github.com/Reach-Industries/lumi-error-reporter

github.com/akto-api-security/gomiddleware

github.com/rumis/storage/skafka

github.com/DMwangnima/micro-plugin/writer

github.com/DMwangnima/micro-plugin/micro_logger

github.com/falcosecurity/plugins/plugins/kafka/pkg/kafka

github.com/freetsdb/freetsdb/services/flux/functions/outputs

github.com/kentik/ktranslate/pkg/sinks/kafka

github.com/3dsinteractive/kafka-go/lz4

github.com/cashwagon/qrpc/examples/client

github.com/balabanovds/containers/kafka

github.com/rohilsurana/kafka-offset/kafka

github.com/cashwagon/qrpc/pkg/drivers/kafka

github.com/cashwagon/qrpc/examples/server

github.com/3dsinteractive/kafka-go/gzip

github.com/3dsinteractive/kafka-go/snappy

github.com/anooshcnayak/butterfly-go

github.com/brc20-collab/brczero/app/logevents

github.com/brc20-collab/brczero/app/rpc/pendingtx

github.com/yahoo/panoptes-stream/producer/mqueue/kafka

github.com/hrojas2021/go-kafka-mongodb/pkg/kafka/segmentio

github.com/skeleton1231/go-iam-ecommerce-microservice/internal/pump/pumps

github.com/worldbug/kafeman/internal/admin

github.com/worldbug/kafeman/internal/kafeman

github.com/chrusty/kafka-cli/internal/cli

github.com/chrusty/kafka-cli/internal/configuration

github.com/Reach-Industries/lumi-audit-reporter

github.com/ShatteredRealms/go-backend/pkg/service

github.com/ShatteredRealms/go-backend/pkg/repository

github.com/jvitoroc/ignite/segmentio/kafka-go.v0

github.com/raczu/kube2kafka/internal/config

github.com/i-sevostyanov/k8s-playground/internal/infrastructure/kafka

github.com/kngu9/kafka-go/gzip

github.com/raczu/kube2kafka/pkg/exporter

github.com/dzonint/go-notify/kafka

github.com/raczu/kube2kafka/pkg/processor

github.com/kngu9/kafka-go/lz4

github.com/chrismoos/caddy-events-kafka

github.com/wosai/havok/dispatcher

github.com/kngu9/kafka-go/snappy

github.com/dimmyjr/goku/internal/consumer

github.com/dimmyjr/goku/internal/producer

github.com/kneu-messenger-pigeon/authorizer

github.com/go-bamboo/pkg/queue/kafka

github.com/go-bamboo/pkg/middleware/tracing

github.com/kaydxh/golang/pkg/mq/kafka

github.com/gfa-inc/gfa/common/mq/kafkax

github.com/Trendyol/go-dcp-kafka/kafka

github.com/Trendyol/go-dcp-kafka

github.com/Trendyol/go-dcp-kafka/kafka/producer

github.com/Trendyol/go-dcp-kafka/kafka/message

github.com/Trendyol/go-dcp-kafka/kafka/metadata

github.com/robertlestak/procx/drivers/kafka

github.com/adimax2953/go-tool/kafkatool

github.com/SENERGY-Platform/device-manager/lib/kafka/util

github.com/SENERGY-Platform/device-manager/lib/kafka/publisher

github.com/SENERGY-Platform/device-manager/lib/tests/docker

github.com/SENERGY-Platform/device-manager/lib/kafka/listener

github.com/SENERGY-Platform/senergy-platform-connector/test/server/docker

github.com/SENERGY-Platform/senergy-platform-connector/lib/configuration

github.com/SENERGY-Platform/external-task-worker/util

github.com/SENERGY-Platform/external-task-worker/lib/com/kafka

github.com/SENERGY-Platform/external-task-worker/lib/test/docker

github.com/SENERGY-Platform/mqtt-platform-connector/lib/configuration

github.com/SENERGY-Platform/event-deployment/lib/kafka

github.com/brilliant-monkey/go-kafka-client

github.com/SENERGY-Platform/mqtt-platform-connector/test/server/docker

github.com/SENERGY-Platform/event-deployment/lib/tests/docker

github.com/SENERGY-Platform/event-deployment/lib/kafka/topicconfig

github.com/SENERGY-Platform/event-deployment/lib/tests/util

github.com/SENERGY-Platform/permissions-v2/pkg/controller/kafka

github.com/SENERGY-Platform/permissions-v2/pkg/tests/docker

github.com/tillkuhn/letitgo/stream

github.com/batchcorp/kng

github.com/relax-space/rtc-api/cmd

github.com/SENERGY-Platform/permission-search/lib/worker/kafka

github.com/SENERGY-Platform/permission-search/lib/tests/docker

github.com/SENERGY-Platform/permission-search/lib/worker/kafka/topicconfig

github.com/garden-raccoon/notify-pkg

github.com/SENERGY-Platform/connection-check-v2/pkg/connectionlog

github.com/SENERGY-Platform/connection-check-v2/pkg/tests/docker

github.com/gzorm/commons/core/go-queue/kq

github.com/wentaojin/dbms/database/taskflow

github.com/wentaojin/dbms/database/msgsrv

github.com/wentaojin/dbms/message/tidb

github.com/hahahannes/e2e-go-utils/lib/streaming/kafka

github.com/SENERGY-Platform/analytics-serving/internal/ew-api

github.com/SENERGY-Platform/process-deployment/lib/tests/docker

github.com/SENERGY-Platform/process-deployment/lib/kafka

github.com/SENERGY-Platform/analytics-serving/internal/api

github.com/d1rtyloudx/spotiby-pkg/kafka

github.com/diazoxide/easy-kafka

github.com/diki-haryadi/ztools/kafka/consumer

github.com/diki-haryadi/ztools/kafka/producer

github.com/diki-haryadi/ztools/infra_container

github.com/SENERGY-Platform/api-aggregator/pkg/tests/environment

github.com/SENERGY-Platform/device-selection/pkg/controller/cacheinvalidator/kafka

github.com/SENERGY-Platform/device-selection/pkg/tests/environment/kafka

github.com/SENERGY-Platform/process-fog-deployment/pkg/tests/docker

github.com/SENERGY-Platform/moses/lib/config

github.com/SENERGY-Platform/process-model-repository/lib/source/consumer

github.com/SENERGY-Platform/smart-service-module-worker-device-repository/pkg/kafka

github.com/SENERGY-Platform/process-model-repository/lib/source/util

github.com/SENERGY-Platform/smart-service-module-worker-process/pkg/kafka

github.com/SENERGY-Platform/live-data-worker/pkg/kafka

github.com/Kevinello/kafka-client

github.com/SENERGY-Platform/process-sync/pkg/kafka

github.com/jlu-cow-studio/product-core/biz

github.com/eden-framework/plugin-kafka/kafka

github.com/SENERGY-Platform/user-management/pkg/kafka

github.com/severuykhin/kafkaproxy

github.com/SENERGY-Platform/user-management/pkg/tests/docker

github.com/Trendyol/kafka-konsumer

github.com/Trendyol/otel-kafka-konsumer/example/consumer-with-autocommit

github.com/Trendyol/otel-kafka-konsumer

github.com/neazossa/common-util-go/queue/queue

github.com/Trendyol/otel-kafka-konsumer/example/producer

github.com/Trendyol/otel-kafka-konsumer/example/consumer-with-manualcommit

github.com/neazossa/common-util-go/queue/implementations/kafkago

github.com/unbxd/go-base/kit/transport/kafka

github.com/zzsds/go-tools/event/kafka

github.com/asemyannikov-vi/vp-nano-lib/models/observers/kafka

github.com/SENERGY-Platform/camunda-engine-wrapper/lib/tests/docker

github.com/hello-pionex/mystic-go/kafkautils/topicwriter

github.com/crawlab-team/crawlab-go-sdk/database

github.com/Trendyol/go-pq-cdc-kafka/kafka/producer

github.com/Trendyol/go-pq-cdc-kafka/kafka

github.com/Trendyol/go-pq-cdc-kafka/config

github.com/Trendyol/go-pq-cdc-kafka

github.com/SENERGY-Platform/camunda-engine-wrapper/lib/events/kafka/topicconfig

github.com/SENERGY-Platform/camunda-engine-wrapper/lib/events/kafka

github.com/hello-pionex/mystic-go/kafkautils

github.com/nstankov-bg/oaievals-collector/pkg/kafka

github.com/RapidCodeLab/ZapLogger

github.com/SENERGY-Platform/process-incident-worker/lib/configuration

github.com/maxim-panchuk/asyncapi-codegen/pkg/extensions/brokers/kafka

github.com/agclqq/prow-framework/queue

github.com/SENERGY-Platform/process-incident-worker/tests/docker

github.com/mohamadkhani/sample-go/messageBroker

github.com/SENERGY-Platform/connection-log-worker/lib/source/util

github.com/SENERGY-Platform/connection-log-worker/lib/source/consumer

github.com/SENERGY-Platform/connection-log-worker/test/helper

github.com/SENERGY-Platform/connection-log-worker/test/server

github.com/SENERGY-Platform/process-incident-worker/lib/source/util

github.com/SENERGY-Platform/process-incident-worker/lib/source/consumer

github.com/atulanand206/go-kafka

github.com/segmentio/topicctl/pkg/groups

github.com/peter-stratton/gofr/pkg/gofr/datasource/pubsub/kafka

github.com/segmentio/topicctl/pkg/admin

github.com/segmentio/topicctl/pkg/util

github.com/segmentio/topicctl/pkg/messages

github.com/segmentio/topicctl/pkg/config

github.com/segmentio/topicctl/pkg/apply

github.com/pyama86/isaka/isaka

github.com/segmentio/topicctl/cmd/topicctl/subcmd

github.com/segmentio/topicctl/pkg/cli

github.com/meow-pad/joytalk-helpers/notice/producer

github.com/s21platform/kafka-lib

github.com/arhamj/go-commons/pkg/tracing

github.com/arhamj/go-commons/pkg/kafka

github.com/meow-pad/joytalk-helpers/notice/consumer

github.com/pecolynx/bamboo

github.com/SENERGY-Platform/permission-command/lib

github.com/pecolynx/bamboo/helper

github.com/SENERGY-Platform/service-topic-worker/pkg

github.com/SENERGY-Platform/service-topic-worker/pkg/configuration

github.com/omec-project/metricfunc/pkg/producer

github.com/segmentio/data-digger/cmd/digger/subcmd

github.com/segmentio/data-digger/pkg/digger

github.com/segmentio/data-digger/pkg/stats

github.com/stormsync/collector

github.com/xiongdi9456/go-queue/kq

github.com/iftechio/go-coco/infra

github.com/lhdhtrc/kafka-go/pkg

github.com/sansmoraxz/any-scrape-go/queue

github.com/jkkkls/logtail

github.com/lidaboo/go-queue/kq

github.com/sbezverk/gobmp/pkg/topology/kafkamessenger

github.com/egustafson/sandbox/go/kafka-segmentio-01

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/volume/messagequeue

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/volume/messagequeue/publish

github.com/robertobadjio/tgtime-aggregator/internal/kafka

github.com/alexandria-oss/streams/driver/kafka

github.com/kamicuu/chirpstack-application-server/internal/integration/kafka

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue

github.com/Shoothzj/cli/pkg

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/subscribe/testing

github.com/ihatiko/kafka-client

github.com/redhatinsights/platform-go-shared/queue

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/subscribe

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/volume/messagequeue/subscribe

github.com/DOs0x12/TeleBot/client/broker

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/publish/testing

github.com/stormsync/transformer

github.com/FujitsuResearch/data-sharing-controllers-on-k8s/pkg/messagequeue/publish

github.com/RedHatInsights/platform-receptor-controller/internal/controller

github.com/RedHatInsights/platform-receptor-controller/internal/platform/queue

github.com/RedHatInsights/platform-receptor-controller/internal/controller/api

github.com/dotunj/pvent/producer

github.com/sbezverk/gobmp/pkg/kafka

github.com/lapitskyss/chat-service/internal/services/afc-verdicts-processor

github.com/Harry-027/go-notify/kafka-consumer

github.com/Harry-027/go-notify/api-server/utils

github.com/Harry-027/go-notify/api-server/handler

github.com/Harry-027/go-notify/cron/cron_jobs

github.com/biangacila/luvungula-go/microservice

github.com/Skyrin/go-lib/kafka

github.com/Skyrin/go-lib/kafka/aws/ec2/example

github.com/btccom/btcpool-go-modules/chainSwitcher

github.com/p2p-org/mbelt-filecoin-streamer/datastore

github.com/p2p-org/mbelt-filecoin-streamer/msg_gen

github.com/go-kratos/examples/event/kafka

github.com/cntechpower/utils/log

github.com/fizzse/gobase/pkg/mq/kafka

github.com/mateuszmidor/gostudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/hw

github.com/mateuszmidor/gostudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/tuner

github.com/mateuszmidor/gostudy/src/github.com/mateuszmidor/GoStudy/sdars/kafka_microservices_demo/ui

github.com/WelcomerTeam/Sandwich/messaging

github.com/indrasaputra/toggle/internal/messaging

github.com/indrasaputra/toggle/internal/builder

github.com/indrasaputra/toggle/test/mock/messaging

github.com/brave-intl/challenge-bypass-server/kafka

github.com/openshift-telco/netconf-operator/controllers

github.com/redhatinsights/sources-superkey-worker/util

github.com/morzhanov/go-mq-examples/internal/kafka

github.com/morzhanov/go-mq-examples/internal/kafka/kafka_test

github.com/SENERGY-Platform/service-commons/pkg/kafka

github.com/SENERGY-Platform/service-commons/pkg/testing/docker

github.com/equalitie/banjax-next/internal

github.com/WelcomerTeam/Sandwich-Daemon/messaging

github.com/sunshibao/go-utils/queue/goqueue/kq

github.com/city-mobil/gobuns/kafka

github.com/city-mobil/gobuns/kafka/examples/async_producer

github.com/city-mobil/gobuns/kafka/examples/sync_producer

github.com/dell/iDRAC-Telemetry-Reference-Tools/internal/messagebus/kafka

github.com/lidofinance/dc4bc/storage/kafka_storage

github.com/onosproject/analytics/internal/kafkaConnector

github.com/banzaicloud/allspark/internal/kafka

github.com/banzaicloud/allspark/internal/kafka/server

github.com/romaxa83/mst-app/pkg/kafka

github.com/romaxa83/mst-app/pkg/tracing

github.com/romaxa83/mst-app/reader_service/internal/server

github.com/romaxa83/mst-app/writer_service/internal/server

github.com/romaxa83/mst-app/gateway/internal/author/commands

github.com/romaxa83/mst-app/gateway/internal/products/commands

github.com/romaxa83/mst-app/writer_service/internal/product/commands

github.com/romaxa83/mst-app/reader_service/internal/product/delivery/kafka

github.com/romaxa83/mst-app/writer_service/internal/product/delivery/kafka

github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/multikcat/segmentio/consumer

github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/multikcat/segmentio/producer

github.com/rostislaved/go-clean-architecture/internal/app/adapters/secondary/kafka-adapter-publisher

github.com/rostislaved/go-clean-architecture/internal/app/adapters/primary/kafka-adapter-subscriber/kafka-queue

github.com/sergiusd/redbus/internal/pkg/app

github.com/sergiusd/redbus/internal/pkg/kafka/consumer

github.com/sergiusd/redbus/internal/pkg/kafka/producer

github.com/FiboChain/fbc/app/logevents

github.com/FiboChain/fbc/app/rpc/pendingtx

github.com/daddydemir/crypto/config/broker

github.com/daddydemir/crypto/pkg/broker/kafka

github.com/cemayan/earthquake_collector_mini/pkg/kafka

github.com/cemayan/earthquake_collector_mini/internal/service

github.com/minicloudsky/golang-in-action/kafka-demo

github.com/packtpublishing/mastering-go-second-edition/ch14

github.com/RedHatInsights/sources-api-go/kafka

github.com/ggxxll/core-processor-demo/handler

github.com/ws6/klib

github.com/PrayagS/kv-store/pkg/kafka

github.com/PrayagS/kv-store/web/handlers

github.com/ddvkid/learngo/internal/kafkaBuilder

github.com/beihai0xff/pudding/pkg/mq/kafka

github.com/jeffotoni/gokafka.poc/pkg/kafka

github.com/jeffotoni/gokafka.poc/service/check

github.com/jeffotoni/gokafka.poc/controller/handler/topic

github.com/nioliu/commons/log

github.com/AJackTi/go-kafka/internal/app

github.com/AJackTi/go-kafka/internal/subscription

github.com/AJackTi/go-kafka/pkg/es

github.com/AJackTi/go-kafka/pkg/kafka

github.com/Alibay/go-kit/kafka

github.com/ericyeungcode/caliber

github.com/lsamu/ago/store/kafka

github.com/ngoralski/snmptrap2mb/enricher

github.com/ngoralski/snmptrap2mb/snmpdCollector

github.com/kloudfuse/kafka-go/topics

github.com/bervProject/go-microservice-boilerplate/services

github.com/vilamslep/bx24sync

github.com/getsentry/vroom/cmd/vroom

github.com/getsentry/vroom/internal/occurrence

github.com/losfair/caddy-log-kafka

github.com/dairongpeng/leona/internal/gstash/gstashs

github.com/underbek/examples-go/testcontainers

github.com/exfury/grbchain/app/logevents

github.com/exfury/grbchain/app/rpc/pendingtx

github.com/onecombine/onecombine-msg-validator/src/utils

github.com/maskarb/sources-integration-go/listener

github.com/emortalmc/kurushimi/internal/kafka

github.com/jackycsl/catalog/pkg/event/kafka

github.com/dimpogissou/isengard-server/connectors

github.com/halokid/NeonRabbit/tests/kafka

github.com/halokid/NeonRabbit/tests/kafka/consumer

github.com/halokid/NeonRabbit/tests/kafka/producer

github.com/estebmaister/go_practice/queues

github.com/giovani-sirbu/mercury/messagebroker

github.com/thk-im/thk-im-base-server/mq

github.com/telkomdev/tob/services/kafka

github.com/lixianmin/shoulder/kafkax

github.com/lixianmin/shoulder/kafkax/internal

github.com/EvWilson/sqump/exec

github.com/festum/gopkg/kafka

github.com/tx7do/go-kafka-example/segmentio

github.com/arthurshafikov/banner-rotation/pkg/queue/mocks

github.com/smallnest/gofer/mq/mka

github.com/trakkie-id/secondbaser/sdk

github.com/trakkie-id/secondbaser/service

github.com/xrpscan/platform/connections

github.com/xrpscan/platform/indexer

github.com/qida/gohp/mqtt

github.com/mutezebra/tiktok/pkg/kafka

github.com/Jimmyweng006/Jimmy-Chat/server

github.com/Jimmyweng006/Jimmy-Chat/server/messageQueue

github.com/stellar/stellar-disbursement-platform-backend/internal/events

github.com/RedHatInsights/cloud-connector/internal/controller

github.com/RedHatInsights/cloud-connector/internal/mqtt

github.com/RedHatInsights/cloud-connector/internal/platform/queue

github.com/aarthikrao/timeMachine/utils/kafkaclient

github.com/nais/dataproduct-topics/pkg/collector

github.com/guatom999/TicketShop-Movie/server

github.com/guatom999/TicketShop-Movie/pkg/queue

github.com/kujilabo/bamboo-root

github.com/kujilabo/bamboo-root/helper

github.com/RedHatInsights/chrome-service-backend/cmd/kafka

github.com/tayron/golang-estudos/apache-kafka

github.com/fenglvWind/kafka-demo/consumer

github.com/fenglvWind/kafka-demo/producer

github.com/achillescres/pkg/kafka

github.com/achillescres/pkg/kafkapubsub

github.com/annchain/BlockDB/plugins/server/kafka

github.com/foundation-go/foundation/kafka

github.com/liguoqinjim/go-labs/lab179/lab001/consumer

github.com/liguoqinjim/go-labs/lab179/lab001/producer

github.com/liguoqinjim/go-labs/lab179/lab002/consumer

github.com/liguoqinjim/go-labs/lab179/lab002/producer

github.com/meidada2464/gostudy/KafkaTest

github.com/KyKyPy3/clean/internal/infrastructure

github.com/KyKyPy3/clean/internal/infrastructure/queue

github.com/KyKyPy3/clean/internal/modules/registration/infrastructure/gateway/queue

github.com/KyKyPy3/clean/internal/modules/registration/infrastructure/controller/queue/v1

github.com/fingertge/public/service/kafka

github.com/abmpio/kafka

github.com/abmpio/kafka/queue

github.com/tanqiuqiang/go-queue/kq

github.com/PranitRout07/Practice-Golang/kafka-client/consumer

github.com/PranitRout07/Practice-Golang/kafka-client/producer

github.com/wslynn/wechat-gozero/common/xmq

github.com/wslynn/wechat-gozero/app/group/rpc/internal/svc

github.com/wslynn/wechat-gozero/app/msg/api/internal/logic

github.com/wslynn/wechat-gozero/app/msg/rpc/internal/svc

github.com/greenac/chaching/internal/service/chaching_kafka

github.com/cvcio/mediawatch/pkg/kafka

github.com/cvcio/mediawatch/cmd/compare

github.com/cvcio/mediawatch/cmd/feeds

github.com/cvcio/mediawatch/cmd/listen

github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/infrastructure

github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/api

github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/http_handlers

github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/kafka_handlers

github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/nats_handlers

github.com/Verce11o/resume-view/shared/kafka

github.com/Verce11o/resume-view/resume-view/internal/app

github.com/Verce11o/resume-view/employee-service/internal/repository/kafka

github.com/spirit-labs/tektite/kafka

github.com/vert-capital/vertc-go-admin/admin

github.com/Niyko/Athena

github.com/mauricioromagnollo/kafrest/external/controllers

github.com/khulnasoft-lab/PacketStreamer/pkg/plugins/kafka

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/cdc

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/queue_coherence/before/errors

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/etl/before/services/consumer

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/etl/before/services/etl

github.com/cockroachdb/architectural-simplification/002_hyper_specialized_dbs/data_fragmentation/before/services/indexer

github.com/ekhvalov/bank-chat-service/internal/logger

github.com/ekhvalov/bank-chat-service/internal/services/msg-producer

github.com/ekhvalov/bank-chat-service/internal/services/afc-verdicts-processor

github.com/chnmk/vue-go-playground/main/transport/kafka

github.com/moyu-x/level-5/pkg/kafka

github.com/moyu-x/level-5/internal/command/kafka/producer

github.com/xpoh/otus-work/pkg/api

github.com/2pgcn/gameim/pkg/event

github.com/alexsuriano/kafkaGoStudy

github.com/AlpacaLabs/go-kafka

github.com/Aorjoa/citizen-persist/mq

github.com/Aorjoa/citizen-persist/cmd/api

github.com/Aorjoa/citizen-persist/cmd/consumer

github.com/AyanChoudhary/transponster/pkg/kafka

github.com/Alieksieiev0/feed-service/internal/transport/kafka

github.com/AlecSmith96/faceit-user-service/internal/adapters

github.com/AlecSmith96/faceit-user-service/mocks/adapters

github.com/Falokut/profiles_service/internal/events

github.com/Falokut/admin_casts_service/internal/events

github.com/Falokut/admin_movies_service/internal/events

github.com/byt3-m3/GoPractice/kafka/consumer

github.com/byt3-m3/GoPractice/mw_alerting_system/kafka

github.com/byt3-m3/GoPractice/mw_alerting_system/app

github.com/byt3-m3/GoPractice/kafka/cmd/basic_app

github.com/buraktabakoglu/TODO_APP_NOTIFICATION/internal/kafka

github.com/JitenPalaparthi/mb-go-client/impl/kafka

github.com/Falokut/accounts_service/internal/events

github.com/Falokut/cinema_orders_service/internal/events

github.com/DeeChau/kafka.go-generic/internal/consumer

github.com/DeeChau/kafka.go-generic/internal/producer

github.com/DeeChau/kafka.go-generic/internal/demo

github.com/DeeChau/kafka.go-generic/kafka/consumers

github.com/DeeChau/kafka.go-generic/kafka/producers

github.com/hamidOyeyiola/kafka-mail-service/service

github.com/BenjaminGlusa/goktm/pkg/model

github.com/BenjaminGlusa/goktm/pkg/sink

github.com/BenjaminGlusa/goktm/pkg/source

github.com/Kbusch54/notification-service/stream/kafka

github.com/JECSand/identity-service/pkg/kafka

github.com/JECSand/identity-service/pkg/tracing

github.com/JECSand/identity-service/api_gateway_service/identity/commands

github.com/JECSand/identity-service/command_service/identity/commands

github.com/JECSand/identity-service/query_service/identity/delivery/kafka

github.com/JECSand/identity-service/command_service/identity/delivery/kafka

github.com/Junjiayy/hamal/pkg/core/readers

github.com/Inspirate789/SOK-golang-test-task/cmd/worker/processor

github.com/Inspirate789/SOK-golang-test-task/internal/transactions/consumer

github.com/Inspirate789/SOK-golang-test-task/internal/transactions/producer

github.com/Egor-Tihonov/Kafka-proj/internal/consumer

github.com/Egor-Tihonov/Kafka-proj/internal/producer

github.com/bobzombie69/btcpool-go-modules/chainSwitcher

github.com/eeQuillibrium/Unimatch/pkg/kafka

github.com/eeQuillibrium/Unimatch/api_gateway_service/internal/service

github.com/eeQuillibrium/Unimatch/profile_service/internal/app

github.com/JordyMoos/kafka-disconnect-test

github.com/FernandoCagale/c4-payment/internal/broker/producer

github.com/FernandoCagale/c4-payment/internal/broker/consumer

github.com/Ferum-Bot/HermesTrade/internal/asset-spread-hunter/producers/found-spreads

github.com/Ferum-Bot/HermesTrade/internal/spreads-storage/workers/found-spreads

github.com/BrobridgeOrg/kabridge/tests

github.com/CRAYON-2024/worker/internal/usecase

github.com/CRAYON-2024/worker/internal/worker

github.com/CRAYON-2024/worker/internal/cmd

github.com/smarty/messaging-kafka

github.com/evanzhang87/evans-tools/cmd/kafka-go/consumer

github.com/burhankangsi/LetsYouTube/content

github.com/rosas99/monster/pkg/options

github.com/rosas99/monster/pkg/queue

github.com/rosas99/monster/internal/pump

github.com/rosas99/monster/internal/sms/writer

github.com/rosas99/monster/internal/sms/biz

github.com/rosas99/monster/internal/sms/monitor

github.com/stdyum/api-auth/internal/config

github.com/steadfastie/gokube/data/brocker

github.com/AccelByte/ic-eventstream-go-sdk/pkg/eventstream

github.com/xBlaz3kx/event-processing-challenge/internal/pkg/kafka

github.com/long250038728/web/tool/mq

github.com/doublecloud/transfer/pkg/providers/kafka

github.com/doublecloud/transfer/pkg/providers/kafka/client

github.com/doublecloud/transfer/pkg/providers/kafka/writer

github.com/Erwin011895/go-examples/user_service

github.com/Katherine-988/task_server

github.com/Katherine-988/tools

github.com/QuanDN22/Server-Management-System/internal/management-system/gRPCServer

github.com/QuanDN22/Server-Management-System/pkg/kafka/consumer

github.com/QuanDN22/Server-Management-System/pkg/kafka/producer

github.com/SergeiIonin/golang_std/kafkago/dial

github.com/SergeiIonin/golang_std/kafkago/readerpartitioned

github.com/SergeiIonin/golang_std/kafkago/writerpartitioned

github.com/SergeiIonin/golang_std/kafkago/app/reader

github.com/SergeiIonin/golang_std/kafkago/app/writer

github.com/minicloudsky/lianjia/internal/biz

github.com/minicloudsky/lianjia/internal/data

github.com/marktran77/go-ecomerce-backend-api/cmd/cli/kafka

github.com/vynovikov/highLoadSaver/internal/adapters/application

github.com/vynovikov/highLoadSaver/internal/adapters/driver/rpc

github.com/Egor123qwe/loggy/pkg/producer

github.com/Baitinq/fs-tracer-backend/src/payload-processor/processor

github.com/Baitinq/fs-tracer-backend/src/payload-processor/cmd

github.com/Baitinq/fs-tracer-backend/src/rest-api/handler

github.com/Baitinq/fs-tracer-backend/src/rest-api/cmd

github.com/skylee424/blue-bell/dao/kafka

github.com/rejdeboer/multiplayer-server/internal/routes

github.com/rejdeboer/multiplayer-server/internal/application

github.com/rejdeboer/multiplayer-server/tests/helpers

github.com/biangacila/biatechlib-go/kafka

github.com/rezaAmiri123/test-microservice/library_service/ports/kafka

github.com/rezaAmiri123/test-microservice/message_service/ports/kafka

github.com/rezaAmiri123/test-microservice/api_service/app/command

github.com/rezaAmiri123/test-microservice/user_service/app/command

github.com/go-transcoder/transcoder/internal/infrastructure/events/kafka

github.com/otaviokr/spacetraders-ship/kafka

github.com/Hank-Kuo/go-kafka-example/internal/server

github.com/Hank-Kuo/go-kafka-example/pkg/kafka

github.com/Hank-Kuo/go-kafka-example/internal/api/repository/user

github.com/Hank-Kuo/go-kafka-example/internal/api/service/user

github.com/PT-Jojonomic-Indonesia/microkit/service/example-kafka

github.com/hlsana/golang-course/hw18/internal/kafka

github.com/burhankangsi/Flash-API/content

github.com/synthao/orders/internal/service

github.com/synthao/orders/cmd/app

github.com/JovidYnwa/microCmp/internal/kafka

github.com/nvj9singhnavjot/media-docker/logger

github.com/nvj9singhnavjot/media-docker/kafkahandler

github.com/venture-technology/venture/scripts

github.com/venture-technology/venture/internal/entity

github.com/jkmancuso/home_sniffer/stores

github.com/muazhari/logi-backend-1/src/outers/datastores/message_brokers

github.com/muazhari/logi-backend-1/src/outers/repositories/message_brokers

github.com/n8sPxD/cowIM/internal/im_server/svc

github.com/n8sPxD/cowIM/internal/im_server/internal/server

github.com/n8sPxD/cowIM/internal/im_server/internal/mqs

github.com/n8sPxD/cowIM/internal/msg_forward/internal/logic

github.com/n8sPxD/cowIM/internal/msg_to_db/internal/mqs

github.com/spark-lence/tiga

github.com/mmfshirokan/PriceProvider/internal/provider

github.com/joshqu1985/lego/broker

github.com/Bitummit/go_auth/internal/api/kafka

github.com/jailtonjunior94/order/cmd/consumer

github.com/BariVakhidov/sso/internal/kafka

github.com/Bitummit/mail-microservice/internal/api/kafka

github.com/Omnitouch/cgrates/engine

github.com/Omnitouch/cgrates/ers

github.com/go-park-mail-ru/2024_2_kotyari/internal/delivery/user

github.com/go-park-mail-ru/2024_2_kotyari/internal/kafka_api/promocodes

github.com/AydinKZ/K-Diode-Caster/internal/adapters

github.com/AydinKZ/K-Diode-Catcher/internal/adapters

github.com/urbanindo/go-kafka-http-sink/cmd/worker/worker

github.com/bezmoradi/knowledge-base-microservice/src/services

github.com/RianNegreiros/vigilate/config

github.com/go-transcoder/uploader/internal/infrastructure/events/kafka

github.com/ogniloud/madr/internal/wordmaster

github.com/kubearmor/sidekick/outputs

github.com/iurikman/cashFlowManager/internal/broker

github.com/DoCongThanhPhuong/go-backend/cmd/cli/kafka

github.com/maestre3d/coinlog/messaging/kafka

github.com/scul0405/saga-orchestration/internal/orchestrator/app

github.com/scul0405/saga-orchestration/internal/orchestrator/eventhandler

github.com/scul0405/saga-orchestration/internal/order/eventhandler

github.com/dwprz/prasorganic-notification-service/src/core/broker/delivery

github.com/dwprz/prasorganic-shipping-service/src/core/broker/handler

github.com/dwprz/prasorganic-shipping-service/src/core/broker/consumer

github.com/costa92/krm/internal/pump

github.com/costa92/krm/internal/usercenter/auth

github.com/costa92/krm/pkg/streams/connector/kafka

github.com/znsio/specmatic-order-bff-go/internal/com/store/order/bff/services

github.com/dwprz/prasorganic-order-service/src/core/broker/handler

github.com/dwprz/prasorganic-order-service/src/core/broker/consumer

github.com/AskaryanKarine/bmstu-ds-3/internal/gateway/retryer

github.com/mmfshirokan/PriceService/internal/consumer

github.com/baxromumarov/CompanyService/internal/event

github.com/isatay012or02/kafka-diode-catcher/internal/adapters

github.com/gemyago/top-k-system-go/internal/services

github.com/qiaogy91/ioc/default/kafka

github.com/chengfield/go-queue/kq

github.com/chengfield/go-queue/kq/internal

github.com/nguyenta1993/service-kit/kafka

github.com/gurodrigues-dev/venture-microservice-emails/internal/service

github.com/gurodrigues-dev/venture-microservice-emails/internal/consumer

github.com/nguyentrunghieu15/kafka-example/taxi-application

github.com/nguyentrunghieu15/kafka-example/wikimedia_producer

github.com/sean0427/outbox-function-distributed-system-p/kafkawrapper

github.com/sean0427/outbox-function-distributed-system-p/kafkacontroller

github.com/jkmancuso/packet_consumer/sources

github.com/destrex271/pgwatch3_rpc_server/cmd/kafka_prod_receiver

github.com/zxlzhd/temporal_md_a/kafka

github.com/movie-recommendation-v1/geteway/pkg/kafka

github.com/Vilinvil/task_messaggio/internal/message/message/repository

github.com/Vilinvil/task_messaggio/internal/messageworker/messageworker/repository

github.com/fangaoxs/go-gist/kafka/internal/reader

github.com/fangaoxs/go-gist/kafka/internal/writer

github.com/peizhong/codeplay/pkg/event

github.com/tetafro/kafka-dump

github.com/yizhezhang-ervin/backend_golang/3-Middlewares/myKafka

github.com/khalid0306/Kafka_golang/collector_kafka-go

github.com/khalid0306/Kafka_golang/stocker_kafka-go

github.com/malav4all/kafka-hexdata-lib/producer

github.com/muhhae/kafka-lstm/consumer

github.com/toomanysource/atreus/app/comment/service/internal/data

github.com/toomanysource/atreus/app/favorite/service/internal/data

github.com/toomanysource/atreus/app/message/service/internal/data

github.com/roackb2/lucid/internal/pkg/pubsub

github.com/dotuananh2k1/client-server-test/test/kafka-test/client

github.com/dotuananh2k1/client-server-test/test/kafka-test/server

github.com/hihoak/otus-microservices-architect/cmd/billing-service

github.com/hihoak/otus-microservices-architect/cmd/order-service/sagas

github.com/hihoak/otus-microservices-architect/internal/adapters/kafka

github.com/ngdangkietswe/swe-auth-service/kafka/producer

github.com/costa92/micros-service/pkg/options

github.com/pereiragm/go-examples/consumer_test

github.com/pereiragm/go-examples/notifier_test

github.com/rubyniu105/gateway/proxy/output/kafka/example

github.com/chenzhiwei/kafka/utils/config

github.com/chenzhiwei/kafka/utils/message

github.com/chenzhiwei/kafka/cmd/consumer

github.com/chenzhiwei/kafka/cmd/producer

github.com/chenzhiwei/kafka/cmd/admin/app

github.com/yogerhub/kratos-news-system/app/filter/service/internal/service

github.com/yogerhub/kratos-news-system/app/news/service/internal/data

github.com/diki-haryadi/go-micro-template/internal/article/domain

github.com/diki-haryadi/go-micro-template/internal/article/usecase

github.com/Lux-N-Sal/autro-signal

github.com/ngdangkietswe/swe-notification-service/kafka/consumer

github.com/AlexEr256/messageService/consumer/cmd

github.com/Rayato159/go-simple-kafka/pkg/utils

github.com/Rayato159/go-simple-kafka/apps/producer

github.com/lapitskyss/chat-service/internal/services/msg-producer

github.com/mirjalilova/auth-service-blacklist/pkg/kafka/producer

github.com/mirjalilova/auth-service-blacklist/pkg/kafka/consumer

github.com/khulnasoft/fanal/outputs

github.com/nuhmanudheent/hosp-connect-payment-service/internal/utils

github.com/Lux-N-Sal/autro-notification

github.com/muhammadali07/system-event-trace/services/acc/app

github.com/muhammadali07/system-event-trace/services/journal/handler

github.com/v1tbrah/post-service/internal/msgsndr

github.com/lightstep/opentelemetry-examples/collector/kafka/src/producer

github.com/li1553770945/sheepim-push-proxy-service/biz/infra/kafka

github.com/li1553770945/sheepim-push-proxy-service/biz/internal/repo

github.com/PhubetK/goWorkshop/app/consumer1

github.com/PhubetK/goWorkshop/app/consumer2

github.com/PhubetK/goWorkshop/app/producer

github.com/PhubetK/goWorkshop/app/pkg/utils

github.com/dsperax/management-api-go/internal/infra/kafka

github.com/owen97779/Pachamama-MQTT-Kafka-Producer/pkg/kafka

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

github.com/phonghaido/log-ingestor/kafka

github.com/dontubaby/kafka_wrapper

github.com/gmlalfjr/go-service-kit/kafka

github.com/costa92/k8s-krm-go/pkg/options

github.com/mheers/kafka-gh-actions-trigger

github.com/arrrden/hykafka

github.com/arrrden/hykafka/router

github.com/arrrden/hykafka/examples/pubsub

github.com/tony-zhuo/follow-service/service/usecase

github.com/tony-zhuo/follow-service/delivery/worker/worker_manager/follow

github.com/dragonator/notification-service/module/notification

github.com/dragonator/notification-service/pkg/kafka

github.com/go-sohunjug/kratos-transport/broker/kafka

github.com/go-sohunjug/kratos-transport/transport/kafka

github.com/LLM-Tests-Checker/Common-Backend/internal/consumers/llm_result

github.com/VladislavSCV/Test3/test

github.com/VladislavSCV/Test3/internal/kafka

github.com/VladislavSCV/Test3/test/qwe

github.com/Sh1ni-Gami/WB_Tech_L0/kafka

github.com/rafaelsanzio/go-flashscore/pkg/kafka

github.com/SENERGY-Platform/platform-connector-lib/kafka

github.com/SENERGY-Platform/platform-connector-lib/connectionlog/test/helper

github.com/falcosecurity/falcosidekick/outputs

github.com/Samuelfaure/go-tracker/messenger

github.com/pervrosen/kafkaapi/kafkaUtils

github.com/pervrosen/kafkaapi/microsvc

github.com/disturb16/kafkaclient

github.com/l-lin/fizzbuzz/stats/kafka

github.com/cblomart/vsphere-graphite/backend

github.com/budiariyanto/cqrs-dummy/common

github.com/budiariyanto/cqrs-dummy/handler

github.com/ggerrietts/leadpipe-go/pkg/kafka

github.com/mxc-foundation/lpwan-app-server/internal/integration/kafka

github.com/SyaibanAhmadRamadhan/go-pub-sub-kafka/consumer

github.com/SyaibanAhmadRamadhan/go-pub-sub-kafka/producer

github.com/SyaibanAhmadRamadhan/go-pub-sub-kafka/consumer/internal

github.com/SyaibanAhmadRamadhan/go-pub-sub-kafka/producer/internal

github.com/rezaAmiri123/test-microservice/test/kafka1

github.com/rezaAmiri123/test-microservice/test/message_example

github.com/rezaAmiri123/test-microservice/user_service/ports/kafka

github.com/TomasVojacek/kafka-go2/gzip

github.com/TomasVojacek/kafka-go2/lz4

github.com/TomasVojacek/kafka-go2/snappy

github.com/TomasVojacek/kafka-go2/zstd

github.com/PT-Jojonomic-Indonesia/microkit/kafka

github.com/VanThen60hz/GoShop/cmd/cli/kafka

github.com/ogibayashi/sample-app-golang/service/kafka

github.com/Falokut/email_service/internal/events

github.com/TheDao032/golang-architectures-demo/internal/api/kafka

github.com/nvj9singhnavjot/media-docker/internal/media-docker-failed-consumer/process

github.com/nvj9singhnavjot/media-docker/internal/media-docker-kafka-consumer/process

github.com/acd19ml/TalentRank/apps/user/kafka

github.com/muazhari/logi-backend-1/src/outers/configurations

github.com/muazhari/logi-backend-1/src/inners/use_cases/managements

github.com/yongxiaodong/golibs/kafkaDB

github.com/vnvo/prensio/pipeline

github.com/vnvo/prensio/test_helpers

github.com/JimySheepman/to-do-api/consumer/internal/infrastructure/consumer

github.com/jailtonjunior94/order/pkg/messaging/kafka

github.com/xavesen/search-api/internal/queue

github.com/JimySheepman/to-do-api/internal/infrastructure/broker/producer

github.com/JimySheepman/to-do-api/consumer/internal/application

github.com/JimySheepman/to-do-api/consumer/internal/service

github.com/byt3-m3/GoPractice/kafka/producer

github.com/infraboard/maudit/apps/event/impl

github.com/Falokut/admin_movies_persons_service/internal/events

github.com/urbanindo/go-kafka-http-sink/internal/processor

github.com/urbanindo/go-kafka-http-sink/cmd/console/simpleavro

github.com/RianNegreiros/vigilate/internal/kafka

github.com/jamesseanwright/knative-kafka-cloudevents/internal

github.com/jamesseanwright/knative-kafka-cloudevents/cmd/consumer

github.com/jamesseanwright/knative-kafka-cloudevents/cmd/producer

github.com/gabiSmachado/intents/producer

github.com/gabiSmachado/intents/broker

github.com/reecerussell/open-social/eventing/kafka

github.com/assylzhan-a/company-task/internal/kafka

github.com/AmanKumar2696/sidekick/outputs

github.com/AlpacaLabs/api-confirmation/internal/async

github.com/cursed-ninja/go-kafka-producer

github.com/margostino/anfield/kafka

github.com/scul0405/saga-orchestration/pkg/kafka

github.com/scul0405/saga-orchestration/internal/payment/eventhandler

github.com/scul0405/saga-orchestration/internal/product/eventhandler

github.com/scul0405/saga-orchestration/internal/purchase/eventhandler

github.com/superhero-match/consumer-delete-media/internal/consumer

github.com/costa92/krm/pkg/options

github.com/Asliddin3/customer-servis/kafka

github.com/alexander-winters/SENG468-A2/kafka-docker/kafkaService

github.com/2pgcn/gameim/internal/logic/data

github.com/2pgcn/gameim/pkg/gamelog

github.com/luebken/todos/cmd/todos

github.com/FabioSebs/NotiService/internal/infrastructure/broker

github.com/FabioSebs/NotiService/internal/domain/services/broker

github.com/gemyago/top-k-system-go/internal/app/aggregation

github.com/gemyago/top-k-system-go/internal/app/ingestion

github.com/nguyenta1993/service-kit/tracing

github.com/nguyenta1993/service-kit/healthcheck

github.com/1ef7yy/go-kafka-poc/internal/kafka

github.com/diy-cloud/log-silo

github.com/isatay012or02/kafka-diode-caster/internal/adapters

github.com/ekhvalov/bank-chat-service/internal/services/afc-verdicts-processor/mocks

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/queue_coherence/before

github.com/ezotrank/interop

github.com/ezotrank/interop/mocks

github.com/ezotrank/interop/examples/http-kafka

github.com/detohm/go-study/kafka/basic

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/queue_coherence/after

github.com/muhhae/kafka-lstm

github.com/toomanysource/atreus/pkg/kafkaX

github.com/toomanysource/atreus/app/publish/service/internal/data

github.com/toomanysource/atreus/app/relation/service/internal/data

github.com/toomanysource/atreus/app/user/service/internal/data

github.com/dotuananh2k1/client-server-test/client/producer/kafka

github.com/dotuananh2k1/client-server-test/server/consumer/kafka

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/polling_clients/after

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/etl/after

github.com/dylanjfeehan/conf-agenda

github.com/trb1maker/gobannercircle/internal/notify/kafka

github.com/rubyniu105/gateway/proxy/output/kafka

github.com/ghenoo/microservices-go/cmd/producer

github.com/cockroachdb/architectural-simplification/001_fragile_data_integrations/business_transactions/after

github.com/diki-haryadi/go-micro-template/internal/health_check/usecase/kafka_health_check

github.com/diki-haryadi/go-micro-template/internal/article/delivery/kafka/producer

github.com/kochabonline/kit/store/kafka

github.com/zackarysantana/velocity/internal/service/kafka

github.com/BariVakhidov/rssaggregator/internal/kafka

github.com/lapitskyss/chat-service/internal/logger

github.com/lapitskyss/chat-service/internal/services/afc-verdicts-processor/mocks

github.com/nuhmanudheent/hosp-connect-notification-service/internal/service

github.com/nuhmanudheent/hosp-connect-notification-service/internal/di

github.com/nuhmanudheent/hosp-connect-appointment-service/internal/di

github.com/chnmk/order-info-l0/internal/models

github.com/chnmk/order-info-l0/internal/config

github.com/chnmk/order-info-l0/internal/consumer

github.com/v1tbrah/relation-service/internal/msgsndr

github.com/2997215859/gomdsdk/consumer

github.com/Verce11o/resume-view/resume-view/internal/handler/kafka

github.com/ninglg/golang-example/kafka/consumer3

github.com/li1553770945/sheepim-push-worker-service/biz/infra/kafka

github.com/Bulut-Bilisimciler/go-ms-boilerplate/pkg/application/scheduler_handlers

github.com/costa92/k8s-krm-go/internal/usercenter/auth

github.com/amrHassanAbdallah/notificationaway

github.com/amrHassanAbdallah/notificationaway/consumer

github.com/tony-zhuo/follow-service/pkg/kafka

github.com/cvcio/mediawatch/cmd/worker

github.com/greenac/chaching/cmd/kafka

github.com/greenac/chaching/cmd/fetch_consumer

github.com/SergeiIonin/golang_kafka_window_utils/timewindows

github.com/wangzhen94/iam/internal/pump/pumps

github.com/ofavor/ddd-go/pkg/event/kafka

github.com/SergeiIonin/golang_kafka_window_utils/testutils

github.com/LLM-Tests-Checker/Common-Backend/internal/producers/llm_check

github.com/LLM-Tests-Checker/Common-Backend/cmd/consumer/llm_result

github.com/LLM-Tests-Checker/Common-Backend/cmd/worker/launch_llm_check

github.com/rsi2m/xk6-kafka-fixed

github.com/djedjethai/gokfk-regent/examples/segmentio-wurstmeister/avro

github.com/djedjethai/gokfk-regent/examples/segmentio-wurstmeister/json

github.com/djedjethai/gokfk-regent/examples/segmentio-wurstmeister/protobuf

github.com/chrismarsilva/cms-golang/cms.golang.teste.messageria/cms.golang.teste.kafka.segmentio

github.com/KyKyPy3/clean/pkg/kafka

github.com/ecodeclub/mq-api/kafka/common

github.com/ecodeclub/mq-api/kafka

github.com/liguoqinjim/go-labs/lab179/lab003

github.com/foundation-go/foundation

github.com/johnnyeven/libtools/task/kafka

github.com/RedHatInsights/chrome-service-backend/rest/kafka

github.com/guatom999/TicketShop-Movie/modules/payment/paymentRepositories

github.com/SENERGY-Platform/platform-connector-lib

github.com/RedHatInsights/cloud-connector/cmd/cloud-connector

github.com/superhero-match/superhero-match/internal/producer

github.com/west2-online/fzuhelper-server/pkg/base/client

github.com/av-ugolkov/lingua-evo/internal/delivery/kafka

github.com/wenlaizhou/middleware

github.com/wahidx/kafkax/xkafka

github.com/xrpscan/platform/producers

github.com/xrpscan/platform/consumers

github.com/trakkie-id/kafka-zipkin-interceptor

github.com/gitbitex/gitbitex-spot/matching

github.com/gitbitex/gitbitex-spot/rest

github.com/alextanhongpin/core/queue/pubsub/examples

github.com/alextanhongpin/core/queue/pubsub

github.com/arthurshafikov/banner-rotation/pkg/queue

github.com/arthurshafikov/banner-rotation/internal/app

github.com/vynovikov/highLoadParser/internal/transmitters

github.com/frain-dev/newcloud-migrator/convoy-23.9.2/internal/pkg/pubsub/kafka

github.com/halokid/NeonRabbit/broker/brokerx

github.com/kanatovnurzhas/test-task-2/pkg/kafka

github.com/circuit-platform/models-utils

github.com/underbek/examples-go/transport/kafka

github.com/JECSand/identity-service/command_service/server

github.com/pauluswi/rhine/internal/trxhistory

github.com/Coflnet/ci-notifications

github.com/Genialngash/sasapay-mandate-microservice/kafkaClient

github.com/EgMeln/touchKafka/internal/consumer

github.com/EgMeln/touchKafka/internal/producer

github.com/eeQuillibrium/Unimatch/profile_service/internal/delivery/kafka

github.com/FernandoCagale/c4-notify/internal/broker/consumer

github.com/Ferum-Bot/HermesTrade/cmd/asset-spread-hunter

github.com/Ferum-Bot/HermesTrade/cmd/spreads-storage

github.com/CRAYON-2024/worker/bootstrap

github.com/blackhorseya/godine/app/infra/transports/kafkax

github.com/blackhorseya/godine/app/infra/transports/mqx

github.com/JECSand/identity-service/query_service/server

github.com/Mario-Jimenez/newspub/broker/kafka

github.com/Inspirate789/kafka-test/cmd/worker

github.com/rosas99/monster/internal/sms/mqs

github.com/rosas99/monster/internal/usercenter/biz

github.com/rosas99/monster/pkg/streams/connector/kafka

github.com/stdyum/api-auth/internal/modules/notifications

github.com/stdyum/api-auth/internal/modules/notifications/repositories

github.com/Inspirate789/kafka-test/cmd/api

github.com/doublecloud/transfer/internal/logger

github.com/QuanDN22/Server-Management-System/internal/monitor

github.com/BaseMax/KafkaDataProcessingGo/cmd

github.com/p2p-org/mbelt-cosmos-streamer/datastore