pkg.gl

Categorygithub.com/confluentinc/confluent-kafka-go/v2kafka

package

2.8.0

Repository: https://github.com/confluentinc/confluent-kafka-go.git

Documentation: pkg.go.dev

github.com/pingcap/tiflow/cmd/kafka-consumer

github.com/shawnwy/go-utils/v5/stream/sinks

github.com/shawnwy/go-utils/v5/stream/sources

github.com/confluentinc/cli/v4/internal/asyncapi

github.com/confluentinc/cli/v4/internal/kafka

github.com/confluentinc/cli/v4/internal/local

github.com/topfreegames/pusher/interfaces

github.com/topfreegames/pusher/extensions

github.com/topfreegames/pusher/feedback

github.com/topfreegames/pusher/mocks

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

github.com/zalbiraw/go-api-test-service/services/kafka/notifications

github.com/seldonio/seldon-core/scheduler/v2/pkg/kafka/gateway

github.com/seldonio/seldon-core/scheduler/v2/pkg/kafka/pipeline

github.com/seldonio/seldon-core/operator/v2/pkg/cli

github.com/seldonio/seldon-core/scheduler/v2/pkg/kafka/config

github.com/confluentinc/confluent-kafka-go/v2/kafka/go_rdkafka_generr

github.com/yaperos/confluent-kafka-go/v2/kafka/go_rdkafka_generr

github.com/flachnetz/startup/v2/lib/events

github.com/flachnetz/startup/v2/startup_events

github.com/flachnetz/startup/v2/startup_kafka

github.com/bro-n-bro/spacebox-crawler/v2/delivery/broker

github.com/gojekfarm/ziggurat/v2/kafka

github.com/zillow/zkafka/v2

github.com/zillow/zkafka/v2/mocks/confluent

github.com/devlibx/gox-messaging/v2/example

github.com/devlibx/gox-messaging/v2/kafka

github.com/devlibx/gox-messaging/v2

github.com/jkratz55/kefka/v2

github.com/jkratz55/kefka/v2/examples/reader

github.com/jkratz55/kefka/v2/examples/producer

github.com/jkratz55/kefka/v2/examples/consumer

github.com/jkratz55/kefka/v2/examples/producer-consumer

gopkg.in/DataDog/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka.v2

github.com/Vonage/gosrvlib/pkg/kafkacgo

github.com/skapfer/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka.v2

github.com/nowfred/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka.v2

github.com/openreplay/openreplay/ee/backend/pkg/kafka

github.com/superblocksteam/agent/pkg/kafka/producer

github.com/superblocksteam/agent/pkg/kafka/consumer

github.com/superblocksteam/agent/internal/kafka

github.com/superblocksteam/agent/pkg/kafka

github.com/superblocksteam/agent/pkg/kafka/consumer/fx

github.com/opengovern/og-util/pkg/dockertest

github.com/bdpiprava/testkit/kitkafka

github.com/bdpiprava/testkit

github.com/gojekfarm/ziggurat/kafka

github.com/metadb-project/metadb/cmd/metadb/server

github.com/metadb-project/metadb/cmd/metadb/change

github.com/metadb-project/metadb/cmd/metadb/util

github.com/adevinta/vulcan-api/pkg/testutil

github.com/adevinta/vulcan-api/pkg/asyncapi/kafka

github.com/wikimedia-enterprise/health-checker/health

github.com/tommzn/hdb-message-client

github.com/zillow/zkafka

github.com/zillow/zkafka/mocks/confluent

github.com/go-yaaf/yaaf-common-kafka/kafka

github.com/matrixorigin/matrixone/pkg/stream/adapter/kafka

github.com/matrixorigin/matrixone/pkg/stream/connector

github.com/matrixorigin/matrixone/pkg/vm/process

github.com/matrixorigin/matrixone/pkg/frontend

github.com/bro-n-bro/spacebox-crawler/delivery/broker

github.com/angusgyoung/gox/internal/operator

github.com/ZMS-DevOps/search-service/infrastructure/api

github.com/ZMS-DevOps/search-service

github.com/romanchechyotkin/car_booking_service/internal/car/producer

