kafka

type Factory struct {
}

type Handler struct {
	// contains filtered or unexported fields
}

type HandlerSettings struct {
	Topic        string `md:"topic,required"` // The Kafka topic on which to listen for messageS
	Partitions   string `md:"partitions"`     // The specific partitions to consume messages from
	Offset       int64  `md:"offset"`         // The offset to use when starting to consume messages, default is set to Newest
	Deserializer string `md:"deserializer"`   // Content deserialization
}

type KafkaConnection struct {
	// contains filtered or unexported fields
}

type Output struct {
	Content interface{} `md:"content"` // The content of the json message recieved
	Message string      `md:"message"` // The message that was consumed
}

type Settings struct {
	BrokerUrls string `md:"brokerUrls,required"` // The Kafka cluster to connect to
	User       string `md:"user"`                // If connecting to a SASL enabled port, the user id to use for authentication
	Password   string `md:"password"`            // If connecting to a SASL enabled port, the password to use for authentication
	TrustStore string `md:"trustStore"`          // If connecting to a TLS secured port, the directory containing the certificates representing the trust chain for the connection. This is usually just the CACert used to sign the server's certificate
}

type Trigger struct {
	// contains filtered or unexported fields
}