kafka-go

kafka-go copied to clipboard

Describe the bug

Kafka is encountering this error for some reason, but the client should support retries. I have configured the number of retries, but it is not working.

My code:

w := &kafka.Writer{
		Addr:                   kafka.TCP(option.Broker...),
		Topic:                  topic,
		Balancer:               &kafka.Hash{},
		Async:                  true,
		RequiredAcks:           kafka.RequireAll,
		Transport:              transport,
		MaxAttempts:            100,
		AllowAutoTopicCreation: true,
		Logger: kafka.LoggerFunc(func(s string, i ...interface{}) {
			log.With(ctx).Info().Msgf(s, i...)
		}),
		ErrorLogger: kafka.LoggerFunc(func(s string, i ...interface{}) {
			log.With(ctx).Error().Msgf(s, i...)
		}),
	}