kafka

Documentation

Index

• func DoReset(ctx context.Context, jobCluster *kube.Client, ...) error
• func ParseResetParams(bytes json.RawMessage) (string, error)
• type ResetParams

Functions

func DoReset

func DoReset(ctx context.Context, jobCluster *kube.Client, kubeNamespace, kafkaBrokers, kafkaConsumerID, kafkaResetValue string) error

DoReset executes a kubernetes job with kafka-consumer-group.sh installed to reset offset policy for the given consumer id on all topics.

func ParseResetParams

func ParseResetParams(bytes json.RawMessage) (string, error)

ParseResetParams parses the given JSON data as reset parameters value and returns the actual reset value to be used with DoReset().

Types

type ResetParams

type ResetParams struct {
	To       string `json:"to"`
	Datetime string `json:"datetime"`
}