Categorygithub.com/confluentinc/examplesclientscloudgo
package
7.9.0+incompatible
Repository: https://github.com/confluentinc/examples.git
Documentation: pkg.go.dev
Overview
Versions
3
Dependencies
9
Dependents
0
Files
180 SLOC

# README

Overview

Produce messages to and consume messages from a Kafka cluster using Confluent Golang Client for Apache Kafka.

Documentation

You can find the documentation and instructions for running this Go example at https://docs.confluent.io/platform/current/tutorials/examples/clients/docs/go.html

# Packages

No description provided by the author

# Functions

CreateTopic creates a topic using the Admin Client API.

# Type aliases

RecordValue represents the struct of the value in a Kafka message.
RecordValue represents the struct of the value in a Kafka message.