Go to main page
Known importing modules: 321
Known importing packages: 262 (displaying 347 packages, including internal and invalid packages)
Known importing packages: 262 (displaying 347 packages, including internal and invalid packages)
- bitbucket.org/bsdrpst/gopkg/q/sarama
- bitbucket.org/credmais/kafka/pkg/mensageria/sarama-kafka
- bitbucket.org/toggleglobal/germ/event/kafka/sasl
- eagain.net/go/scram-password/internal/scramble
- gitea.com/ucsob/libs/kafkasarama/scramclient
- gitee.com/linpbin/nexus/internal/proxy/kafka
- gitee.com/tym_hmm/go-kafa-shopify-sarama/examples/sasl_scram_client
- gitee.com/zsmdmy/skeleton/internal/infra/eventbus
- github.com/11SF/go-common/kafka
- github.com/8xmx8/easier/pkg/amqp/kafka
- github.com/AbnerEarl/goutils/kafkas
- github.com/AccelByte/messagebus-go-sdk
- github.com/Adhiana46/aegis-asesmen/cmd/api
- github.com/Aeroraven/Nclpkgs/pkg/processor/trigger/kafka/scram
- github.com/Andrea-Cavallo/adOmnia/internal/kafka
- github.com/AndrivA89/kafkadesk/infrastructure
- github.com/AzusaChino/maackia/pkg/kafka/auth
- github.com/BlackMocca/mongo-go-driver/x/mongo/driver/auth
- github.com/Clymene-project/Clymene/pkg/kafka/auth
- github.com/Cyber-Watcher/kafman/internal/kafka
- github.com/DamiaRalitsa/messaging-lib-go/messaging/auth
- github.com/Dert091499/Utilities/messaging/kafka
- github.com/Dert12318/Utilities/messaging/kafka
- github.com/EchoMessenger/router
- github.com/G-Sacker/kafka-lib/kafka
- github.com/GoCodeAlone/workflow/module
- github.com/Goden-Gun/transport-lib/pkg/kafka
- github.com/IBM/sarama/examples/sasl_scram_client
- github.com/Jacob2513/mongo-go-driver/x/mongo/driver/auth
- github.com/Jbcampbe/kafka-go/sasl/scram
- github.com/KOMKZ/go-yogan-framework/kafka
- github.com/LoneWolf38/kafka-go/sasl/scram
- github.com/Matrics-io/components-contrib/common/component/kafka
- github.com/Meystergod/mgo
- github.com/MrMiaoMIMI/goshared/mq/internal/mqsp
- github.com/Palladium-blockchain/go-kafka-mq/v2/internal/scram
- github.com/PeerDB-io/peerdb/flow/switchboard
- github.com/PerchSecurity/kafka-go/sasl/scram
- github.com/RomanDeveloperGit/shortlink-link-api/internal/infra/broker
- github.com/Roshick/go-autumn-kafka/pkg/kafka
- github.com/SUNET/vc/pkg/messagebroker/kafka
- github.com/ServiceNow/kafka-go/sasl/scram
- github.com/SnoozeThis-org/pgperms
- github.com/TencentBlueKing/bkmonitor-datalink/pkg/bk-monitor-worker/internal/apm/pre_calculate/notifier
- github.com/TykTechnologies/benthos/v4/internal/impl/kafka
- github.com/WhfWll/yaklang-autonomous/common/utils/bruteutils
- github.com/aaronjheng/kafka-cli/internal/kafka
- github.com/aarontianqx/gopkg/kafka
- github.com/abelanger5/loki/clients/pkg/promtail/targets/kafka
- github.com/abhijitpratinidhi/connect/v4/impl/impl/kafka
- github.com/aeroraven/nclpkgs/pkg/processor/trigger/kafka/scram
- github.com/airunny/timer/pkg/ikafka
- github.com/alirezashaheri/kafka-go/sasl/scram
- github.com/ampliway/way-lib-go/msg/v1
- github.com/amyglan/kafka-go-fork/sasl/scram
- github.com/andriva89/kafkadesk/infrastructure
- github.com/androidjp/llib-kafka
- github.com/ankush-003/alerts-simulation-and-remediation/middleware/sim/kafka
- github.com/anthanhphan/saturday/kafka
- github.com/argoproj/argo-events/pkg/shared/util
- github.com/asabaki/kafka-client/internal/scram
- github.com/aykanferhat/go-kafka-partition-scaler/pkg/kafka/sarama
- github.com/azarakovskiy/kafka-go/sasl/scram
- github.com/b3ns44d/sarama-kafka-sasl-test
- github.com/bakharal/mongo-go-driver/x/mongo/driver/auth
- github.com/ball6847/mongo-ro-proxy/internal/backend
- github.com/bilalba/argo-events-testing/pkg/scram
- github.com/blusewang/pg/client
- github.com/boilingsitar/mss-boot/pkg/config/storage/queue
- github.com/brainlet/brainkit/experiments/mongo-scram
- github.com/cB-Sigma/iotcrypto/sasl
- github.com/caiflower/common-tools/kafka/v2
- github.com/caioricciuti/ch-ui/internal/pipelines
- github.com/charleschuangchang/gingo/backend/3rdLib/src/go.mongodb.org/mongo-driver/x/mongo/driver/auth
- github.com/chenrui333/terraformer/providers/kafka
- github.com/chris-alexander-pop/go-hyperforge/pkg/messaging/adapters/kafka
- github.com/christiancadieux/sarama/examples/sasl_scram_client
- github.com/civitatis/kubernetes-event-exporter/pkg/sinks
- github.com/cloudnative-pg/machinery/pkg/postgres/scram
- github.com/cloudoperators/opentelemetry-collector-contrib/internal/kafka
- github.com/cockroachdb/replicator/internal/source/kafka
- github.com/coder543/roundabout/frontend
- github.com/cody0704/kafka-go/sasl/scram
- github.com/confluentinc/kcp/internal/client
- github.com/contobox/orbita/scram
- github.com/cygy/ginamite/plugins/kafka
- github.com/dalelane/grafana-kafka-datasource/pkg/kafka
- github.com/danielqsj/kafka_exporter
- github.com/dapr/components-contrib/common/component/kafka
- github.com/dataflow-operator/dataflow/internal/connectors
- github.com/ddatdt12/kapo-play-ws-server/internal/scram
- github.com/deatheyes/mongo-proxy/auth
- github.com/deveshk0/mgo/internal/scram
- github.com/deviceinsight/kafkactl/v5/internal/helpers
- github.com/distribworks/dkron/v4/builtin/bins/dkron-executor-kafka
- github.com/donghc/goutils/pkg/pubsub
- github.com/drewpayment/orbit/services/bifrost/internal/proxy
- github.com/drip-in/eden_lib/pubsub
- github.com/dusbot/maxx/core/crack
- github.com/edgeflare/pigo/pkg/pipeline/peer/kafka
- github.com/edu3dw4rd/kafka-cli
- github.com/eduojeda/opentelemetry-collector-contrib/exporter/kafkaexporter
- github.com/eolinker/apinto/drivers/output/kafka
- github.com/erikfastermann/sql/postgres
- github.com/etaques/orb/sinker/otel/kafkafanoutexporter
- github.com/fmoor/loki/v2/clients/pkg/promtail/targets/kafka
- github.com/formancehq/payments/cmd
- github.com/formancehq/stack/libs/go-libs/publish
- github.com/frelon/loki/v2/clients/pkg/promtail/targets/kafka
- github.com/functions-dev/func-operator/internal/objectbucketsource/kafka
- github.com/gatewayd-io/gatewayd/network
- github.com/generalmotors/kafka-go/sasl/scram
- github.com/gleam-G/loki/v2/clients/pkg/promtail/targets/kafka
- github.com/go-god/broker/gkafka
- github.com/go42-dev/go42/internal/events/kafka
- github.com/grepplabs/kafka-proxy/proxy
- github.com/grunyas/grunyas/internal/auth
- github.com/hanzoai/docdb/internal/dataapi/server
- github.com/hanzoai/documentdb-go/x/mongo/driver/auth
- github.com/hanzoai/s3/s3/notification/kafka
- github.com/harphies/go.microservices.io/messaging/kafka
- github.com/herry-go/kafka-scram-cli/scram
- github.com/hongjunxin/go-learning/middleware/sarama/sasl_scram_client
- github.com/hongyuyang/mongo-go-driver/x/mongo/driver/auth
- github.com/hoophq/cloak/internal/connector/postgres
- github.com/housepower/clickhouse_sinker/input
- github.com/hoveychen/kafka-go/sasl/scram
- github.com/iTukaev/kafka-go/sasl/scram
- github.com/ig6gzu/biz_exporter
- github.com/inder/salvobase/internal/auth
- github.com/insistentowl/mss-boot/pkg/config/storage/queue
- github.com/irvingos/go-tools/kafka
- github.com/ivan-zherdev/benthos/v4/internal/impl/kafka
- github.com/j0sh/minikafka
- github.com/jaegertracing/jaeger/internal/storage/kafka/auth
- github.com/jan-zajic/sarama/examples/sasl_scram_client
- github.com/jessekempf/kafka-go/sasl/scram
- github.com/jifuy/commongo/mq/kafka
- github.com/jilin7105/ebase/kafka/ConsumerAbout
- github.com/justyntemme/bigDocker/go/large
- github.com/kadzany/messaging-lib/scram
- github.com/kbukum/gokit/database/postgres/testutil
- github.com/kcore-io/sarama/examples/sasl_scram_client
- github.com/kedacore/keda/v2/pkg/scalers/kafka
- github.com/kingstonduy/go-core/transport/broker/kafka
- github.com/kjschnei001/jaeger/pkg/kafka/auth
- github.com/kloudfuse/kafka-go/sasl/scram
- github.com/kmetaxas/gafkalo
- github.com/korableg/bus/internal/saramacfg
- github.com/korlvs/event-log
- github.com/leonardoce/pgsalt/internal/scram
- github.com/linzeyan/loadconf/connector/conn_kafka_sarama
- github.com/livespotty/K-Filtra/proxy
- github.com/losfair/hgw/homegw-libs/kafka-sink
- github.com/lstruman/sarama/examples/sasl_scram_client
- github.com/lynx-go/lynx/contrib/kafka
- github.com/lzw5399/go-common-public/library/mq/k
- github.com/majorcontext/gatekeeper/proxy
- github.com/marre/ksink/pkg/ksink
- github.com/marsccm/sarama/examples/sasl_scram_client
- github.com/martketplace-vkr/pkg/kafkaconnector
- github.com/meystergod/mgo/internal/scram
- github.com/mingrammer/sarama/examples/sasl_scram_client
- github.com/minhgiang16983/Minh-Kit-Hehe/kafka
- github.com/momeni/clean-arch/pkg/adapter/hash/scram
- github.com/mss-boot-sys/mss-boot-admin/mss-boot/pkg/config/storage/queue
- github.com/musobarlab/kafka-cli
- github.com/n-r-w/kafkaclient
- github.com/nats-io/nats-kafka/server/kafka
- github.com/naver/lobster/pkg/lobster/util
- github.com/neblic/platform/cmd/kafka-sampler/kafka/sarama
- github.com/nibbleshift/blobfish/impl/kafka
- github.com/njcx/libbeat_v8/common/kafka
- github.com/noah-platform/noah/pkg/producer
- github.com/nocsysmars/goflow2/v2/transport/kafka
- github.com/nstrlabs/mongo-go-driver/v2/x/mongo/driver/auth
- github.com/nuclio/nuclio/pkg/processor/trigger/kafka/scram
- github.com/numaproj/numaflow/pkg/shared/util
- github.com/nxdir-s/idlerpg/internal/adapters/secondary
- github.com/obstor/obstor/pkg/event/target
- github.com/og-dim9/dimutils/pkg/kafkautils
- github.com/onbloc/go-common/kafka
- github.com/open-policy-agent/eopa/internal/benthos/impl/kafka
- github.com/openbkn-ai/bkn-foundry/bkn-trace/agent-observability/src/drivenadapter/kafkaaccess/kafkaruntime
- github.com/openshift-assisted/ccx-exporter/internal/factory
- github.com/opensourceways/kafka-lib/kafka
- github.com/orb-community/orb/sinker/otel/kafkafanoutexporter
- github.com/osac-project/osac/fulfillment-service/internal/kafka
- github.com/otpki/components-contrib/common/component/kafka
- github.com/ownkube/kubernetes-events-exporter/internal/output
- github.com/palkx/vault-plugin-secrets-kafka
- github.com/pceric/kafka-offset-lag-for-prometheus
- github.com/pg-sharding/spqr/pkg/auth
- github.com/piotrszyma/sqlfmt/internal/sql/pgwire
- github.com/qianjisantech/gosmo
- github.com/quixio/telegraf/plugins/outputs/quix
- github.com/redpanda-data/connect/v4/internal/impl/kafka
- github.com/rfvbkm/kafka-exporter
- github.com/robertkonga/yekonga-server-go/plugins/mongo-driver/x/mongo/driver/auth
- github.com/routerarchitects/ra-common-mods/kafka
- github.com/ryshoooo/food-me/internal
- github.com/sajithsebastian/components-contrib/internal/component/kafka
- github.com/sciclon2/kafka-lag-go/pkg/kafka
- github.com/seaweedfs/seaweedfs/weed/notification/kafka
- github.com/segmentio/kafka-go/sasl/scram
- github.com/sigmasee/sigmasee/shared/enterprise/messaging/kafka/sarama
- github.com/sine-io/sinx/builtin/bins/sinx-executor-kafka
- github.com/son-la/snorlax/internal/kafka
- github.com/sosnovski/kafka
- github.com/stevemns/kafka-go/sasl/scram
- github.com/strimzi/strimzi-canary/internal/security
- github.com/tarmalonchik/golibs/kafkawrapper
- github.com/teamlify-devx/unimq/drivers/kafka
- github.com/technopoetic/credproxy/internal/dbproxy/pg
- github.com/templatedop/watermill/pkg/kafka
- github.com/thedolphin/karp/internal/pkg/karputils
- github.com/thomaspoignant/go-feature-flag/cmd/relayproxy/config/kafka
- github.com/tidwall/tile38/internal/endpoint
- github.com/tomdong2010/good-gokafka/internal/kafka
- github.com/tommi2day/gomodules/pwlib
- github.com/trinhdaiphuc/go-kit/kafka
- github.com/ucsob/libs/kafkasarama/scramclient
- github.com/uncool-dudes/utils/watermill
- github.com/userfm99/go-feature-flag/cmd/relayproxy/config/kafka
- github.com/validatecl/kafka-toolkit
- github.com/violetpupil/gos/lib/sarama
- github.com/weedge/lib/client/mq/kafka/auth
- github.com/worldbug/kafeman/internal/sarama_config
- github.com/xraph/forge/extensions/kafka
- github.com/xsj321/log-collector/pkg/promtail/targets/kafka
- github.com/xuzhijvn/opentelemetry-collector-contrib/exporter/kafkaexporter
- github.com/xyu-io/genie/transceiver/kafka
- github.com/yaklang/yaklang/common/utils/bruteutils
- github.com/yankunsam/loki/v2/clients/pkg/promtail/targets/kafka
- github.com/yeaze/connect/v4/internal/impl/kafka
- github.com/yvyrovyi-cinemo/utils/kafkalib
- github.com/zdyj3170101136/jaeger/pkg/kafka/auth
- github.com/zeiss/typhoon/pkg/sources/adapter/kafkasource
- github.com/zhangdapeng520/zdpgo_mongo/x/mongo/driver/auth
- gitlab.com/amitai/sarama/examples/sasl_scram_client
- go.digitalxero.dev/mq-kafka/v2
- go.pentstark.com/server/v2/pkg/core/proxy/integrations/scram
- helay.net/go/utils/v3/scram
- trpc.group/trpc-go/trpc-database/kafka