kafkaplugin

package

v2.2.0+incompatible Latest Latest Go to latest Published: Aug 23, 2019 License: Apache-2.0 Imports: 0 Imported by: 0

Details

Package kafkaplugin contains multiple examples with the kafka plugin.

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