php-rdkafka icon indicating copy to clipboard operation
php-rdkafka copied to clipboard

Acks not working

Open artemylapko opened this issue 4 years ago • 0 comments

Hi!

Param request.required.acks = -1 is not working. I have message in log "Broker: Not enough in-sync replicas". But message has been sent to the server.

$conf = new Conf();
$conf->set('log_level', (string) LOG_DEBUG);
$conf->set('debug', 'all');

$rk = new Producer($conf);
$rk->addBrokers($this->brokers);

$topicConf = new TopicConf();
$topicConf->set('request.required.acks', '-1');

$topic = $rk->newTopic("test1", $topicConf);

$topic->produce(RD_KAFKA_PARTITION_UA, 0, "Message payload");

$res = $rk->flush(10000);

$res is 0!

Log:

%7|1635706952.133|PRODUCE|rdkafka#producer-1| [thrd:kafka.21vek.dev:9094/bootstrap]: kafka.21vek.dev:9094/2: test1 [0]: Produce MessageSet with 1 message(s) (83 bytes, ApiVersion 3, MsgVersion 2)
%7|1635706952.133|SEND|rdkafka#producer-1| [thrd:kafka.21vek.dev:9094/bootstrap]: kafka.21vek.dev:9094/2: Sent ProduceRequest (v3, 135 bytes @ 0, CorrId 5)
%7|1635706952.166|RECV|rdkafka#producer-1| [thrd:kafka.21vek.dev:9094/bootstrap]: kafka.21vek.dev:9094/2: Received ProduceResponse (v3, 41 bytes, CorrId 5, rtt 32.49ms)
%7|1635706952.166|REQERR|rdkafka#producer-1| [thrd:kafka.21vek.dev:9094/bootstrap]: kafka.21vek.dev:9094/2: ProduceRequest failed: Broker: Not enough in-sync replicas: explicit actions Retry
%7|1635706952.166|MSGSET|rdkafka#producer-1| [thrd:kafka.21vek.dev:9094/bootstrap]: kafka.21vek.dev:9094/2: test1 [0]: MessageSet with 1 message(s) encountered error: Broker: Not enough in-sync replicas (actions Retry)

artemylapko avatar Oct 31 '21 19:10 artemylapko