//
pkg.gl
Category
github.com/confluentinc/confluent-kafka-go
kafka
package
1.9.3-RC3
Repository:
https://github.com/confluentinc/confluent-kafka-go.git
Documentation:
pkg.go.dev
Overview
Versions
2
Dependencies
2
Dependents
1.5k
Files
10 SLOC
github.com/itsjunglexyz/extensions/v9/kafka
github.com/itsjunglexyz/extensions/v9/kafka/interfaces
github.com/itsjunglexyz/extensions/v9/kafka/mocks
github.com/topfreegames/extensions/v9/kafka/mocks
github.com/topfreegames/extensions/v9/kafka/interfaces
github.com/topfreegames/extensions/v9/kafka
github.com/topfreegames/extensions/kafka/mocks
github.com/topfreegames/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/interfaces
github.com/itsjunglexyz/extensions/kafka/mocks
github.com/itsjunglexyz/extensions/kafka
github.com/lucbarr/extensions/kafka
github.com/lucbarr/extensions/kafka/mocks
github.com/lucbarr/extensions/kafka/interfaces
github.com/lucbarr/extensions/kafka
github.com/lucbarr/extensions/kafka/mocks
github.com/lucbarr/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka/mocks
github.com/itsjunglexyz/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/mocks
github.com/topfreegames/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka/mocks
github.com/topfreegames/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka
github.com/lucbarr/extensions/kafka/interfaces
github.com/lucbarr/extensions/kafka
github.com/itsjunglexyz/extensions/kafka
github.com/lucbarr/extensions/kafka/mocks
github.com/itsjunglexyz/extensions/kafka/interfaces
github.com/itsjunglexyz/extensions/kafka/mocks
github.com/topfreegames/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka
github.com/topfreegames/extensions/kafka/mocks
github.com/itsjunglexyz/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/mocks
github.com/lucbarr/extensions/kafka/interfaces
github.com/lucbarr/extensions/kafka
github.com/lucbarr/extensions/kafka/mocks
github.com/itsjunglexyz/extensions/kafka/interfaces
github.com/DataDog/kafka-kit/v4/kafkaadmin/stub
github.com/DataDog/kafka-kit/v4/registry/server
github.com/DataDog/kafka-kit/v4/kafkaadmin
github.com/lucbarr/extensions/kafka
github.com/lucbarr/extensions/kafka/mocks
github.com/lucbarr/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka
github.com/itsjunglexyz/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/interfaces
github.com/itsjunglexyz/extensions/kafka/mocks
github.com/topfreegames/extensions/kafka/mocks
github.com/topfreegames/extensions/kafka/interfaces
github.com/confluentinc/cli/v3/internal/asyncapi
github.com/confluentinc/cli/v3/internal/kafka
github.com/confluentinc/cli/v3/internal/local
github.com/DataDog/kafka-kit/v3/kafkaadmin/stub
github.com/DataDog/kafka-kit/v3/registry/server
github.com/DataDog/kafka-kit/v3/kafkaadmin
github.com/topfreegames/pusher/mocks
github.com/topfreegames/pusher/interfaces
github.com/topfreegames/pusher/extensions
github.com/topfreegames/pusher/feedback
github.com/topfreegames/marathon/interfaces
github.com/topfreegames/extensions/kafka
github.com/topfreegames/extensions/kafka/mocks
github.com/topfreegames/extensions/kafka/interfaces
github.com/lucbarr/extensions/kafka/interfaces
github.com/lucbarr/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/interfaces
github.com/itsjunglexyz/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/mocks
github.com/lucbarr/extensions/kafka/mocks
github.com/blendle/go-streamprocessor/v3/streamconfig
github.com/blendle/go-streamprocessor/v3/streamclient/kafkaclient
github.com/blendle/go-streamprocessor/v3/streamconfig/kafkaconfig
github.com/velann21/todo-commonlib/async_jobs
github.com/confluentinc/cli/internal/cmd/kafka
github.com/confluentinc/cli/internal/cmd/asyncapi
github.com/topfreegames/extensions/kafka/interfaces
github.com/topfreegames/extensions/kafka/mocks
github.com/itsjunglexyz/extensions/kafka
github.com/topfreegames/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/interfaces
github.com/lucbarr/extensions/kafka/interfaces
github.com/lucbarr/extensions/kafka
github.com/itsjunglexyz/extensions/kafka/mocks
github.com/lucbarr/extensions/kafka/mocks
github.com/milvus-io/milvus/pkg/v2/mq/msgstream
github.com/milvus-io/milvus/pkg/v2/mq/msgstream/mqwrapper/kafka
github.com/velann21/todo-commonlib/async_jobs
github.com/blendle/go-streamprocessor/streamclient/kafkaclient
github.com/topfreegames/marathon/extensions
github.com/topfreegames/marathon/interfaces
github.com/blendle/go-streamprocessor/streamconfig/kafkaconfig
github.com/blendle/go-streamprocessor/streamconfig
github.com/topfreegames/pusher/mocks
github.com/topfreegames/pusher/interfaces
github.com/erda-project/erda/internal/tools/monitor/core/storekit/kafka/topic/initializer
github.com/topfreegames/pusher/extensions
github.com/thiagotilid/goframework
github.com/sabariramc/goserverbase/v2/errors/notifier/kafka
github.com/sabariramc/goserverbase/v2/kafka
github.com/alrusov/kafka/v2
github.com/gmbyapa/kstream/v2/kafka/adaptors/librd
github.com/gmbyapa/kstream/v2/kafka/mocks
github.com/MyBudgetPtyLtd/kstream/v2/kafka/adaptors/librd
github.com/MyBudgetPtyLtd/kstream/v2/kafka/mocks
github.com/Cray-HPE/hms-trs-kafkalib/v2/Test
github.com/Cray-HPE/hms-trs-kafkalib/v2/pkg/trs-kafkalib
github.com/milindl/confluent-kafka-go/v2/kafka/go_rdkafka_generr
github.com/Cray-HPE/hms-trs-app-api/v2/pkg/trs_http_api
gopkg.in/DataDog/dd-trace-go.v1/contrib/confluentinc/confluent-kafka-go/kafka
github.com/thiagotilid/goframework
github.com/skapfer/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/nowfred/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/lannguyen-c0x12c/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/tl-framework/goframework
github.com/suiguo/hwlib/kafka
github.com/liquidm/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/gihyunk/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/KoddiDev/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/velann21/todo-commonlib/async_jobs
github.com/carwale/golibraries/kafka
github.com/cwaeland/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/signalfx/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
github.com/Cray-HPE/hms-msgbus
github.com/confluentinc/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/asiragusa/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/intfish123/confluent-kafka-go/soaktest/soakclient_transaction
github.com/intfish123/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/intfish123/confluent-kafka-go/soaktest/soakclient
github.com/intfish123/confluent-kafka-go/examples/admin_create_topic
github.com/intfish123/confluent-kafka-go/soaktest
github.com/intfish123/confluent-kafka-go/examples/admin_describe_config
github.com/intfish123/confluent-kafka-go/examples/confluent_cloud_example
github.com/intfish123/confluent-kafka-go/examples/consumer_channel_example
github.com/intfish123/confluent-kafka-go/examples/transactions_example
github.com/intfish123/confluent-kafka-go/examples/consumer_example
github.com/intfish123/confluent-kafka-go/examples/consumer_offset_metadata
github.com/intfish123/confluent-kafka-go/examples/cooperative_consumer_example
github.com/intfish123/confluent-kafka-go/examples/go-kafkacat
github.com/intfish123/confluent-kafka-go/examples/idempotent_producer_example
github.com/intfish123/confluent-kafka-go/examples/library-version
github.com/intfish123/confluent-kafka-go/examples/oauthbearer_example
github.com/intfish123/confluent-kafka-go/examples/producer_channel_example
github.com/intfish123/confluent-kafka-go/examples/producer_example
github.com/intfish123/confluent-kafka-go/examples/stats_example
github.com/intfish123/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/intfish123/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/intfish123/confluent-kafka-go/examples/admin_delete_topics
github.com/starius/confluent-kafka-go/examples/stats_example
github.com/sourcefellows/confluent-kafka-go/soaktest
github.com/sourcefellows/confluent-kafka-go/examples/admin_create_topic
github.com/sourcefellows/confluent-kafka-go/examples/admin_delete_topics
github.com/sourcefellows/confluent-kafka-go/examples/admin_describe_config
github.com/sourcefellows/confluent-kafka-go/examples/confluent_cloud_example
github.com/sourcefellows/confluent-kafka-go/examples/consumer_channel_example
github.com/sourcefellows/confluent-kafka-go/examples/consumer_example
github.com/sourcefellows/confluent-kafka-go/examples/consumer_offset_metadata
github.com/sourcefellows/confluent-kafka-go/examples/cooperative_consumer_example
github.com/sourcefellows/confluent-kafka-go/examples/go-kafkacat
github.com/sourcefellows/confluent-kafka-go/examples/idempotent_producer_example
github.com/sourcefellows/confluent-kafka-go/examples/library-version
github.com/sourcefellows/confluent-kafka-go/examples/oauthbearer_example
github.com/sourcefellows/confluent-kafka-go/examples/producer_channel_example
github.com/sourcefellows/confluent-kafka-go/examples/producer_example
github.com/sourcefellows/confluent-kafka-go/examples/stats_example
github.com/sourcefellows/confluent-kafka-go/examples/transactions_example
github.com/sourcefellows/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/sourcefellows/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/starius/confluent-kafka-go/soaktest
github.com/starius/confluent-kafka-go/examples/admin_create_topic
github.com/starius/confluent-kafka-go/examples/admin_delete_topics
github.com/starius/confluent-kafka-go/examples/admin_describe_config
github.com/starius/confluent-kafka-go/examples/confluent_cloud_example
github.com/starius/confluent-kafka-go/examples/consumer_channel_example
github.com/starius/confluent-kafka-go/examples/consumer_example
github.com/starius/confluent-kafka-go/examples/consumer_offset_metadata
github.com/starius/confluent-kafka-go/examples/cooperative_consumer_example
github.com/starius/confluent-kafka-go/examples/go-kafkacat
github.com/starius/confluent-kafka-go/examples/idempotent_producer_example
github.com/starius/confluent-kafka-go/examples/library-version
github.com/starius/confluent-kafka-go/examples/oauthbearer_example
github.com/starius/confluent-kafka-go/examples/producer_channel_example
github.com/starius/confluent-kafka-go/examples/producer_example
github.com/starius/confluent-kafka-go/examples/transactions_example
github.com/starius/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/starius/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/sourcefellows/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/steveruckdashel/confluent-kafka-go/soaktest/soakclient_transaction
github.com/steveruckdashel/confluent-kafka-go/soaktest/soakclient
github.com/steveruckdashel/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/steveruckdashel/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/steveruckdashel/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/steveruckdashel/confluent-kafka-go/examples/transactions_example
github.com/steveruckdashel/confluent-kafka-go/examples/stats_example
github.com/steveruckdashel/confluent-kafka-go/examples/producer_example
github.com/steveruckdashel/confluent-kafka-go/examples/producer_channel_example
github.com/steveruckdashel/confluent-kafka-go/examples/oauthbearer_example
github.com/steveruckdashel/confluent-kafka-go/examples/library-version
github.com/steveruckdashel/confluent-kafka-go/examples/idempotent_producer_example
github.com/steveruckdashel/confluent-kafka-go/examples/go-kafkacat
github.com/steveruckdashel/confluent-kafka-go/examples/cooperative_consumer_example
github.com/steveruckdashel/confluent-kafka-go/examples/consumer_offset_metadata
github.com/steveruckdashel/confluent-kafka-go/examples/consumer_example
github.com/steveruckdashel/confluent-kafka-go/examples/consumer_channel_example
github.com/steveruckdashel/confluent-kafka-go/examples/confluent_cloud_example
github.com/steveruckdashel/confluent-kafka-go/examples/admin_describe_config
github.com/steveruckdashel/confluent-kafka-go/examples/admin_delete_topics
github.com/steveruckdashel/confluent-kafka-go/examples/admin_create_topic
github.com/steveruckdashel/confluent-kafka-go/soaktest
github.com/starius/confluent-kafka-go/soaktest/soakclient_transaction
github.com/starius/confluent-kafka-go/soaktest/soakclient
github.com/starius/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/sourcefellows/confluent-kafka-go/soaktest/soakclient_transaction
github.com/sourcefellows/confluent-kafka-go/soaktest/soakclient
github.com/entropyx/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/devotedhealth/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/imperiuse/golib/kafka/confluent
github.com/imperiuse/golib/kafka/confluent/consumer
github.com/imperiuse/golib/kafka/confluent/producer
github.com/nbwoodward/confluent-kafka-go/soaktest/soakclient_transaction
github.com/nbwoodward/confluent-kafka-go/examples/admin_describe_config
github.com/nbwoodward/confluent-kafka-go/soaktest/soakclient
github.com/nbwoodward/confluent-kafka-go/examples/confluent_cloud_example
github.com/nbwoodward/confluent-kafka-go/examples/admin_delete_topics
github.com/nbwoodward/confluent-kafka-go/examples/consumer_channel_example
github.com/nbwoodward/confluent-kafka-go/examples/consumer_example
github.com/nbwoodward/confluent-kafka-go/examples/consumer_offset_metadata
github.com/nbwoodward/confluent-kafka-go/examples/cooperative_consumer_example
github.com/nbwoodward/confluent-kafka-go/examples/go-kafkacat
github.com/nbwoodward/confluent-kafka-go/examples/idempotent_producer_example
github.com/nbwoodward/confluent-kafka-go/examples/library-version
github.com/nbwoodward/confluent-kafka-go/examples/oauthbearer_example
github.com/nbwoodward/confluent-kafka-go/examples/producer_channel_example
github.com/nbwoodward/confluent-kafka-go/examples/producer_example
github.com/nbwoodward/confluent-kafka-go/examples/stats_example
github.com/nbwoodward/confluent-kafka-go/examples/transactions_example
github.com/nbwoodward/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/nbwoodward/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/nbwoodward/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/nbwoodward/confluent-kafka-go/soaktest
github.com/nbwoodward/confluent-kafka-go/examples/admin_create_topic
github.com/kkhaike/confluent-kafka-go/examples/transactions_example
github.com/kkhaike/confluent-kafka-go/examples/stats_example
github.com/kkhaike/confluent-kafka-go/examples/producer_example
github.com/kkhaike/confluent-kafka-go/examples/producer_channel_example
github.com/kkhaike/confluent-kafka-go/examples/oauthbearer_example
github.com/kkhaike/confluent-kafka-go/examples/library-version
github.com/kkhaike/confluent-kafka-go/examples/idempotent_producer_example
github.com/kkhaike/confluent-kafka-go/examples/go-kafkacat
github.com/kkhaike/confluent-kafka-go/examples/cooperative_consumer_example
github.com/kkhaike/confluent-kafka-go/examples/consumer_offset_metadata
github.com/kkhaike/confluent-kafka-go/examples/consumer_example
github.com/kkhaike/confluent-kafka-go/examples/consumer_channel_example
github.com/kkhaike/confluent-kafka-go/examples/confluent_cloud_example
github.com/kkhaike/confluent-kafka-go/examples/admin_describe_config
github.com/kkhaike/confluent-kafka-go/examples/admin_delete_topics
github.com/kkhaike/confluent-kafka-go/examples/admin_create_topic
github.com/kkhaike/confluent-kafka-go/soaktest
github.com/kkhaike/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/kkhaike/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/kkhaike/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/kkhaike/confluent-kafka-go/soaktest/soakclient_transaction
github.com/kkhaike/confluent-kafka-go/soaktest/soakclient
github.com/colivi/confluent-kafka-go/examples/producer_channel_example
github.com/colivi/confluent-kafka-go/examples/producer_example
github.com/colivi/confluent-kafka-go/examples/stats_example
github.com/colivi/confluent-kafka-go/examples/transactions_example
github.com/colivi/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/colivi/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/colivi/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/finncolman/confluent-kafka-go/examples/admin_create_topic
github.com/hexa00/confluent-kafka-go/examples/producer_channel_example
github.com/colivi/confluent-kafka-go/examples/consumer_channel_example
github.com/colivi/confluent-kafka-go/examples/consumer_example
github.com/colivi/confluent-kafka-go/examples/consumer_offset_metadata
github.com/colivi/confluent-kafka-go/examples/cooperative_consumer_example
github.com/colivi/confluent-kafka-go/examples/go-kafkacat
github.com/colivi/confluent-kafka-go/examples/idempotent_producer_example
github.com/colivi/confluent-kafka-go/examples/library-version
github.com/colivi/confluent-kafka-go/examples/oauthbearer_example
github.com/hexa00/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/hexa00/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/hexa00/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/hexa00/confluent-kafka-go/examples/oauthbearer_example
github.com/nguyencuong382/go-message-router/mkafka
github.com/hexa00/confluent-kafka-go/examples/consumer_example
github.com/hexa00/confluent-kafka-go/examples/consumer_offset_metadata
github.com/hexa00/confluent-kafka-go/examples/cooperative_consumer_example
github.com/hexa00/confluent-kafka-go/examples/go-kafkacat
github.com/hexa00/confluent-kafka-go/examples/idempotent_producer_example
github.com/hexa00/confluent-kafka-go/examples/library-version
github.com/finncolman/confluent-kafka-go/examples/producer_example
github.com/finncolman/confluent-kafka-go/examples/producer_channel_example
github.com/finncolman/confluent-kafka-go/examples/oauthbearer_example
github.com/finncolman/confluent-kafka-go/examples/library-version
github.com/finncolman/confluent-kafka-go/examples/idempotent_producer_example
github.com/finncolman/confluent-kafka-go/examples/go-kafkacat
github.com/finncolman/confluent-kafka-go/examples/cooperative_consumer_example
github.com/finncolman/confluent-kafka-go/examples/consumer_offset_metadata
github.com/finncolman/confluent-kafka-go/examples/stats_example
github.com/finncolman/confluent-kafka-go/examples/transactions_example
github.com/finncolman/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/finncolman/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/hexa00/confluent-kafka-go/examples/transactions_example
github.com/hexa00/confluent-kafka-go/examples/stats_example
github.com/hexa00/confluent-kafka-go/examples/producer_example
github.com/finncolman/confluent-kafka-go/examples/consumer_example
github.com/finncolman/confluent-kafka-go/examples/consumer_channel_example
github.com/finncolman/confluent-kafka-go/examples/confluent_cloud_example
github.com/finncolman/confluent-kafka-go/examples/admin_describe_config
github.com/finncolman/confluent-kafka-go/examples/admin_delete_topics
github.com/alistairking/confluent-kafka-go/examples/go-kafkacat
github.com/finncolman/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/alistairking/confluent-kafka-go/examples/admin_create_topic
github.com/alistairking/confluent-kafka-go/examples/admin_delete_topics
github.com/alistairking/confluent-kafka-go/examples/admin_describe_config
github.com/alistairking/confluent-kafka-go/examples/confluent_cloud_example
github.com/alistairking/confluent-kafka-go/examples/consumer_channel_example
github.com/alistairking/confluent-kafka-go/examples/consumer_example
github.com/alistairking/confluent-kafka-go/examples/consumer_offset_metadata
github.com/alistairking/confluent-kafka-go/examples/cooperative_consumer_example
github.com/alistairking/confluent-kafka-go/examples/idempotent_producer_example
github.com/alistairking/confluent-kafka-go/examples/library-version
github.com/alistairking/confluent-kafka-go/examples/oauthbearer_example
github.com/alistairking/confluent-kafka-go/examples/producer_channel_example
github.com/alistairking/confluent-kafka-go/examples/producer_example
github.com/alistairking/confluent-kafka-go/examples/stats_example
github.com/alistairking/confluent-kafka-go/examples/transactions_example
github.com/alistairking/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/alistairking/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/alistairking/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/hexa00/confluent-kafka-go/examples/admin_create_topic
github.com/hexa00/confluent-kafka-go/examples/admin_delete_topics
github.com/hexa00/confluent-kafka-go/examples/admin_describe_config
github.com/hexa00/confluent-kafka-go/examples/confluent_cloud_example
github.com/hexa00/confluent-kafka-go/examples/consumer_channel_example
github.com/alkoenig09/confluent-kafka-go/examples/admin_create_topic
github.com/alkoenig09/confluent-kafka-go/examples/admin_delete_topics
github.com/alkoenig09/confluent-kafka-go/examples/admin_describe_config
github.com/alkoenig09/confluent-kafka-go/examples/confluent_cloud_example
github.com/alkoenig09/confluent-kafka-go/examples/consumer_channel_example
github.com/alkoenig09/confluent-kafka-go/examples/consumer_example
github.com/alkoenig09/confluent-kafka-go/examples/consumer_offset_metadata
github.com/alkoenig09/confluent-kafka-go/examples/cooperative_consumer_example
github.com/alkoenig09/confluent-kafka-go/examples/go-kafkacat
github.com/alkoenig09/confluent-kafka-go/examples/idempotent_producer_example
github.com/alkoenig09/confluent-kafka-go/examples/library-version
github.com/alkoenig09/confluent-kafka-go/examples/oauthbearer_example
github.com/alkoenig09/confluent-kafka-go/examples/producer_channel_example
github.com/alkoenig09/confluent-kafka-go/examples/producer_example
github.com/alkoenig09/confluent-kafka-go/examples/stats_example
github.com/alkoenig09/confluent-kafka-go/examples/transactions_example
github.com/alkoenig09/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/alkoenig09/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/alkoenig09/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/eko/confluent-kafka-go/examples/admin_create_topic
github.com/eko/confluent-kafka-go/examples/admin_delete_topics
github.com/eko/confluent-kafka-go/examples/admin_describe_config
github.com/eko/confluent-kafka-go/examples/confluent_cloud_example
github.com/eko/confluent-kafka-go/examples/consumer_channel_example
github.com/eko/confluent-kafka-go/examples/consumer_example
github.com/eko/confluent-kafka-go/examples/consumer_offset_metadata
github.com/eko/confluent-kafka-go/examples/cooperative_consumer_example
github.com/eko/confluent-kafka-go/examples/go-kafkacat
github.com/eko/confluent-kafka-go/examples/idempotent_producer_example
github.com/eko/confluent-kafka-go/examples/library-version
github.com/eko/confluent-kafka-go/examples/oauthbearer_example
github.com/eko/confluent-kafka-go/examples/producer_channel_example
github.com/eko/confluent-kafka-go/examples/producer_example
github.com/eko/confluent-kafka-go/examples/stats_example
github.com/eko/confluent-kafka-go/examples/transactions_example
github.com/eko/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/eko/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/eko/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/colivi/confluent-kafka-go/examples/admin_create_topic
github.com/colivi/confluent-kafka-go/examples/admin_delete_topics
github.com/colivi/confluent-kafka-go/examples/admin_describe_config
github.com/colivi/confluent-kafka-go/examples/confluent_cloud_example
github.com/unkiwii/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
github.com/pellared/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
github.com/d7561985/confluent-kafka-go/examples/consumer_offset_metadata
github.com/d7561985/confluent-kafka-go/examples/confluent_cloud_example
github.com/huanggx-sea/confluent-kafka-go/examples/consumer_offset_metadata
github.com/huanggx-sea/confluent-kafka-go/examples/cooperative_consumer_example
github.com/huanggx-sea/confluent-kafka-go/examples/go-kafkacat
github.com/huanggx-sea/confluent-kafka-go/examples/idempotent_producer_example
github.com/huanggx-sea/confluent-kafka-go/examples/library-version
github.com/huanggx-sea/confluent-kafka-go/examples/oauthbearer_example
github.com/huanggx-sea/confluent-kafka-go/examples/producer_channel_example
github.com/huanggx-sea/confluent-kafka-go/examples/producer_example
github.com/huanggx-sea/confluent-kafka-go/examples/stats_example
github.com/sponomis/confluent-kafka-go/examples/admin_describe_config
github.com/sponomis/confluent-kafka-go/examples/confluent_cloud_example
github.com/sponomis/confluent-kafka-go/examples/consumer_channel_example
github.com/sponomis/confluent-kafka-go/examples/consumer_example
github.com/sponomis/confluent-kafka-go/examples/consumer_offset_metadata
github.com/sponomis/confluent-kafka-go/examples/cooperative_consumer_example
github.com/sponomis/confluent-kafka-go/examples/go-kafkacat
github.com/sponomis/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/d7561985/confluent-kafka-go/examples/consumer_channel_example
github.com/huanggx-sea/confluent-kafka-go/examples/consumer_example
github.com/huanggx-sea/confluent-kafka-go/examples/consumer_channel_example
github.com/huanggx-sea/confluent-kafka-go/examples/confluent_cloud_example
github.com/sponomis/confluent-kafka-go/examples/idempotent_producer_example
github.com/sponomis/confluent-kafka-go/examples/library-version
github.com/d7561985/confluent-kafka-go/examples/stats_example
github.com/sponomis/confluent-kafka-go/examples/oauthbearer_example
github.com/sponomis/confluent-kafka-go/examples/producer_channel_example
github.com/sponomis/confluent-kafka-go/examples/producer_example
github.com/sponomis/confluent-kafka-go/examples/stats_example
github.com/sponomis/confluent-kafka-go/examples/transactions_example
github.com/sponomis/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/huanggx-sea/confluent-kafka-go/examples/admin_describe_config
github.com/huanggx-sea/confluent-kafka-go/examples/admin_delete_topics
github.com/huanggx-sea/confluent-kafka-go/examples/admin_create_topic
github.com/d7561985/confluent-kafka-go/examples/cooperative_consumer_example
github.com/sponomis/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/d7561985/confluent-kafka-go/examples/admin_describe_config
github.com/d7561985/confluent-kafka-go/examples/admin_delete_topics
github.com/d7561985/confluent-kafka-go/examples/go-kafkacat
github.com/d7561985/confluent-kafka-go/examples/idempotent_producer_example
github.com/d7561985/confluent-kafka-go/examples/library-version
github.com/d7561985/confluent-kafka-go/examples/producer_example
github.com/d7561985/confluent-kafka-go/examples/transactions_example
github.com/d7561985/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/d7561985/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/d7561985/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/d7561985/confluent-kafka-go/examples/producer_channel_example
github.com/d7561985/confluent-kafka-go/examples/admin_create_topic
github.com/d7561985/confluent-kafka-go/examples/consumer_example
github.com/d7561985/confluent-kafka-go/examples/oauthbearer_example
github.com/sponomis/confluent-kafka-go/examples/admin_delete_topics
github.com/huanggx-sea/confluent-kafka-go/examples/transactions_example
github.com/huanggx-sea/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/huanggx-sea/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/huanggx-sea/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/sponomis/confluent-kafka-go/examples/admin_create_topic
github.com/StevanoZ/dv-shared/kafka/mock
github.com/StevanoZ/dv-shared/kafka
github.com/jliunyu/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/jliunyu/confluent-kafka-go/examples/transactions_example
github.com/jliunyu/confluent-kafka-go/examples/library-version
github.com/sabariramc/goserverbase/kafka
github.com/erda-project/erda/modules/scheduler/executor/plugins/marathon/instanceinfosync
github.com/erda-project/erda/modules/core/monitor/storekit/kafka/topic/initializer
github.com/sandronister/go_broker/pkg/broker/broker_kafka
github.com/victor-perov/confluent-kafka-go/examples/transactions_example
github.com/jdemeyer/confluent-kafka-go/examples/transactions_example
github.com/jdemeyer/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/Boklazhenko/kafka
github.com/victor-perov/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/wahed-tech/confluent-kafka-go/examples/transactions_example
github.com/journeymidnight/yig/messagebus/kafka
github.com/wahed-tech/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/AeroAgency/go-kafka/producer
github.com/AeroAgency/go-kafka
github.com/AeroAgency/go-kafka/consumer
github.com/btubbs/signalfx-go-tracing/contrib/confluentinc/confluent-kafka-go/kafka
github.com/huantt/kafka-dump/cmd
github.com/huantt/kafka-dump/impl
github.com/lonnblad/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/lsgndln/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/huantt/kafka-dump/pkg/kafka_utils
github.com/zooptwopointone/gdsb
github.com/erenkaratas99/COApiCore/pkg/confluentKafka/producer
github.com/erenkaratas99/COApiCore/pkg/confluentKafka/consumer
github.com/topfreegames/extensions/mocks
github.com/lucbarr/extensions/interfaces
github.com/lucbarr/extensions
github.com/topfreegames/extensions
github.com/topfreegames/extensions/interfaces
github.com/lucbarr/extensions/mocks
github.com/itsjunglexyz/extensions
github.com/itsjunglexyz/extensions/interfaces
github.com/itsjunglexyz/extensions/mocks
github.com/core-go/mq/confluent
github.com/architecture-it/go-platform/AMQStream
github.com/AVENTER-UG/mesos-compose/plugins/kafka
github.com/airingone/air-kafkaclient
github.com/cristovaoolegario/tasks-api/cmd/api/consumer
github.com/3rs4lg4d0/go-kafka-checker
github.com/topfreegames/pusher/mocks
github.com/topfreegames/pusher/extensions
github.com/topfreegames/pusher/interfaces
github.com/topfreegames/marathon/extensions
github.com/topfreegames/marathon/interfaces
github.com/cristovaoolegario/tasks-api/internal/infra/kafka
github.com/tommzn/hdb-message-agent
github.com/yyliziqiu/zlib/zkafka
github.com/emmanuelneri/microservices-orchestration/commons/kafka
github.com/Israelsodano/msgb/msgb_kafka
github.com/erda-project/erda-infra/providers/kafka
github.com/erda-project/erda-infra/providers/kafka/examples/batch-reader
github.com/gs-mblock/mbgo/lib/mq/kafka/demo1/tokafka
github.com/gs-mblock/mbgo/lib/mq/kafka/demo1/todata
github.com/core-go/kafka/confluent
github.com/common-go/kafka/confluent
github.com/gustavofdeoliveira/2024-m09-dev/P6/src
github.com/gustavofdeoliveira/2024-m09-dev/P7/src
github.com/gunsluo/go-example/kafka
github.com/iwanjunaid/mokabox/manager
github.com/guil95/outbox
github.com/3rs4lg4d0/goutbox/internal
github.com/3rs4lg4d0/goutbox/test
github.com/ozlemugur/go-cqrs-event-sourcing-tt/pkg/kafka/producer
github.com/modern-era-devs/go-utils/queue/kafka
github.com/iwanjunaid/mokabox/config
github.com/ozlemugur/go-cqrs-event-sourcing-tt/pkg/kafka/consumer
github.com/guil95/outbox/example_mongo
github.com/aifaniyi/kafkaclient
github.com/vemta/mvc
github.com/0angelic0/dd-trace-go/contrib/confluentinc/confluent-kafka-go/kafka
github.com/3rs4lg4d0/goutbox/emitter/kafka
github.com/pigeatgarlic/goedf/chassis/util/event/provider/kafka
github.com/vemta/mvc/internal/infra/kafka/event
github.com/vemta/mvc/internal/infra/kafka/consumer
github.com/iwanjunaid/mokabox/pkg/interfaces/manager
github.com/iwanjunaid/mokabox/pkg/interfaces/config
github.com/mohamedtaher567/enmsAnalyticsExporter10
github.com/mohamedtaher567/enmsAnalyticsExporter4
github.com/mohamedtaher567/enmsAnalyticsExporter3
github.com/mohamedtaher567/enmsAnalyzerExporter5
github.com/w6d-io/x/kafkax
github.com/kyma-incubator/knative-kafka/pkg/common/kafka/consumer
github.com/kyma-incubator/knative-kafka/pkg/channel/test
github.com/kyma-incubator/knative-kafka/pkg/channel/producer
github.com/kyma-incubator/knative-kafka/pkg/channel/message
github.com/kyma-incubator/knative-kafka/pkg/common/kafka/producer
github.com/kyma-incubator/knative-kafka/pkg/common/kafka/admin
github.com/kyma-incubator/knative-kafka/pkg/common/kafka/util
github.com/kyma-incubator/knative-kafka/pkg/dispatcher/dispatcher
github.com/kyma-incubator/knative-kafka/pkg/controller/test
github.com/kyma-incubator/knative-kafka/pkg/controller/kafkachannel
github.com/metadb-project/metadb/cmd/metadb/util
github.com/metadb-project/metadb/cmd/metadb/change
github.com/metadb-project/metadb/cmd/metadb/server
github.com/figma/confluent-kafka-go-dev/examples/producer_channel_example
github.com/figma/confluent-kafka-go-dev/examples/admin_delete_topics
github.com/figma/confluent-kafka-go-dev/examples/admin_create_topic
github.com/figma/confluent-kafka-go-dev/examples/oauthbearer_example
github.com/figma/confluent-kafka-go-dev/examples/consumer_example
github.com/figma/confluent-kafka-go-dev/examples/consumer_channel_example
github.com/figma/confluent-kafka-go-dev/examples/stats_example
github.com/figma/confluent-kafka-go-dev/examples/confluent_cloud_example
github.com/figma/confluent-kafka-go-dev/examples/admin_describe_config
github.com/figma/confluent-kafka-go-dev/examples/producer_example
github.com/figma/confluent-kafka-go-dev/kafkatest/go_verifiable_consumer
github.com/figma/confluent-kafka-go-dev/examples/idempotent_producer_example
github.com/figma/confluent-kafka-go-dev/kafkatest/go_verifiable_producer
github.com/sodafoundation/strato/s3/pkg/messagebus/kafka
github.com/sodafoundation/multi-cloud/s3/pkg/messagebus/kafka
github.com/anvithks/multi-cloud/s3/pkg/messagebus/kafka
github.com/opensds/multi-cloud/s3/pkg/messagebus/kafka
github.com/finncolman/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/huanggx-sea/confluent-kafka-go/examples/admin_describe_config
github.com/huanggx-sea/confluent-kafka-go/examples/confluent_cloud_example
github.com/huanggx-sea/confluent-kafka-go/examples/consumer_channel_example
github.com/huanggx-sea/confluent-kafka-go/examples/consumer_example
github.com/huanggx-sea/confluent-kafka-go/examples/go-kafkacat
github.com/huanggx-sea/confluent-kafka-go/examples/producer_channel_example
github.com/huanggx-sea/confluent-kafka-go/examples/producer_example
github.com/huanggx-sea/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/huanggx-sea/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/beeketing/confluent-kafka-go/examples/admin_create_topic
github.com/beeketing/confluent-kafka-go/examples/admin_delete_topics
github.com/beeketing/confluent-kafka-go/examples/admin_describe_config
github.com/beeketing/confluent-kafka-go/examples/confluent_cloud_example
github.com/beeketing/confluent-kafka-go/examples/consumer_channel_example
github.com/beeketing/confluent-kafka-go/examples/consumer_example
github.com/beeketing/confluent-kafka-go/examples/go-kafkacat
github.com/beeketing/confluent-kafka-go/examples/producer_channel_example
github.com/beeketing/confluent-kafka-go/examples/producer_example
github.com/beeketing/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/beeketing/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/alkoenig09/confluent-kafka-go/examples/admin_create_topic
github.com/alkoenig09/confluent-kafka-go/examples/admin_delete_topics
github.com/alkoenig09/confluent-kafka-go/examples/admin_describe_config
github.com/alkoenig09/confluent-kafka-go/examples/confluent_cloud_example
github.com/alkoenig09/confluent-kafka-go/examples/consumer_channel_example
github.com/alkoenig09/confluent-kafka-go/examples/consumer_example
github.com/alkoenig09/confluent-kafka-go/examples/go-kafkacat
github.com/alkoenig09/confluent-kafka-go/examples/producer_channel_example
github.com/alkoenig09/confluent-kafka-go/examples/producer_example
github.com/alkoenig09/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/alkoenig09/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/3dsinteractive/confluent-kafka-go/examples/admin_create_topic
github.com/3dsinteractive/confluent-kafka-go/examples/admin_delete_topics
github.com/3dsinteractive/confluent-kafka-go/examples/admin_describe_config
github.com/3dsinteractive/confluent-kafka-go/examples/confluent_cloud_example
github.com/3dsinteractive/confluent-kafka-go/examples/consumer_channel_example
github.com/3dsinteractive/confluent-kafka-go/examples/consumer_example
github.com/3dsinteractive/confluent-kafka-go/examples/go-kafkacat
github.com/3dsinteractive/confluent-kafka-go/examples/producer_channel_example
github.com/simnotes/confluent-kafka-go/examples/admin_create_topic
github.com/simnotes/confluent-kafka-go/examples/admin_delete_topics
github.com/simnotes/confluent-kafka-go/examples/admin_describe_config
github.com/simnotes/confluent-kafka-go/examples/confluent_cloud_example
github.com/simnotes/confluent-kafka-go/examples/consumer_channel_example
github.com/simnotes/confluent-kafka-go/examples/consumer_example
github.com/simnotes/confluent-kafka-go/examples/go-kafkacat
github.com/simnotes/confluent-kafka-go/examples/producer_channel_example
github.com/simnotes/confluent-kafka-go/examples/producer_example
github.com/simnotes/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/simnotes/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/d7561985/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/d7561985/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/sourcefellows/confluent-kafka-go/examples/admin_create_topic
github.com/sourcefellows/confluent-kafka-go/examples/admin_delete_topics
github.com/sourcefellows/confluent-kafka-go/examples/admin_describe_config
github.com/sourcefellows/confluent-kafka-go/examples/confluent_cloud_example
github.com/sourcefellows/confluent-kafka-go/examples/consumer_channel_example
github.com/sourcefellows/confluent-kafka-go/examples/consumer_example
github.com/sourcefellows/confluent-kafka-go/examples/go-kafkacat
github.com/sourcefellows/confluent-kafka-go/examples/producer_channel_example
github.com/sourcefellows/confluent-kafka-go/examples/producer_example
github.com/sourcefellows/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/sourcefellows/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/bjlhlin/confluent-kafka-go/examples/admin_create_topic
github.com/ruseinov/confluent-kafka-go/examples/admin_create_topic
github.com/ruseinov/confluent-kafka-go/examples/admin_delete_topics
github.com/ruseinov/confluent-kafka-go/examples/admin_describe_config
github.com/ruseinov/confluent-kafka-go/examples/confluent_cloud_example
github.com/ruseinov/confluent-kafka-go/examples/consumer_channel_example
github.com/ruseinov/confluent-kafka-go/examples/consumer_example
github.com/ruseinov/confluent-kafka-go/examples/go-kafkacat
github.com/ruseinov/confluent-kafka-go/examples/producer_channel_example
github.com/ruseinov/confluent-kafka-go/examples/producer_example
github.com/ruseinov/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/ruseinov/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/nbwoodward/confluent-kafka-go/examples/admin_create_topic
github.com/nbwoodward/confluent-kafka-go/examples/admin_delete_topics
github.com/nbwoodward/confluent-kafka-go/examples/admin_describe_config
github.com/nbwoodward/confluent-kafka-go/examples/confluent_cloud_example
github.com/nbwoodward/confluent-kafka-go/examples/consumer_channel_example
github.com/nbwoodward/confluent-kafka-go/examples/consumer_example
github.com/nbwoodward/confluent-kafka-go/examples/go-kafkacat
github.com/nbwoodward/confluent-kafka-go/examples/producer_channel_example
github.com/nbwoodward/confluent-kafka-go/examples/producer_example
github.com/nbwoodward/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/nbwoodward/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/starius/confluent-kafka-go/examples/admin_create_topic
github.com/starius/confluent-kafka-go/examples/admin_delete_topics
github.com/starius/confluent-kafka-go/examples/admin_describe_config
github.com/starius/confluent-kafka-go/examples/confluent_cloud_example
github.com/starius/confluent-kafka-go/examples/consumer_channel_example
github.com/starius/confluent-kafka-go/examples/consumer_example
github.com/starius/confluent-kafka-go/examples/go-kafkacat
github.com/starius/confluent-kafka-go/examples/producer_channel_example
github.com/starius/confluent-kafka-go/examples/producer_example
github.com/starius/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/starius/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/intfish123/confluent-kafka-go/examples/admin_create_topic
github.com/intfish123/confluent-kafka-go/examples/admin_delete_topics
github.com/intfish123/confluent-kafka-go/examples/admin_describe_config
github.com/intfish123/confluent-kafka-go/examples/confluent_cloud_example
github.com/intfish123/confluent-kafka-go/examples/consumer_channel_example
github.com/intfish123/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/intfish123/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/perdue/confluent-kafka-go/examples/admin_create_topic
github.com/perdue/confluent-kafka-go/examples/admin_delete_topics
github.com/perdue/confluent-kafka-go/examples/admin_describe_config
github.com/perdue/confluent-kafka-go/examples/confluent_cloud_example
github.com/perdue/confluent-kafka-go/examples/consumer_channel_example
github.com/perdue/confluent-kafka-go/examples/consumer_example
github.com/perdue/confluent-kafka-go/examples/go-kafkacat
github.com/perdue/confluent-kafka-go/examples/producer_channel_example
github.com/perdue/confluent-kafka-go/examples/producer_example
github.com/perdue/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/perdue/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/seabfh/confluent-kafka-go/examples/admin_create_topic
github.com/seabfh/confluent-kafka-go/examples/admin_delete_topics
github.com/seabfh/confluent-kafka-go/examples/admin_describe_config
github.com/seabfh/confluent-kafka-go/examples/confluent_cloud_example
github.com/seabfh/confluent-kafka-go/examples/consumer_channel_example
github.com/seabfh/confluent-kafka-go/examples/consumer_example
github.com/seabfh/confluent-kafka-go/examples/go-kafkacat
github.com/finncolman/confluent-kafka-go/examples/producer_channel_example
github.com/finncolman/confluent-kafka-go/examples/producer_example
github.com/finncolman/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/confluentinc/confluent-kafka-go/examples/consumer_example
github.com/confluentinc/confluent-kafka-go/examples/go-kafkacat
github.com/confluentinc/confluent-kafka-go/examples/producer_channel_example
github.com/confluentinc/confluent-kafka-go/examples/producer_example
github.com/confluentinc/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/confluentinc/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/peak/confluent-kafka-go/examples/producer_channel_example
github.com/peak/confluent-kafka-go/examples/producer_example
github.com/peak/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/peak/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/bjlhlin/confluent-kafka-go/examples/admin_delete_topics
github.com/bjlhlin/confluent-kafka-go/examples/admin_describe_config
github.com/bjlhlin/confluent-kafka-go/examples/confluent_cloud_example
github.com/bjlhlin/confluent-kafka-go/examples/consumer_channel_example
github.com/bjlhlin/confluent-kafka-go/examples/consumer_example
github.com/bjlhlin/confluent-kafka-go/examples/go-kafkacat
github.com/bjlhlin/confluent-kafka-go/examples/producer_channel_example
github.com/bjlhlin/confluent-kafka-go/examples/producer_example
github.com/bjlhlin/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/bjlhlin/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/zendesk/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/zendesk/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/zendesk/confluent-kafka-go/examples/producer_example
github.com/zendesk/confluent-kafka-go/examples/producer_channel_example
github.com/zendesk/confluent-kafka-go/examples/go-kafkacat
github.com/zendesk/confluent-kafka-go/examples/consumer_example
github.com/zendesk/confluent-kafka-go/examples/consumer_channel_example
github.com/zendesk/confluent-kafka-go/examples/confluent_cloud_example
github.com/zendesk/confluent-kafka-go/examples/admin_describe_config
github.com/zendesk/confluent-kafka-go/examples/admin_delete_topics
github.com/zendesk/confluent-kafka-go/examples/admin_create_topic
github.com/jdemeyer/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/jdemeyer/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/jdemeyer/confluent-kafka-go/examples/producer_example
github.com/jdemeyer/confluent-kafka-go/examples/producer_channel_example
github.com/jdemeyer/confluent-kafka-go/examples/go-kafkacat
github.com/jdemeyer/confluent-kafka-go/examples/consumer_example
github.com/jdemeyer/confluent-kafka-go/examples/consumer_channel_example
github.com/jdemeyer/confluent-kafka-go/examples/confluent_cloud_example
github.com/jdemeyer/confluent-kafka-go/examples/admin_describe_config
github.com/jdemeyer/confluent-kafka-go/examples/admin_delete_topics
github.com/jdemeyer/confluent-kafka-go/examples/admin_create_topic
github.com/intfish123/confluent-kafka-go/examples/consumer_example
github.com/intfish123/confluent-kafka-go/examples/go-kafkacat
github.com/intfish123/confluent-kafka-go/examples/producer_channel_example
github.com/intfish123/confluent-kafka-go/examples/producer_example
github.com/victor-perov/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/victor-perov/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/victor-perov/confluent-kafka-go/examples/producer_example
github.com/victor-perov/confluent-kafka-go/examples/producer_channel_example
github.com/victor-perov/confluent-kafka-go/examples/go-kafkacat
github.com/victor-perov/confluent-kafka-go/examples/consumer_example
github.com/steveruckdashel/confluent-kafka-go/examples/admin_create_topic
github.com/steveruckdashel/confluent-kafka-go/examples/admin_delete_topics
github.com/steveruckdashel/confluent-kafka-go/examples/admin_describe_config
github.com/steveruckdashel/confluent-kafka-go/examples/confluent_cloud_example
github.com/steveruckdashel/confluent-kafka-go/examples/consumer_channel_example
github.com/steveruckdashel/confluent-kafka-go/examples/consumer_example
github.com/steveruckdashel/confluent-kafka-go/examples/go-kafkacat
github.com/steveruckdashel/confluent-kafka-go/examples/producer_channel_example
github.com/steveruckdashel/confluent-kafka-go/examples/producer_example
github.com/steveruckdashel/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/steveruckdashel/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/victor-perov/confluent-kafka-go/examples/consumer_channel_example
github.com/victor-perov/confluent-kafka-go/examples/confluent_cloud_example
github.com/victor-perov/confluent-kafka-go/examples/admin_describe_config
github.com/victor-perov/confluent-kafka-go/examples/admin_delete_topics
github.com/victor-perov/confluent-kafka-go/examples/admin_create_topic
github.com/wahed-tech/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/wahed-tech/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/wahed-tech/confluent-kafka-go/examples/producer_example
github.com/wahed-tech/confluent-kafka-go/examples/producer_channel_example
github.com/wahed-tech/confluent-kafka-go/examples/go-kafkacat
github.com/wahed-tech/confluent-kafka-go/examples/consumer_example
github.com/wahed-tech/confluent-kafka-go/examples/consumer_channel_example
github.com/wahed-tech/confluent-kafka-go/examples/confluent_cloud_example
github.com/jliunyu/confluent-kafka-go/examples/admin_create_topic
github.com/jliunyu/confluent-kafka-go/examples/admin_delete_topics
github.com/jliunyu/confluent-kafka-go/examples/admin_describe_config
github.com/jliunyu/confluent-kafka-go/examples/confluent_cloud_example
github.com/jliunyu/confluent-kafka-go/examples/consumer_channel_example
github.com/jliunyu/confluent-kafka-go/examples/consumer_example
github.com/jliunyu/confluent-kafka-go/examples/go-kafkacat
github.com/jliunyu/confluent-kafka-go/examples/producer_channel_example
github.com/jliunyu/confluent-kafka-go/examples/producer_example
github.com/jliunyu/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/wahed-tech/confluent-kafka-go/examples/admin_describe_config
github.com/wahed-tech/confluent-kafka-go/examples/admin_delete_topics
github.com/wahed-tech/confluent-kafka-go/examples/admin_create_topic
github.com/jliunyu/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/seabfh/confluent-kafka-go/examples/producer_channel_example
github.com/seabfh/confluent-kafka-go/examples/producer_example
github.com/seabfh/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/seabfh/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/finncolman/confluent-kafka-go/examples/admin_create_topic
github.com/3dsinteractive/confluent-kafka-go/examples/producer_example
github.com/3dsinteractive/confluent-kafka-go/examples/stats_example
github.com/3dsinteractive/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/3dsinteractive/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/alistairking/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/alistairking/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/rayokota/confluent-kafka-go/examples/admin_create_topic
github.com/rayokota/confluent-kafka-go/examples/admin_delete_topics
github.com/rayokota/confluent-kafka-go/examples/admin_describe_config
github.com/rayokota/confluent-kafka-go/examples/confluent_cloud_example
github.com/rayokota/confluent-kafka-go/examples/consumer_channel_example
github.com/rayokota/confluent-kafka-go/examples/consumer_example
github.com/rayokota/confluent-kafka-go/examples/go-kafkacat
github.com/rayokota/confluent-kafka-go/examples/producer_channel_example
github.com/rayokota/confluent-kafka-go/examples/producer_example
github.com/rayokota/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/rayokota/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/alistairking/confluent-kafka-go/examples/producer_example
github.com/d7561985/confluent-kafka-go/examples/admin_create_topic
github.com/d7561985/confluent-kafka-go/examples/admin_delete_topics
github.com/d7561985/confluent-kafka-go/examples/admin_describe_config
github.com/d7561985/confluent-kafka-go/examples/confluent_cloud_example
github.com/d7561985/confluent-kafka-go/examples/consumer_channel_example
github.com/d7561985/confluent-kafka-go/examples/consumer_example
github.com/d7561985/confluent-kafka-go/examples/go-kafkacat
github.com/d7561985/confluent-kafka-go/examples/producer_channel_example
github.com/d7561985/confluent-kafka-go/examples/producer_example
github.com/eko/confluent-kafka-go/examples/admin_create_topic
github.com/eko/confluent-kafka-go/examples/admin_delete_topics
github.com/eko/confluent-kafka-go/examples/admin_describe_config
github.com/eko/confluent-kafka-go/examples/confluent_cloud_example
github.com/eko/confluent-kafka-go/examples/consumer_channel_example
github.com/eko/confluent-kafka-go/examples/consumer_example
github.com/eko/confluent-kafka-go/examples/go-kafkacat
github.com/eko/confluent-kafka-go/examples/producer_channel_example
github.com/eko/confluent-kafka-go/examples/producer_example
github.com/eko/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/eko/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/finncolman/confluent-kafka-go/examples/admin_delete_topics
github.com/finncolman/confluent-kafka-go/examples/admin_describe_config
github.com/finncolman/confluent-kafka-go/examples/confluent_cloud_example
github.com/finncolman/confluent-kafka-go/examples/consumer_channel_example
github.com/finncolman/confluent-kafka-go/examples/consumer_example
github.com/finncolman/confluent-kafka-go/examples/go-kafkacat
github.com/colivi/confluent-kafka-go/examples/admin_create_topic
github.com/colivi/confluent-kafka-go/examples/admin_delete_topics
github.com/colivi/confluent-kafka-go/examples/admin_describe_config
github.com/colivi/confluent-kafka-go/examples/confluent_cloud_example
github.com/colivi/confluent-kafka-go/examples/consumer_channel_example
github.com/colivi/confluent-kafka-go/examples/consumer_example
github.com/colivi/confluent-kafka-go/examples/go-kafkacat
github.com/colivi/confluent-kafka-go/examples/producer_channel_example
github.com/colivi/confluent-kafka-go/examples/producer_example
github.com/colivi/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/colivi/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/alistairking/confluent-kafka-go/examples/producer_channel_example
github.com/kkhaike/confluent-kafka-go/examples/admin_create_topic
github.com/kkhaike/confluent-kafka-go/examples/admin_delete_topics
github.com/kkhaike/confluent-kafka-go/examples/admin_describe_config
github.com/kkhaike/confluent-kafka-go/examples/confluent_cloud_example
github.com/kkhaike/confluent-kafka-go/examples/consumer_channel_example
github.com/kkhaike/confluent-kafka-go/examples/consumer_example
github.com/kkhaike/confluent-kafka-go/examples/go-kafkacat
github.com/kkhaike/confluent-kafka-go/examples/producer_channel_example
github.com/kkhaike/confluent-kafka-go/examples/producer_example
github.com/kkhaike/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/kkhaike/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/alistairking/confluent-kafka-go/examples/go-kafkacat
github.com/alistairking/confluent-kafka-go/examples/consumer_example
github.com/alistairking/confluent-kafka-go/examples/consumer_channel_example
github.com/alistairking/confluent-kafka-go/examples/confluent_cloud_example
github.com/alistairking/confluent-kafka-go/examples/admin_describe_config
github.com/alistairking/confluent-kafka-go/examples/admin_delete_topics
github.com/alistairking/confluent-kafka-go/examples/admin_create_topic
github.com/huanggx-sea/confluent-kafka-go/examples/admin_delete_topics
github.com/huanggx-sea/confluent-kafka-go/examples/admin_create_topic
github.com/peak/confluent-kafka-go/examples/admin_create_topic
github.com/peak/confluent-kafka-go/examples/admin_delete_topics
github.com/peak/confluent-kafka-go/examples/admin_describe_config
github.com/peak/confluent-kafka-go/examples/confluent_cloud_example
github.com/peak/confluent-kafka-go/examples/consumer_channel_example
github.com/peak/confluent-kafka-go/examples/consumer_example
github.com/peak/confluent-kafka-go/examples/go-kafkacat
github.com/confluentinc/confluent-kafka-go/examples/consumer_channel_example
github.com/confluentinc/confluent-kafka-go/examples/confluent_cloud_example
github.com/confluentinc/confluent-kafka-go/examples/admin_describe_config
github.com/confluentinc/confluent-kafka-go/examples/admin_delete_topics
github.com/confluentinc/confluent-kafka-go/examples/admin_create_topic
github.com/hexa00/confluent-kafka-go/examples/admin_create_topic
github.com/hexa00/confluent-kafka-go/examples/admin_delete_topics
github.com/hexa00/confluent-kafka-go/examples/admin_describe_config
github.com/hexa00/confluent-kafka-go/examples/confluent_cloud_example
github.com/hexa00/confluent-kafka-go/examples/consumer_channel_example
github.com/hexa00/confluent-kafka-go/examples/consumer_example
github.com/hexa00/confluent-kafka-go/examples/go-kafkacat
github.com/hexa00/confluent-kafka-go/examples/producer_channel_example
github.com/hexa00/confluent-kafka-go/examples/producer_example
github.com/hexa00/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/hexa00/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/sponomis/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/sponomis/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/sponomis/confluent-kafka-go/examples/producer_example
github.com/sponomis/confluent-kafka-go/examples/producer_channel_example
github.com/sponomis/confluent-kafka-go/examples/go-kafkacat
github.com/sponomis/confluent-kafka-go/examples/consumer_example
github.com/sponomis/confluent-kafka-go/examples/consumer_channel_example
github.com/stb2132/confluent-kafka-go/examples/admin_create_topic
github.com/stb2132/confluent-kafka-go/examples/admin_delete_topics
github.com/stb2132/confluent-kafka-go/examples/admin_describe_config
github.com/stb2132/confluent-kafka-go/examples/confluent_cloud_example
github.com/stb2132/confluent-kafka-go/examples/consumer_channel_example
github.com/stb2132/confluent-kafka-go/examples/consumer_example
github.com/stb2132/confluent-kafka-go/examples/go-kafkacat
github.com/stb2132/confluent-kafka-go/examples/producer_channel_example
github.com/stb2132/confluent-kafka-go/examples/producer_example
github.com/stb2132/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/stb2132/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/sponomis/confluent-kafka-go/examples/confluent_cloud_example
github.com/sponomis/confluent-kafka-go/examples/admin_describe_config
github.com/sponomis/confluent-kafka-go/examples/admin_delete_topics
github.com/sponomis/confluent-kafka-go/examples/admin_create_topic
github.com/octarinesec/confluent-kafka-go/examples/consumer_channel_example
github.com/octarinesec/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/octarinesec/confluent-kafka-go/examples/consumer_example
github.com/octarinesec/confluent-kafka-go/examples/go-kafkacat
github.com/octarinesec/confluent-kafka-go/examples/producer_channel_example
github.com/octarinesec/confluent-kafka-go/examples/producer_example
github.com/octarinesec/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/chow1937/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/gwilym/confluent-kafka-go/examples/consumer_channel_example
github.com/oscarhealth/confluent-kafka-go/examples/producer_example
github.com/oscarhealth/confluent-kafka-go/examples/producer_channel_example
github.com/gwilym/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/gwilym/confluent-kafka-go/examples/consumer_example
github.com/chow1937/confluent-kafka-go/examples/consumer_channel_example
github.com/chow1937/confluent-kafka-go/examples/consumer_example
github.com/chow1937/confluent-kafka-go/examples/go-kafkacat
github.com/chow1937/confluent-kafka-go/examples/producer_channel_example
github.com/chow1937/confluent-kafka-go/examples/producer_example
github.com/chow1937/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/oscarhealth/confluent-kafka-go/examples/consumer_example
github.com/oscarhealth/confluent-kafka-go/examples/consumer_channel_example
github.com/pagrus7/kafka-fwd/routing
github.com/gwilym/confluent-kafka-go/examples/go-kafkacat
github.com/pagrus7/kafka-fwd/config
github.com/oscarhealth/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/oscarhealth/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/alphazero/confluent-kafka-go/examples/go-kafkacat
github.com/alphazero/confluent-kafka-go/examples/consumer_example
github.com/alphazero/confluent-kafka-go/examples/consumer_channel_example
github.com/gwilym/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/gwilym/confluent-kafka-go/examples/producer_example
github.com/gwilym/confluent-kafka-go/examples/producer_channel_example
github.com/oscarhealth/confluent-kafka-go/examples/go-kafkacat
github.com/georgeerickson/confluent-kafka-go/examples/producer_channel_example
github.com/georgeerickson/confluent-kafka-go/examples/producer_example
github.com/georgeerickson/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/georgeerickson/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/georgeerickson/confluent-kafka-go/examples/consumer_channel_example
github.com/alphazero/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/georgeerickson/confluent-kafka-go/examples/consumer_example
github.com/alphazero/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/alphazero/confluent-kafka-go/examples/producer_example
github.com/alphazero/confluent-kafka-go/examples/producer_channel_example
github.com/georgeerickson/confluent-kafka-go/examples/go-kafkacat
github.com/architecture-it/go-platform/AMQStream
github.com/argoproj-labs/argo-dataflow/runner/sidecar/source/kafka
github.com/argoproj-labs/argo-dataflow/runner/sidecar/shared/kafka
github.com/argoproj-labs/argo-dataflow/runner/sidecar/sink/kafka
github.com/argoproj-labs/argo-dataflow/testapi
github.com/gojekfarm/ziggurat
github.com/datadog/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/thomas91310/confluent-kafka-go/examples/consumer_channel_example
github.com/thomas91310/confluent-kafka-go/examples/consumer_example
github.com/thomas91310/confluent-kafka-go/examples/go-kafkacat
github.com/thomas91310/confluent-kafka-go/examples/producer_channel_example
github.com/thomas91310/confluent-kafka-go/examples/producer_example
github.com/thomas91310/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/thomas91310/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/datadog/confluent-kafka-go/examples/consumer_channel_example
github.com/datadog/confluent-kafka-go/examples/consumer_example
github.com/datadog/confluent-kafka-go/examples/go-kafkacat
github.com/datadog/confluent-kafka-go/examples/producer_channel_example
github.com/datadog/confluent-kafka-go/examples/producer_example
github.com/datadog/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/ewencp/confluent-kafka-go/examples/consumer_channel_example
github.com/ewencp/confluent-kafka-go/examples/consumer_example
github.com/ewencp/confluent-kafka-go/examples/go-kafkacat
github.com/ewencp/confluent-kafka-go/examples/producer_channel_example
github.com/ewencp/confluent-kafka-go/examples/producer_example
github.com/ewencp/confluent-kafka-go/kafkatest/go_verifiable_consumer
github.com/ewencp/confluent-kafka-go/kafkatest/go_verifiable_producer
github.com/gojekfarm/xtools/examples/xkafka
github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mcis/collector
github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mcis/collector/k8s_collector
github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mck8s/collector/k8s_collector
github.com/cloud-barista/cb-dragonfly/pkg/modules/monitoring/push/mck8s/collector
github.com/core-go/mq/confluent
github.com/skroutz/rafka
github.com/blacklane/go-libs/x/events
github.com/jkratz55/kefka
github.com/jkratz55/kefka/examples/consumer
github.com/jkratz55/kefka/examples/producer
github.com/jkratz55/kefka/examples/reader
github.com/corabank/goharvest
github.com/Octops/agones-event-broadcaster/pkg/brokers/kafka
github.com/AVENTER-UG/mesos-m3s/plugins/kafka
github.com/ibm-avocados/ibmcloud-kubernetes-admin/cmd/notifier
github.com/ibm-avocados/ibmcloud-kubernetes-admin/pkg/eventstream
github.com/ibm-avocados/ibmcloud-kubernetes-admin/internals/notifier
github.com/stolostron/hub-of-hubs-kafka-transport/kafka-client/kafka-consumer
github.com/stolostron/hub-of-hubs-agent/pkg/helper
github.com/stolostron/hub-of-hubs-kafka-transport/kafka-client/kafka-producer
github.com/stolostron/hub-of-hubs-kafka-transport/kafka-client/kafka-producer/builder
github.com/stolostron/hub-of-hubs-agent/pkg/transport/consumer
github.com/qntfy/frafka
github.com/stolostron/hub-of-hubs-agent/pkg/transport/producer
github.com/lethexixin/go-funcs/library/platforms/kafka/consumer
github.com/lethexixin/go-funcs/library/platforms/kafka/producer
github.com/stolostron/leaf-hub-spec-sync/pkg/transport/kafka
github.com/stolostron/hub-of-hubs-spec-transport-bridge/pkg/transport/kafka
github.com/raystack/raccoon/publisher/kafka
github.com/raystack/raccoon/config
github.com/ant-libs-go/kafka/producer
github.com/ant-libs-go/kafka/consumer
github.com/core-go/kafka/confluent
github.com/common-go/kafka/confluent
github.com/mykube-run/keel/pkg/impl/transport
github.com/mykube-run/keel/cmd/kafka-producer
github.com/hetacode/command-es-repository-kafka
github.com/guil95/outbox/example_mongo
github.com/guil95/outbox
github.com/topfreegames/pusher/extensions
github.com/topfreegames/pusher/interfaces
github.com/topfreegames/pusher/mocks
github.com/debman/blacklog-exporter/internal/kafkaclient
github.com/rinkudesu/go-kafka/producer
github.com/bro-n-bro/spacebox-writer/adapter/broker
github.com/rinkudesu/go-kafka/subscriber
github.com/rinkudesu/go-kafka/configuration
github.com/bcowtech/lib-kafka
github.com/bcowtech/worker-kafka/internal
github.com/bcowtech/worker-kafka
github.com/velann21/todo-commonlib/async_jobs
github.com/alrusov/kafka
github.com/third-place/user-service/internal/util
github.com/third-place/user-service/internal/kafka
github.com/third-place/user-service/cmd/republish_user_to_kafka
github.com/danielmunro/otto-notification-service/internal/kafka
github.com/wangbokun/go/transfer/kafka
github.com/third-place/community-service/internal/kafka
github.com/third-place/community-service/internal/service
github.com/third-place/community-service/internal/util
github.com/amendge/go/transfer/kafka
github.com/sosalejandro/kafka-x-go/pkg/consumer
github.com/sosalejandro/kafka-x-go/pkg/observability
github.com/sosalejandro/kafka-x-go/pkg/producer
github.com/third-place/notification-service/internal/kafka
github.com/digitalocean/firebolt/node/kafkaconsumer
github.com/digitalocean/firebolt/examples/shared
github.com/digitalocean/firebolt/node/kafkaproducer
github.com/digitalocean/firebolt/message
github.com/digitalocean/firebolt/kafka
github.com/digitalocean/firebolt/util
github.com/third-place/image-service/internal/service
github.com/third-place/image-service/internal/util
github.com/third-place/image-service/internal/kafka
github.com/fajarardiyanto/flt-go-database/lib/kafka
github.com/squareup/pranadb/kafka
github.com/hibrid/statemachine2
github.com/alfredyang1986/blackmirror/bmkafka
github.com/danielmunro/otto-image-service/internal/service
github.com/danielmunro/otto-image-service/internal/kafka
github.com/adevinta/graph-vulcan-assets/stream/kafka
github.com/kkiling/kafka-lib/producer/producer.impl
github.com/kkiling/kafka-lib/consumer/consumer.impl
github.com/douglarek/kafka-tools/cmd/producer
github.com/douglarek/kafka-tools/cmd/consumer
github.com/qframe/handler-kafka
github.com/douglarek/kafka-tools
github.com/skroutz/downloader/backend/kafka_backend
github.com/deepfence/PacketStreamer/pkg/plugins/kafka
github.com/huantt/kafka-dump/impl
github.com/huantt/kafka-dump
github.com/YAOYouYou/go-toolkit/kafka
github.com/huantt/kafka-dump/pkg/kafka_utils
github.com/sermojohn/otelkafka
github.com/ri-nat/kafka-proto-monitor/internal/app
github.com/ri-nat/kafka-proto-monitor/internal/pkg/consumer
github.com/joshchu00/finance-go-common/kafka
github.com/hrojas2021/go-kafka-mongodb/pkg/kafka/confluentic
github.com/losfair/caddy-watch/interest
github.com/losfair/caddy-watch
github.com/rd-robin-senftleben/scanner-messaging/pkg/message/kafkabackend
github.com/merlinapp/queues-go/kafka
github.com/go-bamboo/contrib/client/confluent
github.com/Swiggy/grill/canned
github.com/Swiggy/grill/pkg/grillkafka
github.com/strangedev/kafka-golang/cmd/confluent_consumer
github.com/strangedev/kafka-golang/cmd/confluent_producer
github.com/fairyhunter13/kafkaclient
github.com/strangedev/kafka-golang/pkg
github.com/mithunril/kafka-message-scheduler/config
github.com/hewenyu/toolspackage/kafka_plus
github.com/hetacode/go-bus
github.com/mithunril/kafka-message-scheduler/internal/test
github.com/mithunril/kafka-message-scheduler/runner/kafka
github.com/mithunril/kafka-message-scheduler/schedule/kafka
github.com/mithunril/kafka-message-scheduler/store/kafka
github.com/Tracking-SYS/go-lib/kafka
github.com/flurn/callisto/types
github.com/flurn/callisto/kafka
github.com/flurn/callisto/kafka/consumer
github.com/m-pavel/firebolt/kafka
github.com/m-pavel/firebolt/message
github.com/m-pavel/firebolt/util
github.com/m-pavel/firebolt/node/kafkaproducer
github.com/m-pavel/firebolt/examples/shared
github.com/Basic-Components/connecthelper/kafkahelper
github.com/m-pavel/firebolt/node/kafkaconsumer
github.com/Boklazhenko/kafka
github.com/maksim-paskal/kafka-topic-admin/cmd
github.com/mario-imperato/r3ds9-apicommon/linkedservices/kafka
github.com/mario-imperato/r3ds9-apicommon/linkedservices
github.com/josvisser66/confluent-kafka-go/kafka/go_rdkafka_generr
github.com/maxim-kuderko/coeus/Io
github.com/dot-backend/synergetic-craft/kafka/producer
github.com/agriuseatstweets/go-pubbers/pubbers
github.com/dot-backend/synergetic-craft/kafka/consumer
github.com/luopengift/pkg/kafka2
github.com/JingIsCoding/kafka_job_queue
github.com/Golang-Tools/kafkahelper/producerproxy
github.com/strangedev/kafka-schema/pkg
github.com/Golang-Tools/kafkahelper/consumerproxy
github.com/amient/goconnect/io/kafka1
github.com/nakji-network/connector
github.com/nakji-network/connector/kafkautils
github.com/deltics/go-kafka/mock
github.com/deltics/go-kafka/hooks
github.com/deltics/go-kafka
github.com/Golang-Tools/kafkahelper/msghelper
github.com/JuanDiegoCastellanos/kafka_golang
github.com/team-triage/triage/types
github.com/team-triage/triage/fetcher
github.com/team-triage/triage/reaper
github.com/team-triage/triage/utils
github.com/team-triage/triage/channels/commits
github.com/team-triage/triage/channels/messages
github.com/solutioncrafting/kafkaandgo/cmd/serviceone
github.com/solutioncrafting/kafkaandgo/cmd/servicetwo
github.com/fomichalopoulos/companiesMicroService
github.com/fomichalopoulos/companiesMicroService/helpers
github.com/fomichalopoulos/companiesMicroService/swagger
github.com/iamviniciuss/wallet-core-eda/balance-api/internal/infra/broker
github.com/protsack-stephan/wme-architecture-poc/bridge
github.com/blendle/pg2kafka
github.com/blacksmith-vish/sso/cmd/kafka
github.com/ODawah/url-shortener/kafka
github.com/consolelabs/mochi-toolkit/kafka
github.com/Aamir-Lone/go-kafka/consumer
github.com/Aamir-Lone/go-kafka/producer
github.com/luyenw/tech-training/go-kafka
github.com/confluentinc/schema-deletion-tool/pkg
github.com/n-kazachuk/go_tg_bot/internal/app/adapters/secondary/kafka-adapter-publisher
github.com/reshiadavan/cryptgo/memorystore
github.com/reshiadavan/cryptgo/sql
github.com/reshiadavan/cryptgo/ws
github.com/reshiadavan/cryptgo/wallet/ethereum
github.com/ArtemVoronov/indefinite-studies-utils/pkg/services/kafka
github.com/netrebel/kafka-with-go/producer
github.com/netrebel/kafka-with-go/consumer
github.com/corabank/goneli
github.com/mchirico/k8skafka/pkg/utils
github.com/mchirico/k8skafka/pkg/wrapper
github.com/mchirico/k8skafka/temperature/pubsub
github.com/headend/share-module/MQ
github.com/scliangx/webServerTools/internal/kafka
github.com/aclk/goblog/common/kafka
github.com/azure/azure-event-hubs-for-kafka/tutorials/oauth/go/consumer
github.com/Corner-W/sk/mque/kfk
github.com/salesof7/go_kafka-simulator-fs
github.com/salesof7/go_kafka-simulator-fs/app/kafka
github.com/salesof7/go_kafka-simulator-fs/infra/kafka
github.com/MatheusNP/fc-ms-wallet/pkg/kafka
github.com/MatheusNP/fc-ms-wallet/cmd/walletcore
github.com/ShelbyKS/Roamly-backend/notifier
github.com/ShelbyKS/Roamly-backend/pkg/kafka
github.com/supersherm5/movie-app/rating/internal/ingester/kafka
github.com/exsmund/grpc-psql-example/services/server
github.com/MihasBel/test-transactions-service/adapters/broker
github.com/hyuti/consumer-blueprint/pkg/kafka
github.com/hyuti/consumer-blueprint/internal/app
github.com/amrHassanAbdallah/notificationaway/test
github.com/erdemkosk/box_bridge/pkg
github.com/erdemkosk/box_bridge/internal/kafka
github.com/exsmund/grpc-psql-example/services/logger
github.com/datacircus/highwire/service/server
github.com/geoffwilliams/kscanner/cmd/main
github.com/devfullcycle/gointensivo2/pkg/kafka
github.com/gosom/kit/es/kafka
github.com/Telefonica/prometheus-kafka-adapter
github.com/datasage-io/datasage/src/integrations
github.com/liusuxian/go-toolkit/gtkkafka
github.com/hdlproject/es-transaction-service/interface_adapter/messaging
github.com/CrowdStrike/kafka-replicator/pkg/stores
github.com/s-larionov/async-kafka
github.com/s-larionov/async-kafka/examples
github.com/CrowdStrike/kafka-replicator/pkg/kafka
github.com/CrowdStrike/kafka-replicator/pkg/ingress
github.com/Goboolean/fetch-system.IaC/pkg/kafka
github.com/Goboolean/fetch-system.IaC/internal/kafka
github.com/Goboolean/common/deprecated/broker
github.com/Goboolean/common/pkg/kafka
github.com/rverma-nsl/kafka-schemaregistry-protobuf
github.com/samutayuga/sam-twitter-go/kafkist
github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/multikcat/confluent/producer
github.com/ramseyjiang/go_mid_to_senior/pkgusages/kafka/multikcat/confluent/consumer
github.com/qudj/fly_lib/confluent_kafka
github.com/redborder/events-counter/cmd
github.com/redhatinsights/export-service-go/cmd/export-service
github.com/redhatinsights/export-service-go/exports
github.com/redhatinsights/export-service-go/kafka
github.com/AdrianeRibeiro/CodePix/application/kafka
github.com/AdrianeRibeiro/CodePix/cmd
github.com/welly87/go-telegram-bot
github.com/ignalina/shredder/fixed2avro
github.com/ignalina/shredder/kafkaavro
github.com/redhatinsights/edge-api/pkg/common/kafka/mock_kafka
github.com/redhatinsights/edge-api/pkg/common/kafka
github.com/redhatinsights/edge-api/pkg/services
github.com/jadoint/micro/pkg/msgqueue
github.com/razorpay/metro/pkg/messagebroker
github.com/iwanjunaid/basesvc/adapter/repository/event
github.com/iwanjunaid/basesvc/infrastructure/rest
github.com/iwanjunaid/basesvc/infrastructure/mokabox
github.com/iwanjunaid/basesvc/infrastructure/datastore
github.com/iwanjunaid/basesvc/infrastructure/consumer
github.com/iwanjunaid/basesvc/internal/kafka
github.com/iwanjunaid/basesvc/cmd
github.com/iwanjunaid/basesvc/registry
github.com/avisiedo/go-microservice-1/internal/interface/presenter/event
github.com/ArnaudGallardo/rocktest-go/scenario
github.com/ninglg/golang-example/kafka/consumer2
github.com/enkodio/pkg-kafka/internal/pkg/config/entity
github.com/Goboolean/fetch-system.worker/internal/infrastructure/kafka
github.com/podengo-project/idmsvc-backend/internal/infrastructure/event/producer
github.com/kafka-go-streams/kafka-go-streams
github.com/podengo-project/idmsvc-backend/internal/infrastructure/event/adapter
github.com/podengo-project/idmsvc-backend/internal/infrastructure/event/handler
github.com/podengo-project/idmsvc-backend/internal/handler/impl
github.com/clunc/hr-monitor-ble-server/pkg/kafka
github.com/04Akaps/kafka-go/server/service
github.com/04Akaps/kafka-go/server/repository/kafka
github.com/1Prestes/gointensivo2/pkg/kafka
github.com/1Prestes/gointensivo2/cmd/consumer
github.com/64bitAryan/go-microservice/data_receiver
github.com/Aldiwildan77/backend-skeleton/config
github.com/Aldiwildan77/backend-skeleton/libs/kafka
github.com/axelgeorg/ImersaoGo_03022023/cmd/app
github.com/podengo-project/idmsvc-backend/internal/api/event
github.com/HsiaoCz/code-beast/tollcalc/data_receiver
github.com/codingDr/watermill-kafka/pkg/kafka
github.com/GustavoEklund/payment-gateway-api/main
github.com/GustavoEklund/payment-gateway-api/infra/brokers/kafka
github.com/JonatasMSantos/golang-apis-messaging-hexagonal-architecture/cmd/app
github.com/JonatasMSantos/golang-apis-messaging-hexagonal-architecture/internal/infra/akafka
github.com/JPauloMoura/payment-gateway/cmd
github.com/JPauloMoura/payment-gateway/adapter/broker/kafka
github.com/denizumutdereli/golang-K8-microservice-probs/internal/transport
github.com/emilebui/demoX-rk_worker/pkg/conn
github.com/emilebui/demoX-rk_worker/cmd/admin
github.com/emilebui/demoX-rk_worker/cmd/producer
github.com/emilebui/demoX-rk_worker/internal/services
github.com/emilebui/demoX-rk_worker/internal/handlers
github.com/joaomarcosbc/imersaoFC-ms/cmd/freight
github.com/Chavozoom/go-Kafka/cmd/consumer
github.com/Chavozoom/go-Kafka/cmd/producer
github.com/CelsoTaliatelli/ms-walletconsumer/cmd
github.com/CelsoTaliatelli/ms-walletconsumer/pkg/kafka
github.com/Goboolean/fetch-server.v1/internal/infrastructure/kafka
github.com/Brigant/AGS/kafka/analitic-consumer
github.com/Brigant/AGS/kafka/manager-consumer
github.com/Brigant/AGS/kafka/online-store-produser
github.com/jdaniloc/Individual-FullCycle-01
github.com/jdaniloc/Individual-FullCycle-01/application/kafka
github.com/jdaniloc/Individual-FullCycle-01/infra/kafka
github.com/giovane-aG/imersaofsfc2-simulator
github.com/giovane-aG/imersaofsfc2-simulator/application/kafka
github.com/giovane-aG/imersaofsfc2-simulator/infra/kafka
github.com/GabrielGasp/kafka-example/cmd/consumer
github.com/GabrielGasp/kafka-example/cmd/producer
github.com/denison3965/CodePix/cmd
github.com/denison3965/CodePix/application/kafka
github.com/Feruz666/gokafka/producer
github.com/jackduh/goKafka/cmd
github.com/jackduh/goKafka/datateam
github.com/jackduh/goKafka/processor
github.com/JulioZittei/homebroker-matcher-go/cmd/trade
github.com/JulioZittei/homebroker-matcher-go/internal/infra/kafka
github.com/Deciohanda/gointensivo/pkg/kafka
github.com/Deciohanda/gointensivo/cmd/consumer
github.com/EfimoffN/receivingLogs/dbapi/kafkadb
github.com/EliasOlie/IFF-Kafka/kafka/consumer
github.com/EliasOlie/IFF-Kafka/kafka/producer
github.com/lucasAzS/psychic-octo-garbanzo
github.com/lucasAzS/psychic-octo-garbanzo/application/kafka
github.com/lucasAzS/psychic-octo-garbanzo/infra/kafka
github.com/j03hanafi/kafkaGo
github.com/bucaojit/PolygonTools/streamer
github.com/burhankangsi/LetsYouTube/bucket_api
github.com/joseluis8906/project-layout/pkg/kafka
github.com/whj1990/go-core/store
github.com/raffops/chat/cmd/api
github.com/raffops/chat/internal/app/chat
github.com/8xmx8/easier/pkg/amqp/confluent
github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/admin/config_describe
github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/producer/channel
github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/consumer/channel/channel_consumer
github.com/jay-SP/movieapplication/ratingingester
github.com/jay-SP/movieapplication/rating/internal/ingester/kafka
github.com/aeekayy/stilla/service/pkg/api
github.com/aeekayy/stilla/service/pkg/models
github.com/dawei101/gor/rkafka
github.com/cpustejovsky/franz
github.com/protsack-stephan/wme-architecture-poc/store
github.com/lucasrgt/go-microservice/pkg/kafka
github.com/lucasrgt/go-microservice/cmd/freight
github.com/matthogan/polypully-events
github.com/soyacen/easypubsub/ckafka/example
github.com/burhankangsi/Flash-API/bucket_api
github.com/roserossi/proyecto-ds-iii/kafka-server/go/kafkaPlugin
github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/producer
github.com/danyukod/chave-pix-utils/pkg/kafka
github.com/Streamfair/streamfair_idp/kafka_
github.com/n-kazachuk/go_parser/internal/app/adapters/primary/kafka-adapter-subscriber
github.com/n-kazachuk/go_parser/internal/app/adapters/primary/kafka-adapter-subscriber/kafka-handler
github.com/bondzai/portfolio-backend/pkg/kafka
github.com/JordanRad/notification-system-assignment/internal/message_queue
github.com/JordanRad/notification-system-assignment/internal/service/dispatcher_service
github.com/iamviniciuss/wallet-core-eda/balance-api/pkg/kafka
github.com/iamviniciuss/wallet-core-eda/wallet-core-api/pkg/kafka
github.com/iamviniciuss/wallet-core-eda/wallet-core-api/cmd/walletcore
github.com/iamviniciuss/wallet-core-eda/wallet-core-api/scripts/database
github.com/BladeCKG/blockhouse-realtime-data-streaming-api-golang/mykafka
github.com/AYGA2K/go-kafka
github.com/AYGA2K/go-kafka/processor
github.com/04Akaps/gateway_module/kafka
github.com/qml-123/AppService/pkg/producer
github.com/qml-123/AppService/pkg/consumer/kafka
github.com/TomasCruz/users/internal/infra/kafkaque
github.com/josenaldo/fc-gokafka/cmd/producer
github.com/podengo-project/idmsvc-backend/internal/interface/event
github.com/santosant/codepix/cmd
github.com/santosant/codepix/application/kafka
github.com/agniBit/whatsapp/pkg/worker
github.com/agniBit/whatsapp/pkg/whatsapp
github.com/agniBit/whatsapp/pkg/api
github.com/agniBit/whatsapp/pkg/test
github.com/agniBit/whatsapp/util/config
github.com/agniBit/whatsapp/pkg/whatsapp/worker/event
github.com/bytemoves/toll-calculator/distance_calculator
github.com/jhq0113/gochat/lib/pubsub
github.com/danilobandeira29/ms-wallet/pkg/kafka
github.com/danilobandeira29/ms-wallet/cmd/walletcore
github.com/legolas145/kafkawrapper/kafka/consumer
github.com/legolas145/kafkawrapper/kafka/producer
github.com/OpenFactor-Holding/superapp/kafka
github.com/hmuir28/go-thepapucoin-rest/kafka
github.com/supersherm5/movie-app/ratingIngester/cmd
github.com/EvertonLMsilva/api-avulso/internal/infra/akafka
github.com/MajotraderLucky/Kafka-FIO-Listener/checker
github.com/hyperbolicresearch/hlog/utils
github.com/hyperbolicresearch/hlog/internal/kafkaservice
github.com/hyperbolicresearch/hlog/internal/ingest
github.com/go-hasaki/hasaki-layout-advanced/pkg/xkafka/consumer
github.com/go-hasaki/hasaki-layout-advanced/pkg/xkafka/producer
github.com/tiksup/tiksup-kafka-worker/internal/config
github.com/tiksup/tiksup-kafka-worker/internal/service
github.com/tiksup/tiksup-kafka-worker/cmd/tiksup
github.com/stwrtrio/coffee-shop/pkg/kafka
github.com/ugurcancaykara/odd-service/cmd/ratingingester
github.com/devfullcycle/gointensivo2/cmd/consumer
github.com/anupam0601/golang-stuff/microservices/kafka-to-mongo
github.com/anupam0601/golang-stuff/microservices/rest-to-kafka
github.com/azure/azure-event-hubs-for-kafka/quickstart/go/consumer
github.com/azure/azure-event-hubs-for-kafka/quickstart/go/producer
github.com/sdx13/csv2kafka/cmd/kafka2csv
github.com/ryanpfalz/go-openapi/internal/kafka
github.com/ryanpfalz/go-openapi/cmd/elasticsearch-indexer-kafka
github.com/ryanpfalz/go-openapi/cmd/internal
github.com/tx7do/go-kafka-example/confluent
github.com/diegopacheco/go-playground/kafka
github.com/tonnytg/lightbank/adapter/broker/kafka
github.com/tonnytg/lightbank/cmd
github.com/donvito/learngo/rest-kafka-mongo-microservice/rest-to-kafka
github.com/donvito/learngo/rest-kafka-mongo-microservice/kafka-to-mongo
github.com/donvito/learngo/kafka/producer
github.com/donvito/learngo/kafka/consumer
github.com/fabiotavarespr/liveProject-asynchronous-event-handling/platform/consumers
github.com/fabiotavarespr/liveProject-asynchronous-event-handling/platform/producers
github.com/alexsjones/frontier/components/kafka
github.com/ijsong/farseer/pkg/kafka
github.com/CrowdStrike/kafka-replicator/pkg/egress
github.com/CrowdStrike/kafka-replicator/pkg/compaction
github.com/CrowdStrike/kafka-replicator/pkg/core
github.com/cloudkarafka/cloudkarafka-manager/store
github.com/cloudkarafka/cloudkarafka-manager/server/api
github.com/CrowdStrike/kafka-replicator/tests
github.com/samutayuga/sam-twitter-go/consumer
github.com/confluentinc/confluent-kafka-go-dev/examples/admin_create_topic
github.com/confluentinc/confluent-kafka-go-dev/examples/admin_delete_topics
github.com/confluentinc/confluent-kafka-go-dev/examples/admin_describe_config
github.com/confluentinc/confluent-kafka-go-dev/examples/confluent_cloud_example
github.com/confluentinc/confluent-kafka-go-dev/examples/consumer_channel_example
github.com/confluentinc/confluent-kafka-go-dev/examples/consumer_example
github.com/confluentinc/confluent-kafka-go-dev/examples/idempotent_producer_example
github.com/confluentinc/confluent-kafka-go-dev/examples/oauthbearer_example
github.com/confluentinc/confluent-kafka-go-dev/examples/producer_channel_example
github.com/confluentinc/confluent-kafka-go-dev/examples/producer_example
github.com/confluentinc/confluent-kafka-go-dev/examples/stats_example
github.com/confluentinc/confluent-kafka-go-dev/kafkatest/go_verifiable_consumer
github.com/confluentinc/confluent-kafka-go-dev/kafkatest/go_verifiable_producer
github.com/BaianorASR/ifc2-simulator/infra/kafka
github.com/comp1x/final-task/customer/pkg/app
github.com/comp1x/final-task/kafka/cmd/main
github.com/andrew-hillier/protocol-buffers
github.com/palomasoftware/msds434_module_eight_kafka_demo
github.com/JeffRisberg/LiveProjectAsynchronousEventsWithKafka/publisher
github.com/podengo-project/idmsvc-backend/internal/infrastructure/event
github.com/reshiadavan/cryptgo/match
github.com/podengo-project/idmsvc-backend/internal/test/mock/infrastructure/event
github.com/podengo-project/idmsvc-backend/internal/test/mock/interface/event
github.com/podengo-project/idmsvc-backend/internal/test/mock/infrastructure/event/handler
github.com/enkodio/pkg-kafka/kafka
github.com/enkodio/pkg-kafka/client
github.com/enkodio/pkg-kafka/internal/kafka/entity
github.com/enkodio/pkg-kafka/internal/kafka/logic
github.com/anupam0601/golang-stuff/go-kafka-consumer
github.com/anupam0601/golang-stuff/go-kafka/kafka-producer
github.com/liguoqinjim/go-labs/lab173/lab002
github.com/liguoqinjim/go-labs/lab173/lab001
github.com/redhatinsights/payload-tracker-go/internal/kafka
github.com/yurii-vyrovyi/kafkalib
github.com/redborder/dswatcher/cmd
github.com/0xAckerMan/movieapp-ms/src/cmd/ratingingester
github.com/0xAckerMan/movieapp-ms/rating/internal/ingester/kafka
github.com/AndersonQ/gokafka
github.com/AndersonQ/gokafka/kafka
github.com/andrewunifei/SOLID-system/cmd/app
github.com/andrewunifei/SOLID-system/internal/infra/akafka
github.com/ArtemVoronov/indefinite-studies-feed-builder-service/internal/services/feed
github.com/tomassar/microservices-with-kafka
github.com/adamatti/sandboxgo/Kafka
github.com/arcosx/Sirius/kafka/consumer
github.com/arcosx/Sirius/kafka/producer
github.com/arcosx/Sirius/kafka/isolation
github.com/arcosx/Sirius/kafka/grpc
github.com/axelgeorg/ImersaoGo_03022023/internal/infra/akafka
github.com/Drinnn/kool-pix/cmd
github.com/Drinnn/kool-pix/application/kafka
github.com/JulioOLV/codebank/infrastructure/kafka
github.com/KaueSabinoSRV17/DeliveryGoSimulator
github.com/KaueSabinoSRV17/DeliveryGoSimulator/infra/kafka
github.com/GODPARK/KafValidator/consumer
github.com/GODPARK/KafValidator/producer
github.com/emilebui/demoX-rk_api/internal/repositories
github.com/emilebui/demoX-rk_api/pkg/conn
github.com/devAndre-Isaac/simulator-full-cycle
github.com/devAndre-Isaac/simulator-full-cycle/application/kafka
github.com/devAndre-Isaac/simulator-full-cycle/infra/kafka
github.com/joaomarcosbc/imersaoFC-ms/pkg/kafka
github.com/BrunoC0102/imersao-fullcycle-13/cmd/trade
github.com/BrunoC0102/imersao-fullcycle-13/internal/infra/kafka
github.com/JoaoRafa19/codepix/application/kafka
github.com/EliasSantiago/kafka-example/infra/kafka
github.com/Dmitrij-Kochetov/peoples/internal/adapter/kafka
github.com/Dmitrij-Kochetov/peoples/internal/application/presentation/kafka
github.com/gabsferrara/kafka-go-POC/cmd/consumer
github.com/gabsferrara/kafka-go-POC/cmd/producer
github.com/Julio-Norberto/api-message/cmd/api
github.com/Julio-Norberto/api-message/internal/infra/akafka
github.com/Harmew/imersao12-go-esquenta/cmd/app
github.com/Harmew/imersao12-go-esquenta/internal/infra/akafka
github.com/Guilherme-daCosta/go-mensageria-products/cmd/app
github.com/Guilherme-daCosta/go-mensageria-products/internal/infra/akafka
github.com/Halgenthaler/System-Delivery
github.com/Halgenthaler/System-Delivery/infra/kafka
github.com/Halgenthaler/System-Delivery/app/kafka
github.com/Carlos-Descalzi/mtjobrunner/pkg/controller/mtjobrunner
github.com/HyAgOsK/home_broker_full_cycle/cmd/trade
github.com/HyAgOsK/home_broker_full_cycle/internal/infra/kafka
github.com/Junkes887/queues/cmd/app
github.com/Junkes887/queues/internal/infra/kafkaConsumer
github.com/GuiCintra27/go/projects/api_and_messaging_project/cmd/app
github.com/GuiCintra27/go/projects/api_and_messaging_project/internal/infra/akafka
github.com/ItaloG/full-cycle-walletcore/pkg/kafka
github.com/ItaloG/full-cycle-walletcore/cmd/wallercore
github.com/Cristianoaf81GIT/codebank/infrastructure/kafka
github.com/Lemos1347/inteli-modulo-9-prova-2/internal/kafka
github.com/Lemos1347/inteli-modulo-9-prova-2/cmd/consumer
github.com/EdSwArchitect/go-kafka
github.com/GirishBhutiya/mqtt-kafka-bridge/internal
github.com/LostPetInitiative/CardMatcher/kafkajobs
github.com/derekyu332/goii/frame/kafka
github.com/rcttavares/codepix/cmd
github.com/rcttavares/codepix/application/kafka
github.com/Danny5487401/go_package_example/03_amqp/02_kafka/02_confluent-kafka/consumer