github.com/etf1/opentelemetry-go-contrib/instrumentation/github.com/confluentinc/confluent-kafka-go/otelconfluent/internal

github.com/etf1/opentelemetry-go-contrib/instrumentation/github.com/confluentinc/confluent-kafka-go/otelconfluent

github.com/ZMS-DevOps/booking-service

github.com/ZMS-DevOps/booking-service/startup

github.com/ZMS-DevOps/booking-service/application

github.com/solum-sp/aps-be-common/common/event

github.com/exgamer/gosdk/pkg/kafkahelper

github.com/exgamer/gosdk/pkg/kafkahelper/messenger

github.com/Ptsecuritydit/libs/mq

github.com/kiga-hub/arc/kafka

github.com/engpap/kafka-wrapper-go/pkg

github.com/sing3demons/kp/examples

github.com/openmeterio/openmeter/cmd/server

github.com/openmeterio/openmeter/config

github.com/openmeterio/openmeter/openmeter/sink/models

github.com/xgodev/boost/factory/contrib/confluentinc/confluent-kafka-go/v2/examples/producer

github.com/xgodev/boost/factory/contrib/confluentinc/confluent-kafka-go/v2/examples/consumer

github.com/realmicro/realmicro/broker/kafka/confluentkafka

github.com/openmeterio/openmeter/pkg/kafka

github.com/openmeterio/openmeter/cmd/sink-worker

github.com/openmeterio/openmeter/openmeter/sink

github.com/rodrigorodrigues/opentelemetry-go-contrib/instrumentation/github.com/confluentinc/confluent-kafka-go/otelconfluent/internal

github.com/rodrigorodrigues/opentelemetry-go-contrib/instrumentation/github.com/confluentinc/confluent-kafka-go/otelconfluent

github.com/0angelic0/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka.v2

github.com/DenisBytes/GoToll/data_receiver

github.com/DenisBytes/GoToll/distance_calculator

github.com/xgodev/boost/factory/contrib/confluentinc/confluent-kafka-go/v2

github.com/openmeterio/openmeter/openmeter/ingest/kafkaingest

github.com/xgodev/boost/bootstrap/function/adapter/contrib/confluentinc/confluent-kafka-go/v2

github.com/xgodev/boost/wrapper/publisher/driver/contrib/confluentinc/confluent-kafka-go/v2

github.com/openmeterio/openmeter/openmeter/watermill/driver/kafka

github.com/rilldata/rill/runtime/pkg/activity

github.com/arquivei/goduck/middleware/dlqmiddleware

github.com/arquivei/goduck/pipeline/inputstreams

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

github.com/arquivei/goduck/pipeline/kafkasink

github.com/softwok/confluent-kafka-util-go/kafkautil

github.com/gojekfarm/xtools/xkafka

github.com/gojekfarm/xtools/examples/riverkfq

github.com/zpiroux/geist-connector-kafka/gkafka/internal/gki

github.com/zpiroux/geist-connector-kafka/ikafka

github.com/daffarg/distributed-cascading-cb/broker/kafka

github.com/shubhang93/propel/record

github.com/shubhang93/propel/conflgo

github.com/shubhang93/propel/internal/batchpoll

github.com/shubhang93/propel/internal/confluent

github.com/shubhang93/propel/throttled

github.com/shubhang93/propel/batch

github.com/bro-n-bro/spacebox-crawler/delivery/broker

github.com/grepplabs/mqtt-proxy/pkg/publisher/kafka

github.com/openreplay/openreplay/ee/backend/pkg/kafka

github.com/grepplabs/mqtt-proxy/pkg/config

github.com/etf1/kafka-mongo-watcher/internal/kafka

github.com/etf1/kafka-mongo-watcher/internal/service

github.com/port-labs/port-k8s-exporter/pkg/event_handler/consumer

github.com/St3plox/Blogchain/business/web/broker/consumer

github.com/St3plox/Blogchain/business/web/broker/producer

github.com/St3plox/Blogchain/app/backend/user-service

github.com/goplugin/plugin-common/pkg/monitoring

github.com/jrnd-io/jr/pkg/producers/kafka

