kafka_file

package

v0.76.0 Latest Latest Go to latest Published: Feb 2, 2026 License: BSD-3-Clause Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Topics    []string
	Brokers   []string
	FilesDir  string
	Count     int
	RetTime   string
	Partition int
}

Config for kafka-file plugin e2e test

func (c *Config) Configure(t *testing.T, conf *cfg.Config, pipelineName string)

Configure sets additional fields for input and output plugins

func (c *Config) Send(t *testing.T)

Send creates a Partition of messages (one for each partition) and sends them Count times to kafka

func (c *Config) Validate(t *testing.T)

Validate waits for the message processing to complete