package
0.7.0
Repository: https://github.com/flow-lab/flow.git
Documentation: pkg.go.dev

# Functions

NewFlowKafka create new instance of service.

# Structs

Broker represents kafka broker.
ConfigEntry represents topic configuration.
No description provided by the author
Metadata represents topics details.
No description provided by the author
Topic represents kafka topic.

# Interfaces

FlowKafka is an interface representing operations that can be executed with Kafka Cluster.