github.com/teslamotors/fleet-telemetry/config

github.com/teslamotors/fleet-telemetry/datastore/kafka

github.com/mustafatheconqueror/karaca-kafka

github.com/realmicro/realmicro/broker/kafka/confluentkafka

github.com/alebabai/go-kafka/adapter/confluent

github.com/tcarland/tca-kafka-go/kafka

microcks.io/testcontainers-go/internal/test

github.com/openmeterio/openmeter

github.com/sqlpub/qin-cdc/outputs/kafka

github.com/openmeterio/openmeter/internal/ingest/kafkaingest

github.com/smartcontractkit/chainlink-common/pkg/monitoring

github.com/GPA-Gruppo-Progetti-Avanzati-SRL/tpm-kafka-common/tprod

github.com/GPA-Gruppo-Progetti-Avanzati-SRL/tpm-kafka-common/kafkalks

github.com/GPA-Gruppo-Progetti-Avanzati-SRL/tpm-kafka-common/tprod/processor/reworkdlt

github.com/blugnu/kafka/internal/mock

github.com/blugnu/kafka

github.com/blugnu/kafka/message

github.com/mcgillowen/arkime-kafka-indexer/kafka

github.com/pianoyeg94/go-kafka-queue

github.com/DavidSie/notification-service/notifications-request-producer

github.com/DavidSie/notification-service/notifications-server

github.com/DavidSie/notification-service/pkg/model

github.com/exgamer/go-sdk/pkg/kafka

github.com/exgamer/go-sdk/pkg/kafka/messenger

github.com/rimdesk/rimbus-go/rimbus

github.com/GPA-Gruppo-Progetti-Avanzati-SRL/tpm-http-kafka-har/kafkahartracer

github.com/bernardomoraes/delivery-tracking/infra/kafka

github.com/bernardomoraes/delivery-tracking

github.com/bernardomoraes/delivery-tracking/application/kafka

github.com/vlab-research/spine

github.com/nosuchperson/gpipe/plugins/kafka

github.com/devlibx/gox-messaging/kafka

github.com/devlibx/gox-messaging

github.com/devlibx/gox-messaging/example

github.com/GPA-Gruppo-Progetti-Avanzati-SRL/tpm-chorus/reporter

github.com/AndriyKalashnykov/go-kafka-confluent-examples/producer

github.com/AndriyKalashnykov/go-kafka-confluent-examples/consumer

github.com/AndriyKalashnykov/go-kafka-confluent-examples/internal/util

github.com/aide-family/moon/pkg/util/interflow/mq

github.com/aide-family/moon/pkg/servers

github.com/aide-family/moon/pkg/conn

github.com/etf1/kafka-transformer/internal/test

github.com/etf1/kafka-message-scheduler/clientlib

github.com/etf1/kafka-message-scheduler/config

github.com/etf1/kafka-message-scheduler/internal/test

github.com/etf1/kafka-message-scheduler/runner/kafka

github.com/etf1/kafka-message-scheduler/schedule/kafka

github.com/etf1/kafka-transformer/pkg/instrument

github.com/etf1/kafka-transformer/internal/instrument

github.com/etf1/kafka-transformer/pkg/transformer

github.com/etf1/kafka-message-scheduler/store/kafka

github.com/etf1/kafka-transformer/instrumentation/otel/internal

github.com/etf1/kafka-transformer/internal/transformer

github.com/etf1/kafka-transformer/instrumentation/otel

github.com/etf1/kafka-transformer/pkg/transformer/kafka

github.com/etf1/kafka-transformer/internal/transformer/kafka

github.com/gsantosc18/todo/internal/todo/message

github.com/vordimous/gohlay/configs

github.com/vordimous/gohlay/internal

github.com/vordimous/gohlay/pkg/deliver

github.com/vordimous/gohlay/pkg/find

github.com/vordimous/gohlay/internal/kafkautil

github.com/wisemonkeys-co/ocs-messaging/consumer

github.com/wisemonkeys-co/ocs-messaging/test-utils

github.com/wisemonkeys-co/ocs-messaging/log-handler

github.com/wisemonkeys-co/ocs-messaging/utils

