diff --git a/listener/nats_publisher.go b/listener/nats_publisher.go index 5c5dccb5..d49ade79 100644 --- a/listener/nats_publisher.go +++ b/listener/nats_publisher.go @@ -48,7 +48,7 @@ func (n NatsPublisher) Publish(ctx context.Context, cfg *config.Config, log *log "subject": subject, "action": event.Action, "table": event.Table, - }).Infoln("event was sent") + }).Debugln("event was sent") return nil } diff --git a/listener/pubsub_publisher.go b/listener/pubsub_publisher.go index 152cd2c8..4228c302 100644 --- a/listener/pubsub_publisher.go +++ b/listener/pubsub_publisher.go @@ -48,7 +48,8 @@ func (p *PubSubPublisher) Publish(ctx context.Context, _ *config.Config, log *lo "topic": p.topic.String(), "action": event.Action, "table": event.Table, - }).Infoln("event was sent") + "data": event.Data, + }).Debugln("event was sent") return nil } diff --git a/listener/wal_transaction.go b/listener/wal_transaction.go index 99bcc5df..535094a2 100644 --- a/listener/wal_transaction.go +++ b/listener/wal_transaction.go @@ -113,7 +113,7 @@ func (c *Column) AssertValue(src []byte) { err = json.Unmarshal(src, &m) val = m default: - logrus.WithFields(logrus.Fields{"pgtype": c.valueType, "column_name": c.name}).Warnln("unknown oid type") + logrus.WithFields(logrus.Fields{"pgtype": c.valueType, "column_name": c.name}).Debugln("unknown oid type") val = strSrc } @@ -199,7 +199,7 @@ func (w *WalTransaction) CreateEventsWithFilter(tableMap map[string][]string) [] "table": item.Table, "action": item.Kind, }). - Infoln("wal-message was skipped by filter") + Debugln("wal-message was skipped by filter") } return events