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 high-level Apache Kafka consumer using the cooperative incremental rebalancing protocol which allows seamless reassignment of partitions to other group members.
|
Example high-level Apache Kafka consumer using the cooperative incremental rebalancing protocol which allows seamless reassignment of partitions to other group members. |
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.