|
|
@ -98,9 +98,9 @@ func (p *KafkaAsyncProducer) Close() { |
|
|
|
func NewKafkaAsyncProducer(brokers []string, clientID string) *KafkaAsyncProducer { |
|
|
|
config := sarama.NewConfig() |
|
|
|
config.ClientID = clientID |
|
|
|
config.Net.DialTimeout = time.Second * 10 |
|
|
|
config.Net.ReadTimeout = time.Second * 10 |
|
|
|
config.Net.WriteTimeout = time.Second * 10 |
|
|
|
config.Net.DialTimeout = time.Second * 30 |
|
|
|
config.Net.ReadTimeout = time.Second * 30 |
|
|
|
config.Net.WriteTimeout = time.Second * 30 |
|
|
|
producer, err := sarama.NewAsyncProducer(brokers, config) |
|
|
|
if err != nil { |
|
|
|
log.Printf("_kafka 生产者[%v] 初始化异常 %s", brokers, err.Error()) |
|
|
|