Сарама Продюсер должен быть воссоздан / восстановлен при переработке кафки - PullRequest
Новая
       34

Сарама Продюсер должен быть воссоздан / восстановлен при переработке кафки

0 голосов
/ 08 апреля 2019

Я создал Kafka Producer, используя сараму с кодом ниже.

var, производитель sarama.AsyncProducer //... Это глобальное объявление 

config := sarama.NewConfig()
//config.Producer.Return.Successes = false
//config.Producer.Partitioner = sarama.NewRandomPartitioner
//config.Producer.RequiredAcks = sarama.WaitForLocal       
config.Producer.Compression = sarama.CompressionSnappy   
config.Producer.Flush.Frequency = 100 * time.Millisecond 
producer, errsar = sarama.NewAsyncProducer([]string{"x.x.x.x:9091"}, config)
if errsar != nil {
    panic(errsar)
}

Все работает нормально, но когда яперезагрузите мою кафку .. я получаю сообщение об ошибке "раздел в середине лидерских выборов ...".Когда я перезапускаю свое приложение, которое фактически перезапускает производителя, все работает отлично.

Есть ли в Сараме вариант, при котором мне не выдается ошибка партиции, когда я перезапускаю kafka и начинаю отправлять сообщения (у confluent такой проблемы нет ... она работает хорошо. Но sarama дает нам лучшую производительность)

Любая помощь приветствуется.

...