Categorygithub.com/kipling-engineering/kipling-cn-infraexampleskafka-plugin
package
0.1.1
Repository: https://github.com/kipling-engineering/kipling-cn-infra.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
0
Dependents
0
Files
0

# Packages

Example "hash-partitioner" demonstrates the use of Kafka plugin API with automatic (hash-based) partitioning.
Example "manual-partitioner" demonstrates the use of Kafka plugin API with a focus on manual partitioning.
Example "later-stage" demonstrates the use partition watcher initialized and used after multiplexer Init().