pkg.gl

Categorygithub.com/segmentio/kafka-gosaslplain

package

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

github.com/sabariramc/goserverbase/v5/testutils

github.com/sabariramc/goserverbase/v4/testutils

github.com/sabariramc/goserverbase/v3/utils/testutils

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

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

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

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

github.com/streamdal/plumber/backends/kafka

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

github.com/housepower/clickhouse_sinker/input

github.com/Trendyol/kafka-konsumer/v2

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

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

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

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

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

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

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

github.com/segmentio/topicctl/pkg/admin

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

github.com/batchcorp/plumber/backends/kafka

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

github.com/housepower/clickhouse_sinker/input

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/marmotedu/iam/internal/pump/pumps

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

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

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

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

github.com/fcristovao/await

github.com/gowins/dionysus/kafka

github.com/LeeZXin/zsf/logger

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

github.com/gw123/gutils/kafka

github.com/shipperizer/kilo-franz/sasl

github.com/zeromicro/go-queue/kq

github.com/onno-vos-dev/await

github.com/visforest/windy/kq

github.com/ego-component/ekafka

github.com/sko00o/kafka/producer/kafkago

github.com/musobarlab/kafka-cli

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

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

github.com/mosajjal/dnsmonster/internal/output

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

github.com/dmachard/go-dnscollector/workers

github.com/batchcorp/plumber/backends/kafka

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

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

github.com/deepshore/xk6-kafka

github.com/telenornms/skogul/receiver

github.com/telenornms/skogul/sender

github.com/mostafa/xk6-kafka

github.com/daylikon/xk6-kafka

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

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

github.com/livepeer/go-livepeer/monitor

github.com/tillkuhn/rubin/pkg/polly

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

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

github.com/seymac/xk6-kafka

github.com/bangunindo/trap2json/forwarder

github.com/chenquan/go-queue/kafka

github.com/viru-tech/clickhouse_sinker/input

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

github.com/databendcloud/bend-ingest-kafka

github.com/kevinyjn/gocom/mq/kafka

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

github.com/GRMrGecko/freeipa-health-metrics

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

github.com/owlify/sparrow/producer

github.com/owlify/sparrow/consumer

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

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

github.com/superproj/onex/pkg/options

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

github.com/rumis/storage/skafka

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

github.com/raczu/kube2kafka/pkg/exporter

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

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

github.com/robertlestak/procx/drivers/kafka

github.com/tillkuhn/letitgo/stream

github.com/batchcorp/kng

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

github.com/Trendyol/kafka-konsumer

github.com/xiongdi9456/go-queue/kq

github.com/lhdhtrc/kafka-go/pkg

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

github.com/ihatiko/kafka-client

github.com/lidaboo/go-queue/kq

github.com/dotunj/pvent/producer

github.com/AmanKumar2696/sidekick/outputs

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

github.com/blackhorseya/godine/app/infra/transports/kafkax

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

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

github.com/kochabonline/kit/store/kafka

github.com/kubearmor/sidekick/outputs

github.com/Niyko/Athena

github.com/tanqiuqiang/go-queue/kq

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

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

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

github.com/festum/gopkg/kafka

github.com/nguyenta1993/service-kit/kafka

github.com/chenzhiwei/kafka/utils/config

github.com/telkomdev/tob/services/kafka

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

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

github.com/rsi2m/xk6-kafka-fixed

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

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

github.com/Alibay/go-kit/kafka

github.com/west2-online/fzuhelper-server/pkg/base/client

github.com/falcosecurity/falcosidekick/outputs

github.com/ws6/klib

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

github.com/lidofinance/dc4bc/storage/kafka_storage

github.com/2pgcn/gameim/internal/logic/data

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

github.com/foundation-go/foundation/kafka

github.com/rosas99/monster/pkg/options

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

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

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

github.com/costa92/krm/pkg/options

github.com/chengfield/go-queue/kq

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

github.com/khulnasoft/fanal/outputs

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

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