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 |
---|---|
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 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. |
Click to show internal directories.
Click to hide internal directories.