Go to main page
Known importers: 364 (displaying 445 packages, including internal and invalid packages)
- bitbucket.org/amotus/pubsub/kafka
- github.com/0xgirish/kafka-exporter
- github.com/134ARG/testops-tmp/gosdk/log_agent
- github.com/3lvia/libraries-go/pkg/kafkaclient
- github.com/4books-sparta/utils/kafka2
- github.com/90poe/kafkaobjects-operator/internal/kafka
- github.com/DoNewsCode/core-otfranz
- github.com/Haeven/codec/pkg/kafka
- github.com/Jeffail/benthos/v3/internal/impl/kafka
- github.com/MisLink/go-web-template/pkg/kafka
- github.com/NikitaTsaralov/transactional-outbox
- github.com/NikitaTsaralov/transactional-outbox/example
- github.com/NikitaTsaralov/transactional-outbox/internal/infrastructure/broker/kafka
- github.com/NikitaTsaralov/transactional-outbox/internal/infrastructure/broker/kafka/dto
- github.com/NikitaTsaralov/transactional-outbox/tests
- github.com/NikitaTsaralov/utils/connectors/kafka
- github.com/NikitaTsaralov/utils/connectors/kafka/consumer
- github.com/NikitaTsaralov/utils/connectors/kafka/opts/ack_policy
- github.com/NikitaTsaralov/utils/connectors/kafka/opts/compression
- github.com/NikitaTsaralov/utils/connectors/kafka/opts/consumer_group_balancer
- github.com/NikitaTsaralov/utils/connectors/kafka/opts/partitioner
- github.com/NikitaTsaralov/utils/connectors/kafka/producer
- github.com/QenjieRepository/pkg/services
- github.com/TicketsBot/common/rpc
- github.com/TykTechnologies/benthos/v4/internal/impl/kafka
- github.com/a-h/kgomock
- github.com/acquirecloud/kafkaq/pkg/kafka
- github.com/agalue/gominion/broker
- github.com/anchamber-studios/hevonen/lib/events
- github.com/aranw/kafkatest
- github.com/arshanh/benthos/v4/internal/impl/kafka
- github.com/atropos112/atrka/producers
- github.com/aws-samples/amazon-msk-topic-resource/admin
- github.com/banzaicloud/koperator/tests/e2e
- github.com/bira37/benthos/v4/internal/impl/kafka
- github.com/birdayz/kstreams
- github.com/blink-io/x/kafka/franz/registrar
- github.com/bojand/pbgsmt
- github.com/boomerlang/go_kafka_txn_eos
- github.com/brivnc/goKafkaClient
- github.com/callistaenterprise/go-kafka-state-blog
- github.com/catake-com/multibase/backend/kafka
- github.com/ccarver-cni/kafka_learning_plan/cmd/produce_app
- github.com/centrifugal/centrifugo/v5/internal/consuming
- github.com/cerbos/cerbos/internal/audit/kafka
- github.com/clinia/x/pubsubx/kgox
- github.com/connectfit-team/log/kafkalog
- github.com/cos-okan/common
- github.com/crossplane-contrib/provider-kafka/internal/clients/kafka
- github.com/cwxstat/redpanda
- github.com/cybre/home-inventory/internal/kafka
- github.com/dataphos/lib-brokers/pkg/broker/kafka
- github.com/deepfence/ThreatMapper/deepfence_server
- github.com/deepfence/ThreatMapper/deepfence_server/handler
- github.com/deepfence/ThreatMapper/deepfence_server/ingesters
- github.com/deepfence/ThreatMapper/deepfence_server/router
- github.com/deepfence/ThreatMapper/deepfence_utils/utils
- github.com/deepfence/ThreatMapper/deepfence_worker
- github.com/deepfence/ThreatMapper/deepfence_worker/processors
- github.com/deepfence/ThreatMapper/deepfence_worker/tasks/malwarescan
- github.com/deepfence/ThreatMapper/deepfence_worker/tasks/sbom
- github.com/deepfence/ThreatMapper/deepfence_worker/tasks/secretscan
- github.com/ditsuke/kafka-pubsub
- github.com/dotnwat/pdc-verifier
- github.com/doublecloud/transfer/pkg/providers/kafka
- github.com/doublegrey/kabanchik
- github.com/douglasdgoulart/kafka-sql/internal/kafka
- github.com/douglasdgoulart/video-editor-api/internal/mocks
- github.com/douglasdgoulart/video-editor-api/pkg/api/internal/handler
- github.com/douglasdgoulart/video-editor-api/pkg/event
- github.com/douglasdgoulart/video-editor-api/pkg/event/emitter
- github.com/douglasdgoulart/video-editor-api/pkg/event/receiver
- github.com/duythinht/raven
- github.com/dzrock1989/perkakas/common/sync_services
- github.com/eisandbar/BusPool/lion/subscriber
- github.com/elwin/topic-cloner
- github.com/emoss08/trenova/pkg/kfk
- github.com/exsql-io/go-datastore/services
- github.com/fenghaojiang/kafka-mock-producer/kafka
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/cmd/processor/internal/contracts/kafkaclient
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/cmd/processor/internal/services/kafkaclient
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/cmd/processor/internal/services/kafkacloudeventservice
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/cmd/processor/internal/services/processor
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/internal/contracts/kafkaclient
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/internal/kafka_franz/v2
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/internal/services/bloblang
- github.com/fluffy-bunny/benthos-cloudevents-fluffycore/internal/services/kafkaclient
- github.com/fremantle-industries/tabletop/pkg/producer
- github.com/hexolan/stocklet/cmd/auth-service
- github.com/hexolan/stocklet/cmd/order-service
- github.com/hexolan/stocklet/cmd/payment-service
- github.com/hexolan/stocklet/cmd/product-service
- github.com/hexolan/stocklet/cmd/shipping-service
- github.com/hexolan/stocklet/cmd/warehouse-service
- github.com/hexolan/stocklet/internal/pkg/messaging
- github.com/hexolan/stocklet/internal/svc/auth/controller
- github.com/hexolan/stocklet/internal/svc/order/controller
- github.com/hexolan/stocklet/internal/svc/payment/controller
- github.com/hexolan/stocklet/internal/svc/product/controller
- github.com/hexolan/stocklet/internal/svc/shipping/controller
- github.com/hexolan/stocklet/internal/svc/warehouse/controller
- github.com/hhromic/kadumper/internal/kadumper
- github.com/hoyle1974/chorus/pubsub
- github.com/ice-blockchain/wintr/connectors/message_broker
- github.com/insolare/elionacore/kafka
- github.com/jcsp/si-verifier
- github.com/jmpsec/osctrl/logging
- github.com/joaothallis/franz-go-getting-started
- github.com/kameshsampath/rp-registry-demo/pkg/commands
- github.com/khulnasoft/kengine/deepfence_utils/utils
- github.com/khulnasoft/kengine/khulnasoft_server
- github.com/khulnasoft/kengine/khulnasoft_server/handler
- github.com/khulnasoft/kengine/khulnasoft_server/ingesters
- github.com/khulnasoft/kengine/khulnasoft_server/router
- github.com/khulnasoft/kengine/khulnasoft_utils/utils
- github.com/kloudlite/operator/pkg/redpanda
- github.com/krivenkov/pkg/bus/franz
- github.com/larsenpanda/rogue-examples
- github.com/lkumarjain/benchmark/kafka-client/franz
- github.com/lolizeppelin/micro/broker
- github.com/mdhwk/terraform-provider-kafka/internal/provider/client
- github.com/nehal119/benthos-119/pkg/impl/kafka
- github.com/nibbleshift/blobfish/impl/kafka
- github.com/nusa-exchange/pkg/services
- github.com/obaydullahmhs/kafka-client-go/franz-go
- github.com/orbservability/io/pkg/kafka
- github.com/pachecoio/chat-room-go
- github.com/patyukin/mbs-pkg/pkg/kafka
- github.com/perbu/kafkatail
- github.com/perbu/mkafka
- github.com/perbu/pkafka
- github.com/perfectbuii/event-simulator/internal/kafka
- github.com/peter-evans/kdef/core/client
- github.com/petshop-system/petshop-api/adapter/input/message/stream
- github.com/pianzm/kafka-redpanda/cmd/consumer
- github.com/poletaev-v/go-kafka
- github.com/presnalex/go-micro/v3/service
- github.com/ragul28/redpanda-go-sample
- github.com/rchnmy/xupery/pkg/controller
- github.com/redpanda-data/console/backend/pkg/api
- github.com/redpanda-data/console/backend/pkg/api/connect/service/console
- github.com/redpanda-data/console/backend/pkg/console
- github.com/redpanda-data/console/backend/pkg/kafka
- github.com/redpanda-data/console/backend/pkg/serde
- github.com/redpanda-data/console/backend/pkg/testutil
- github.com/redpanda-data/helm-charts/pkg/redpanda
- github.com/redpanda-data/redpanda-operator/acceptance/steps
- github.com/redpanda-data/redpanda-operator/operator/internal/controller/redpanda
- github.com/redpanda-data/redpanda-operator/operator/pkg/client
- github.com/redpanda-data/redpanda-operator/operator/pkg/client/acls
- github.com/redpanda-data/redpanda-operator/operator/pkg/console
- github.com/redpanda-data/redpanda-operator/src/go/k8s/internal/controller/redpanda
- github.com/redpanda-data/redpanda-operator/src/go/k8s/pkg/client
- github.com/redpanda-data/redpanda-operator/src/go/k8s/pkg/client/acls
- github.com/redpanda-data/redpanda-operator/src/go/k8s/pkg/console
- github.com/redpanda-data/redpanda/src/go/k8s/internal/controller/cluster.redpanda.com
- github.com/redpanda-data/redpanda/src/go/k8s/pkg/console
- github.com/redpanda-data/redpanda/src/go/rpk/pkg/cli/container
- github.com/redpanda-data/redpanda/src/go/rpk/pkg/cli/debug/bundle
- github.com/redpanda-data/redpanda/src/go/rpk/pkg/cli/generate
- github.com/redpanda-data/redpanda/src/go/rpk/pkg/cli/topic
- github.com/redpanda-data/redpanda/src/go/rpk/pkg/cli/transform
- github.com/redpanda-data/redpanda/src/go/rpk/pkg/kafka
- github.com/remiges-tech/logharbour/examples/tmp
- github.com/retail-store-saas/checkout
- github.com/sassoftware/event-provenance-registry/pkg/watcher
- github.com/shinhagunn/websocket/pkg/routing
- github.com/silverton-io/buz/pkg/backend/kafka
- github.com/svetsrebrev/tms/internal/queue
- github.com/swytman/jp-kafka
- github.com/teamseodo/kafka-do
- github.com/temoon/telegram-bots/handlers
- github.com/testcontainers/workshop-go/internal/streams
- github.com/triggermesh/brokers/pkg/backend/impl/kafka
- github.com/twmb/franz-go/pkg/kadm
- github.com/twmb/franz-go/plugin/kgmetrics
- github.com/twmb/franz-go/plugin/klogr
- github.com/twmb/franz-go/plugin/klogrus
- github.com/twmb/franz-go/plugin/kotel
- github.com/twmb/franz-go/plugin/kphuslog
- github.com/twmb/franz-go/plugin/kprom
- github.com/twmb/franz-go/plugin/kslog
- github.com/twmb/franz-go/plugin/kzap
- github.com/twmb/franz-go/plugin/kzerolog
- github.com/ujunglangit-id/redpanda-consumer-failover/internal/consumer
- github.com/unistack-org/micro-examples/pubsub
- github.com/utilitywarehouse/data-infra-benthos/v4/internal/impl/kafka
- github.com/vipcxj/conference.go/signal
- github.com/vtolstov/mc-go-fns-service
- github.com/wangqinghuan/franz-go/examples/requesting
- github.com/wesley601/kafka-notify/pkg/kafka
- github.com/wildster/go-utils
- github.com/yoratyo/go-redpanda/kafka
- github.com/zamkot/bus
- github.com/zerodha/kaf-relay/internal/relay
- github.com/zhiminwen/waiops
- gitlab.4lapy.ru/4lapy-shared/go-kafka/v2
- gitlab.com/dwagin/go-utils/kafka
- gitlab.com/miatel/go/utils/kafka
- gitlab.com/nguyenvhoang99/common-go-pkg/pkg/broker/kafka
- gitlab.com/prettytechnical-tools/bus/franz
- gitlab.forterro.com/it-operations-public/libraries/golang/producer-librairies
- gitlab.k8s-it.common.forterro.com/it-operations-public/libraries/golang/producer-librairies
- go.flipt.io/flipt/internal/server/audit/kafka