diff --git a/destination/config.go b/destination/config.go index 412ea95..c34428d 100644 --- a/destination/config.go +++ b/destination/config.go @@ -151,7 +151,7 @@ func (c Config) ParseTopic() (topic string, f TopicFn, err error) { } topic := buf.String() if topic == "" { - return "", fmt.Errorf("topic not found on record %s", r.Key.Bytes()) + return "", fmt.Errorf("topic not found on record %s using template %s", r.Key.Bytes(), c.Topic) } return topic, nil