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