This message was sent because you forgot a password
// // // // ` // msgText := strings.ReplaceAll(MSG_TEXT, "{{Link}}", link) // m := gomail.NewMessage() // m.SetHeader("From", "email") // m.SetHeader("To", email) // m.SetHeader("Subject", "Hello!") // m.SetBody("text/html", msgText) // if err := d.DialAndSend(m); err != nil { // panic(err) // } // } func main() { const ( SMTP_SERVER = "smtp.yandex.ru" SMTP_PORT = 587 SMTP_LOGIN = "serghio2@yandex.ru" SMTP_PASSWORD = "ercutguhcfuzbvyl" ) ctx := context.Background() d := gomail.NewDialer(SMTP_SERVER, SMTP_PORT, SMTP_LOGIN, SMTP_PASSWORD) log.Println("starting reader...") r := kafka.NewReader(kafka.ReaderConfig{ Brokers: []string{"localhost:9092"}, Topic: "backend_events", GroupID: "consumer-group-id", }) log.Println("reader started") for { msg, err := r.FetchMessage(ctx) if err == io.EOF { log.Fatal("EOF") return } if err != nil { log.Fatal(err.Error()) return } log.Printf("offset: %d, partition: %d, key: %s, value: %s\n", msg.Offset, msg.Partition, string(msg.Key), string(msg.Value)) if err := r.CommitMessages(ctx, msg); err != nil { log.Fatalf("failed to commit: %s\n", err.Error()) continue } value := struct { Email string `json:"email"` Token string `json:"token"` }{} if err := json.Unmarshal(msg.Value, &value); err != nil { log.Fatalf("failed to unmarshal: %s\n", err.Error()) continue } m := gomail.NewMessage() m.SetHeader("From", m.FormatAddress("serghio2@yandex.ru", "Pet Backend")) m.SetHeader("To", value.Email) m.SetHeader("Subject", "Hello!") m.SetBody("text/html", "Test backend") if err := d.DialAndSend(m); err != nil { log.Fatalf("failed to send email: %s\n", err.Error()) continue } } }