examples/

directory
Version: v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 2020 License: Apache-2.0

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
Create topic
Create topic
Delete topics
Delete topics
List current configuration for a cluster resource
List current configuration for a cluster resource
Example channel-based high-level Apache Kafka consumer
Example channel-based high-level Apache Kafka consumer
Example function-based high-level Apache Kafka consumer
Example function-based high-level Apache Kafka consumer
Example Apache Kafka consumer that commit offset with metadata
Example Apache Kafka consumer that commit offset with metadata
Example kafkacat clone written in Golang
Example kafkacat clone written in Golang
Example client with a custom OAUTHBEARER token implementation.
Example client with a custom OAUTHBEARER token implementation.
Example channel-based Apache Kafka producer
Example channel-based Apache Kafka producer
Example function-based Apache Kafka producer
Example function-based Apache Kafka producer
Example of a consumer handling statistics events.
Example of a consumer handling statistics events.

Jump to

Keyboard shortcuts

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