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