kafka

Documentation

Index

• func New(ctx context.Context, secretInterface corev1.SecretInterface, ...) (source.Interface, error)
• type Stats

Functions

func New

func New(ctx context.Context, secretInterface corev1.SecretInterface, consumerGroupID, sourceName, sourceURN string, replica int, x dfv1.KafkaSource, process source.Process) (source.Interface, error)

Types

type Stats

type Stats struct {
	Topics map[string]struct {
		Partitions map[string]struct {
			ConsumerLag int64 `json:"consumer_lag"`
		} `json:"partitions"`
	} `json:"topics"`
}