sparrow/pkg/ruleEngine/nodes/kafka_node.go

package nodes

// KafkaNode Kafka Node sends messages to Kafka brokers. Expects messages with any message type. Will send record via Kafka producer to Kafka server
type KafkaNode struct {
}

type KafkaNodeConfiguration struct {
	TopicPattern        string            `json:"topic_pattern"`
	BootstrapServer     string            `json:"bootstrap_server"`
	RetryTimes          int               `json:"retry_times"`            // if fails retry times
	BatchSize           int64             `json:"batch_size"`             // produces batch size in bytes
	LocallyBufferTime   int64             `json:"locally_buffer_time"`    // time to buffer locally(ms)
	MaxSizeClientBuffer int64             `json:"max_size_client_buffer"` // client buffer max size in bytes
	MetaData            map[string]string `json:"meta_data"`
	AckNumber           int               `json:"ack_number"` // number of ack
}