diff --git a/mqtt/hook.go b/mqtt/hook.go index f404549..ffc9148 100644 --- a/mqtt/hook.go +++ b/mqtt/hook.go @@ -101,7 +101,7 @@ func (h *MqttServerHook) OnPublish(cl *mqttServerV2.Client, pk packets.Packet) ( } func (h *MqttServerHook) OnPublished(cl *mqttServerV2.Client, pk packets.Packet) { - h.Log.Info("published to client", "client", cl.ID, "payload", string(pk.Payload)) + h.Log.Info("published to client", "client", cl.ID, "topic", pk.TopicName, "payload", string(pk.Payload)) } // OnConnectAuthenticate returns true/allowed for all requests.