github.com/wisemonkeys-co/ocs-messaging/producer

github.com/flash-vision/kafka-message-wranglers

github.com/ikaushiksharma/toll-calculator/distance_calculator

github.com/djedjethai/gokfk-regent/examples/confluent/avro

github.com/djedjethai/gokfk-regent/examples/confluent/json

github.com/djedjethai/gokfk-regent/examples/confluent/protobuf

github.com/sdhfyvyv/dbandpubsub/tests/consumer

github.com/Informasjonsforvaltning/fdk-resource-service/kafka

github.com/shariqali-dev/toll-calculator/cmd/distance_calculator

github.com/shariqali-dev/toll-calculator/cmd/reciever

github.com/caiflower/common-tools/kafka/v1

github.com/leyle/dbandpubsub/kafkaconnector

github.com/leyle/dbandpubsub/tests/consumer

github.com/redhatinsights/ros-ocp-backend/internal/kafka

github.com/redhatinsights/ros-ocp-backend/internal/services

github.com/kyawkyawsoezhu/otelconfluent

github.com/kyawkyawsoezhu/otelconfluent/internal

github.com/kyawkyawsoezhu/otelkafka

github.com/zp857/goutil/kafkax

github.com/OpenDataTelemetry/device-gateway-mqtt

github.com/RuanScherer/journey-track-api/adapters/kafkaadptr

github.com/YungBenn/tech-shop-microservices/internal/kafka

github.com/YungBenn/tech-shop-microservices/internal/product/di

github.com/YungBenn/tech-shop-microservices/internal/search/message

github.com/stolostron/maestro-addon/pkg/helpers

github.com/stolostron/maestro-addon/pkg/mq

github.com/stolostron/maestro-addon/test/performance/pkg/hub/maestro/topics

github.com/Housiadas/backend-system/app/cmd/commands

github.com/spirit-labs/tektite/kafka

github.com/spirit-labs/tektite/integ

github.com/spirit-labs/tektite/perf

github.com/legocy-co/legocy/internal/pkg/kafka

github.com/microcks/microcks-testcontainers-go-demo/internal

github.com/microcks/microcks-testcontainers-go-demo/cmd

github.com/microcks/microcks-testcontainers-go-demo/internal/service

github.com/microcks/microcks-testcontainers-go-demo/cmd/run

github.com/dr4g0n7ly/AutoTariff-Service/data_receiver

github.com/dr4g0n7ly/AutoTariff-Service/distance_calculator

github.com/airunny/timer/pkg/ikafka

github.com/Fermekoo/orderin-api/mq

github.com/FerMusicComposer/toll-calculator/data-receiver/pkg

github.com/FerMusicComposer/toll-calculator/distance-calculator/pkg

github.com/GrigoryNazarov96/toll-calculator/data_receiver

github.com/GrigoryNazarov96/toll-calculator/distance_calculator

github.com/garfieldlw/NimbusIM/im.logic/internal/service/kafka

github.com/garfieldlw/NimbusIM/pusher/internal/service/kafka

github.com/garfieldlw/NimbusIM/im.logic/internal/model/dao/kafka-cli

github.com/Vladislav747/truck-toll-calculator/data_receiver/producer

github.com/AlexBlackNn/authloyalty/loyalty/pkg/tracing/otelconfluent/internal

github.com/AlexBlackNn/authloyalty/sso/pkg/tracing/otelconfluent/internal

github.com/imrishuroy/legal-referral-fanout-service/api

github.com/trenchesdeveloper/toll-calculator/data_receiver

github.com/trenchesdeveloper/toll-calculator/distance_calculator

github.com/agalue/nxos-telemetry-to-kafka-go

github.com/abdoroot/tolling/data_receiver

github.com/abdoroot/tolling/distance_calculator

github.com/jrnd-io/jrv2/pkg/plugin/local/kafka

github.com/vnnyx/real-time-data/internal/config

github.com/vnnyx/real-time-data/internal/gateway/messaging

github.com/vnnyx/real-time-data/internal/delivery/messaging

github.com/csams/common-inventory/pkg/eventing/kafka

github.com/Karzoug/meower-relation-service/internal/delivery/kafka

