producer

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

type Input struct {
	Message interface{} `md:"message,required"` // The message to send
}

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

type Output struct {
	Partition int32 `md:"partition"` // Documents the partition that the message was placed on
	OffSet    int64 `md:"offset"`    // Documents the offset for the message
}

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
	Topic        string `md:"topic,required"`      // The Kafka topic on which to place the message
	PeriodOfTime string `md:"periodOfTime"`        // ("s", "m", "h")
}