examples/

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/aw-was-here/confluent-kafka-go

README ¶

Examples:

consumer_channel_example - Channel based consumer consumer_example - Function & callback based consumer consumer_offset_metadata - Commit offset with metadata

producer_channel_example - Channel based producer producer_example - Function based producer

transactions_example - Showcasing a transactional consume-process-produce application

go-kafkacat - Channel based kafkacat Go clone

oauthbearer_example - Provides unsecured SASL/OAUTHBEARER example

Usage example:

$ cd consumer_example
$ go build   (or 'go install')
$ ./consumer_example    # see usage
$ ./consumer_example mybroker mygroup mytopic

Directories ¶

Path	Synopsis
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
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
consumer_offset_metadata Example Apache Kafka consumer that commit offset with metadata	Example Apache Kafka consumer that commit offset with metadata
go-kafkacat Example kafkacat clone written in Golang	Example kafkacat clone written in Golang
idempotent_producer_example
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.
transactions_example

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL