php-rdkafka
php-rdkafka copied to clipboard
Acks not working
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)