github.com/bobhonores/goexperiments/internal/kafka

github.com/bobhonores/goexperiments/cmd/kafka/consumer

github.com/bobhonores/goexperiments/cmd/kafka/producer

github.com/AwesomeXjs/kafka-prod-cons/internal/handler

github.com/AwesomeXjs/kafka-prod-cons/internal/kafka

github.com/chrisdamba/foodatasim/internal/simulator

github.com/chrisdamba/foodatasim/internal/simulator/producers

github.com/allnightmarel0Ng/employee-controller/internal/infrastructure/kafka

github.com/aitsvet/saga_example/internal/kafka

github.com/bicosteve/booking-system/pkg/utils

github.com/tuannkhoi/sport-data-feed/config

github.com/tuannkhoi/sport-data-feed/service

github.com/allnightmarel0Ng/albums/internal/infrastructure/kafka

github.com/perfectbuii/event-simulator/internal/kafka

github.com/yael-castro/outbox/internal/app/output/kafka

github.com/niudaii/goutil/kafkax

github.com/MingyangXiaTim/kafka-scheduler/config

github.com/MingyangXiaTim/kafka-scheduler/schedule/kafka

github.com/MingyangXiaTim/kafka-scheduler/internal/test

github.com/MingyangXiaTim/kafka-scheduler/store/kafka

github.com/MingyangXiaTim/kafka-scheduler/runner/kafka

github.com/jurabek/otelkafka

github.com/co-codin/toll-calculator/data_receiver

github.com/co-codin/toll-calculator/distance_calculator

github.com/Hhanri/toll_calculator/data_receiver

github.com/Hhanri/toll_calculator/distance_calculator

github.com/otto-de/sherlock-kafka-service/pkg/envflags

github.com/AugustoKlaic/golearningstack/pkg/queue

github.com/AugustoKlaic/golearningstack/pkg/configuration

github.com/bmviniciuss/sagas-golang/internal/streaming

github.com/bmviniciuss/sagas-golang/cmd/local/accounting

github.com/bmviniciuss/sagas-golang/cmd/local/customer

github.com/bmviniciuss/sagas-golang/cmd/local/order

github.com/bmviniciuss/sagas-golang/cmd/local/orchestrator

github.com/bmviniciuss/sagas-golang/cmd/local/accounting/handlers

github.com/bmviniciuss/sagas-golang/cmd/local/customer/handlers

github.com/burakolgun/gokafkashovel/producer

github.com/burakolgun/gokafkashovel/shovel

github.com/burakolgun/gokafkashovel/startup

github.com/burakolgun/gokafkashovel/utils/kafka_utils

github.com/nurbeknurjanov/go-gin-backend/pkg/kafka

github.com/samarthasthan/e-commerce/pkg/kafka

github.com/sdhfyvyv/dbandpubsub/kafkaconnector

github.com/target/strelka/src/go/cmd/strelka-frontend

github.com/AlexBlackNn/kafka-avro/avro-example/cmd/create-topic

github.com/AlexBlackNn/kafka-avro/avro-example/internal/broker/consumer

github.com/AlexBlackNn/kafka-avro/avro-example/internal/broker/producer

github.com/Hnamnguyen0112/cryptocurrency-forecasting-project/collector_ingestor/pkg/kafka

github.com/Hnamnguyen0112/cryptocurrency-forecasting-project/collector_ingestor/cmd/ingestor

github.com/anandaadam/search-service/config

github.com/Raideeen/DNS-Stream-Analyzer/consumer

github.com/Raideeen/DNS-Stream-Analyzer/server

github.com/posthog/livestream

github.com/ugurcancaykara/odd-service/rating/internal/ingester/kafka

github.com/ikaushiksharma/toll-calculator/data_receiver

github.com/allnightmarel0Ng/godex/internal/infrastructure/kafka

github.com/loongkirin/gdk/mq/kafka

github.com/allnightmarel0Ng/employee-controller/internal/app/container/handler

github.com/allnightmarel0Ng/employee-controller/internal/app/storage/handler

github.com/bicosteve/booking-system/controllers

