confluent-kafka-go-dev

module
Version: v0.0.0-...-f818fd3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2021 License: Apache-2.0

README

DO NOT USE THIS REPOSITORY

This is an outdated proof-of-concept repo that must no longer be used.

Use the proper confluent-kafka-go client instead.

THIS REPOSITORY WILL BE REMOVED

Directories

Path Synopsis
examples
admin_create_topic
Create topic
Create topic
admin_delete_topics
Delete topics
Delete topics
admin_describe_config
List current configuration for a cluster resource
List current configuration for a cluster resource
confluent_cloud_example
This is a simple example demonstrating how to produce a message to Confluent Cloud then read it back again.
This is a simple example demonstrating how to produce a message to Confluent Cloud then read it back again.
consumer_channel_example
Example channel-based high-level Apache Kafka consumer
Example channel-based high-level Apache Kafka consumer
consumer_example
Example function-based high-level Apache Kafka consumer
Example function-based high-level Apache Kafka consumer
go-kafkacat
Example kafkacat clone written in Golang
Example kafkacat clone written in Golang
oauthbearer_example
Example client with a custom OAUTHBEARER token implementation.
Example client with a custom OAUTHBEARER token implementation.
producer_channel_example
Example channel-based Apache Kafka producer
Example channel-based Apache Kafka producer
producer_example
Example function-based Apache Kafka producer
Example function-based Apache Kafka producer
stats_example
Example of a consumer handling statistics events.
Example of a consumer handling statistics events.
Package kafka provides high-level Apache Kafka producer and consumers using bindings on-top of the librdkafka C library.
Package kafka provides high-level Apache Kafka producer and consumers using bindings on-top of the librdkafka C library.
go_rdkafka_generr
confluent-kafka-go internal tool to generate error constants from librdkafka
confluent-kafka-go internal tool to generate error constants from librdkafka
kafkatest
go_verifiable_consumer
Apache Kafka kafkatest VerifiableConsumer implemented in Go
Apache Kafka kafkatest VerifiableConsumer implemented in Go
go_verifiable_producer
Apache Kafka kafkatest VerifiableProducer implemented in Go
Apache Kafka kafkatest VerifiableProducer implemented in Go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL