golang sarama_produce_test_with_timestamp.go

Posted 2021-05-24

package main

import (
	"log"
	"os"
	"time"

	"github.com/Shopify/sarama"
)

func main() {
	config := sarama.NewConfig()
	config.Producer.Return.Errors = true
	config.Producer.Retry.Max = 10
	config.Producer.Compression = sarama.CompressionSnappy // or GZIP don't work in combination with Timestamp!
	config.Producer.Flush.Frequency = 500 * time.Millisecond
	config.ClientID = "test"
	sarama.Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags)

	producer, err := sarama.NewAsyncProducer([]string{"localhost:9092"}, config)
	if err != nil {
		log.Fatalln("[ERROR] Failed to start Sarama producer:", err)
	}
	defer producer.Close()

	go func() {
		for err := range producer.Errors() {
			log.Printf("[ERROR]: %s\n", err.Error())
		}
	}()

	producer.Input() <- &sarama.ProducerMessage{
		Timestamp: time.Now(),
		Topic:     "bla",
		Value:     sarama.ByteEncoder("test this message"),
	}
}

golang 日志打印后程序直接退出

参考技术A 在一段 http get 的程序中，如果出现错误，打印日志后会导致程序退出。

将 log.Fatal 修改为 log.Println 即可解决问题。

感觉一个函数做了本不该它做的事情，有些好奇，golang 设计者的设计哲学。