github.com/AlexBlackNn/authloyalty/sso/pkg/tracing/otelconfluent

github.com/AlexBlackNn/authloyalty/loyalty/pkg/tracing/otelconfluent

github.com/wesleyfebarretos/ticket-sale/internal/akafka

github.com/AlexBlackNn/authloyalty/sso/docs/examples

github.com/AlexBlackNn/authloyalty/sso/pkg/broker

github.com/AlexBlackNn/authloyalty/loyalty/pkg/broker

github.com/popovds617/go_snippets/message_queues/kafka

github.com/Admiral-Simo/toll-calculator/data_receiver

github.com/Admiral-Simo/toll-calculator/distance_calculator

github.com/emmadal/feeti-module/stream

github.com/bytemoves/toll-calculator/data_reciever

github.com/Vladislav747/truck-toll-calculator/distance_calc/consumer

github.com/dafailyasa/golang-template/pkg/kafka/infrastructure/repositories

github.com/dafailyasa/golang-template/pkg/kafka/ports

github.com/rormartin/qet/pkg/kafka

github.com/rormartin/qet/examples/kafka_processor

github.com/rormartin/qet/examples/kafka_sender

github.com/AugustoKlaic/golearningstack/pkg/queue/apachekafka

github.com/project-kessel/inventory-api/internal/eventing/kafka

github.com/CaelRowley/geth-indexer-service/pkg/pubsub

github.com/qwallet-expense-tracker/shared/broker

github.com/Karzoug/meower-user-service/internal/delivery/kafka

github.com/romashorodok/stream-source/pkgs/consumer

github.com/egapay-core/shared/broker

github.com/egapay-core/shared/modules/money_transfer

github.com/DistributedPlayground/product-search/pkg/store

github.com/DistributedPlayground/product-search/pkg/message

github.com/EarnestScott/kafka-playground

github.com/Kale-Grabovski/impay/api/mock

github.com/Kale-Grabovski/impay/di

github.com/Kale-Grabovski/impay/kafka

github.com/Kale-Grabovski/gonah/src/service

github.com/khalid0306/Kafka_golang/collector_confluentKafka

github.com/khalid0306/Kafka_golang/stocker_confluentKafka

github.com/gadisamenu/tolling/data_receiver

github.com/gadisamenu/tolling/distance_calculator

github.com/jhlee7854/message-sender

github.com/Karzoug/meower-timeline-service/internal/delivery/kafka

github.com/64bitAryan/go-microservice/distance_calculator

github.com/Mohammadmohebi33/toll_calculator/data_receiver

github.com/Mohammadmohebi33/toll_calculator/distance_calculator

github.com/Hnamnguyen0112/cryptocurrency-forecasting-project/collector_ingestor/internal/ingestor

github.com/suzushin54/actor-based-inventory/pkg/kafka

github.com/mjmichael73/toll-calculator/data_receiver

github.com/mjmichael73/toll-calculator/distance_calculator

github.com/richardktran/go-movie-microservices/cmd/ratingingester

github.com/richardktran/go-movie-microservices/rating/internal/ingester/kafka

github.com/shubhang93/cdcingestor/internal/kafka

github.com/shubhang93/cdcingestor/internal/opensearch

github.com/suzushin54/actor-based-inventory/internal/infrastructure

github.com/spirit-labs/tektite/asl/scripttest

github.com/Housiadas/backend-system/foundation/kafka

github.com/stolostron/maestro-addon/pkg/helpers/mock

github.com/YungBenn/tech-shop-microservices/internal/product/message

github.com/YungBenn/tech-shop-microservices/cmd/product

github.com/willjrcom/sales-backend-go/internal/infra/service/kafka

github.com/wesleyburlani/go-observability/internal/ports/kafka

github.com/redhatinsights/ros-ocp-backend/internal/services/housekeeper

github.com/wesleyburlani/go-observability/internal/ports/kafka/handlers

github.com/kwstars/film-hive/pkg/event/kafka

github.com/greyerof/test-kafka

github.com/unsuman/go-microservices/data_receiver

github.com/unsuman/go-microservices/distance_calculator

github.com/kveriz/kfproxy/internal/client