examples/

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/confluentinc/confluent-kafka-go

Links

Open Source Insights

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 ¶

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

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
cooperative_consumer_example Example high-level Apache Kafka consumer using the cooperative incremental rebalancing protocol which allows seamless reassignment of partitions to other group members.	Example high-level Apache Kafka consumer using the cooperative incremental rebalancing protocol which allows seamless reassignment of partitions to other group members.
go-kafkacat Example kafkacat clone written in Golang	Example kafkacat clone written in Golang
idempotent_producer_example
library-version
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