kafka

type Config struct {
	SchemaRegistry     string `pipelane:"schema_registry"`
	pipelaner.Internal `pipelane:",squash"`
}

type ConsumerConfig struct {
	Kafka             `pipelane:",squash"`
	Config            `pipelane:",squash"`
	AutoCommitEnabled bool   `pipelane:"auto_commit_enabled"`
	ConsumerGroupID   string `pipelane:"consumer_group_id"`

	MaxPartitionFetchBytes string   `pipelane:"max_partition_fetch_bytes"`
	AutoOffsetReset        string   `pipelane:"auto_offset_reset"`
	FetchMaxBytes          string   `pipelane:"fetch_max_bytes"`
	BalancerStrategy       []string `pipelane:"balancer_strategy"`
}

type Kafka struct {
	SASLEnabled   bool     `pipelane:"sasl_enabled"`
	SASLMechanism string   `pipelane:"sasl_mechanism"`
	SASLUsername  string   `pipelane:"sasl_username"`
	SASLPassword  string   `pipelane:"sasl_password"`
	Brokers       string   `pipelane:"brokers"`
	Version       string   `pipelane:"version"`
	Topics        []string `pipelane:"topics"`
}

type ProducerConfig struct {
	Kafka            `pipelane:",squash"`
	Config           `pipelane:",squash"`
	MaxRequestSize   string `pipelane:"max_request_size"`
	LingerMs         string `pipelane:"linger_ms"`
	BatchNumMessages *int   `pipelane:"batch_num_messages"`
}