examples/

directory
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

Examples:

  consumer_channel_example - Channel based consumer
  consumer_example - Function & callback based consumer

  producer_channel_example - Channel based producer
  producer_example - Function based producer

  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
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.
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 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