kafka

Documentation

Index

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

Functions

func DoReset

func DoReset(ctx context.Context, jobCluster *kube.Client, kubeNamespace, kafkaBrokers, kafkaConsumerID, kafkaResetValue, resetJobName 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().

func ParseResetV2Params

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

ParseResetV2Params 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"`
}

type ResetV2Params

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