kafka

package
v0.1.20 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 7, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL