// GetNewKafkaWriter create new kafka producer
GetNewKafkaWriter create new kafka producer
// GetNewKafkaWriter create new kafka producer
func (c *consumerGroup) GetNewKafkaWriter() *kafka.Writer {
	w := &kafka.Writer{
		Addr:         kafka.TCP(c.Brokers...),
		Balancer:     &kafka.LeastBytes{},
		RequiredAcks: writerRequiredAcks,
		MaxAttempts:  writerMaxAttempts,
		Compression:  compress.Snappy,
		ReadTimeout:  writerReadTimeout,
		WriteTimeout: writerWriteTimeout,
	}
	return w
}
func ( c * consumerGroup ) GetNewKafkaWriter ( ) * kafka . Writer { w := & kafka . Writer { Addr : kafka . TCP ( c . Brokers ... ) , Balancer : & kafka . LeastBytes { } , RequiredAcks : writerRequiredAcks , MaxAttempts : writerMaxAttempts , Compression : compress . Snappy , ReadTimeout : writerReadTimeout , WriteTimeout : writerWriteTimeout , } return w }
GetNewKafkaWriter create new kafka producer
GetNewKafkaWriter create new kafka producer