examples/

Details

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

Repository

github.com/finncolman/confluent-kafka-go

Links

Open Source Insights

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


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

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