README
¶
Examples
admin_create_acls - Create Access Control Lists
admin_create_topic - Create a topic
admin_delete_acls - Delete Access Control Lists using different filters
admin_delete_topics - Delete some topics
admin_describe_acls - Find Access Control Lists using a filter
admin_describe_config - Describe broker, topic or group configs
avro_generic_consumer_example - consumer with Schema Registry and Avro Generic Deserializer
avro_generic_producer_example - producer with Schema Registry and Avro Generic Serializer
avro_specific_consumer_example - consumer with Schema Registry and Avro Specific Deserializer
avro_specific_producer_example - producer with Schema Registry and Avro Specific Serializer
consumer_example - Function & callback based consumer
consumer_offset_metadata - Commit offset with metadata
cooperative_consumer_example - Using the cooperative incremental rebalancing protocol
confluent_cloud_example - Usage example with Confluent Cloud
go-kafkacat - Channel based kafkacat Go clone
idempotent_producer_example - Idempotent producer
json_consumer_example - consumer with Schema Registry and JSON Schema Deserializer
json_producer_example - producer with Schema Registry and JSON Schema Serializer
legacy - Legacy examples
library-version - Show the library version
mockcluster_example - Use a mock cluster for testing
oauthbearer_consumer_example - Unsecured SASL/OAUTHBEARER consumer example
oauthbearer_oidc_example - SASL/OAUTHBEARER with OIDC method example
oauthbearer_producer_example - Unsecured SASL/OAUTHBEARER producer example
producer_custom_channel_example - Function based producer with a custom delivery channel
producer_example - Function based producer
protobuf_consumer_example - consumer with Schema Registry and Protocol Buffers Deserializer
protobuf_producer_example - producer with Schema Registry and Protocol Buffers Serializer
stats_example - Receiving stats events
transactions_example - Showcasing a transactional consume-process-produce application
Usage example
$ cd consumer_example
$ go build (or 'go install')
$ ./consumer_example # see usage
$ ./consumer_example mybroker mygroup mytopic
Directories
¶
| Path | Synopsis |
|---|---|
|
Create ACLs
|
Create ACLs |
|
Create topic
|
Create topic |
|
Delete ACLs
|
Delete ACLs |
|
Delete topics
|
Delete topics |
|
Describe ACLs
|
Describe ACLs |
|
List current configuration for a cluster resource
|
List current configuration for a cluster resource |
|
Example function-based high-level Apache Kafka consumer
|
Example function-based high-level Apache Kafka consumer |
|
Example function-based Apache Kafka producer
|
Example function-based Apache Kafka producer |
|
Example function-based high-level Apache Kafka consumer
|
Example function-based high-level Apache Kafka consumer |
|
Example function-based Apache Kafka producer
|
Example function-based Apache Kafka producer |
|
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 function-based high-level Apache Kafka consumer
|
Example function-based high-level Apache Kafka consumer |
|
Example function-based Apache Kafka producer
|
Example function-based Apache Kafka producer |
|
legacy
|
|
|
consumer_channel_example
Example channel-based high-level Apache Kafka consumer
|
Example channel-based high-level Apache Kafka consumer |
|
producer_channel_example
Example channel-based Apache Kafka producer
|
Example channel-based Apache Kafka producer |
|
Example consumer with a custom OAUTHBEARER token implementation.
|
Example consumer with a custom OAUTHBEARER token implementation. |
|
Example producer with a custom OAUTHBEARER token implementation.
|
Example producer with a custom OAUTHBEARER token implementation. |
|
Example function-based Apache Kafka producer with a custom delivery channel
|
Example function-based Apache Kafka producer with a custom delivery channel |
|
Example function-based Apache Kafka producer
|
Example function-based Apache Kafka producer |
|
Example function-based high-level Apache Kafka consumer
|
Example function-based high-level Apache Kafka consumer |
|
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. |