Categorygithub.com/goto/entropypkgkafka
package
0.2.7-rc
Repository: https://github.com/goto/entropy.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
2
Files
95 SLOC

# Functions

DoReset executes a kubernetes job with kafka-consumer-group.sh installed to reset offset policy for the given consumer id on all topics.
ParseResetParams parses the given JSON data as reset parameters value and returns the actual reset value to be used with DoReset().
ParseResetV2Params parses the given JSON data as reset parameters value and returns the actual reset value to be used with DoReset().

# Structs

No description provided by the author
No description provided by the author