kafka

type Bridge struct {
	mqtt.HookBase
	// contains filtered or unexported fields
}

type Message struct {
	Action   string   `json:"action"`
	ClientID string   `json:"clientid"`           // the client id
	Username string   `json:"username"`           // the username of the client
	Remote   string   `json:"remote,omitempty"`   // the remote address of the client
	Listener string   `json:"listener,omitempty"` // the listener the client connected on
	Topics   []string `json:"topics,omitempty"`   // publish topic or subscribe/unsubscribe filters

	Payload         []byte `json:"payload,omitempty"`         // publish payload
	ProtocolVersion byte   `json:"protocolVersion,omitempty"` // mqtt protocol version of the client
	Clean           bool   `json:"clean,omitempty"`           // if the client requested a clean start/session
	Timestamp       int64  `json:"ts"`                        // event time
	PacketID        uint16 `json:"packetid,omitempty"`        // the packet id
	// contains filtered or unexported fields
}

type Options struct {
	KafkaOptions *kafkaOptions `json:"kafka-options" yaml:"kafka-options"`
	Rules        rules         `json:"rules" yaml:"rules"`
}