Node.js 16 actions are deprecated. Please update the following actions to use Node.js 20: ramsey/composer-install@v1. For more information see: https://github.blog/changelog/2023-09-22-github-actions-transitioning-from-node-16-to-node-20/.

The following actions uses node12 which is deprecated and will be forced to run on node16: ramsey/composer-install@v1. For more info: https://github.blog/changelog/2023-06-13-github-actions-all-actions-will-run-on-node16-instead-of-node12-by-default/

The `save-state` command is deprecated and will be disabled soon. Please upgrade to using Environment Files. For more information see: https://github.blog/changelog/2022-10-11-github-actions-deprecating-save-state-and-set-output-commands/

The `save-state` command is deprecated and will be disabled soon. Please upgrade to using Environment Files. For more information see: https://github.blog/changelog/2022-10-11-github-actions-deprecating-save-state-and-set-output-commands/

The `set-output` command is deprecated and will be disabled soon. Please upgrade to using Environment Files. For more information see: https://github.blog/changelog/2022-10-11-github-actions-deprecating-save-state-and-set-output-commands/

Escaped Mutant for Mutator "Coalesce": --- Original +++ New @@ @@ private bool $shouldRun = true; public function __construct(ConsumerConfig $config, LoggerInterface|null $logger = null) { - $this->logger = $logger ?? new NullLogger(); + $this->logger = new NullLogger() ?? $logger; $this->setupInternalTerminationSignal($config); $config->getConf()->setErrorCb(function (RdKafkaConsumer $kafka, int $err, string $reason) : void { $this->logger->error(sprintf('Kafka error: "%s": "%s"', rd_kafka_err2str($err), $reason), ['err' => $err]);

Escaped Mutant for Mutator "MethodCallRemoval": --- Original +++ New @@ @@ public function __construct(ConsumerConfig $config, LoggerInterface|null $logger = null) { $this->logger = $logger ?? new NullLogger(); - $this->setupInternalTerminationSignal($config); + $config->getConf()->setErrorCb(function (RdKafkaConsumer $kafka, int $err, string $reason) : void { $this->logger->error(sprintf('Kafka error: "%s": "%s"', rd_kafka_err2str($err), $reason), ['err' => $err]); });

Escaped Mutant for Mutator "MethodCallRemoval": --- Original +++ New @@ @@ { $this->logger = $logger ?? new NullLogger(); $this->setupInternalTerminationSignal($config); - $config->getConf()->setErrorCb(function (RdKafkaConsumer $kafka, int $err, string $reason) : void { - $this->logger->error(sprintf('Kafka error: "%s": "%s"', rd_kafka_err2str($err), $reason), ['err' => $err]); - }); + $rebalanceCallback = function (RdKafkaConsumer $kafka, int $err, array|null $partitions = null) : void { switch ($err) { case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS:

Escaped Mutant for Mutator "MethodCallRemoval": --- Original +++ New @@ @@ $rebalanceCallback = function (RdKafkaConsumer $kafka, int $err, array|null $partitions = null) : void { switch ($err) { case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS: - $this->logger->debug('Assigning partitions', $partitions === null ? [] : array_map(static function (TopicPartition $partition) : string { - return (string) $partition->getPartition(); - }, $partitions)); + $kafka->assign($partitions); break; case RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS:

Escaped Mutant for Mutator "Identical": --- Original +++ New @@ @@ $rebalanceCallback = function (RdKafkaConsumer $kafka, int $err, array|null $partitions = null) : void { switch ($err) { case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS: - $this->logger->debug('Assigning partitions', $partitions === null ? [] : array_map(static function (TopicPartition $partition) : string { + $this->logger->debug('Assigning partitions', $partitions !== null ? [] : array_map(static function (TopicPartition $partition) : string { return (string) $partition->getPartition(); }, $partitions)); $kafka->assign($partitions);

Escaped Mutant for Mutator "UnwrapArrayMap": --- Original +++ New @@ @@ $rebalanceCallback = function (RdKafkaConsumer $kafka, int $err, array|null $partitions = null) : void { switch ($err) { case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS: - $this->logger->debug('Assigning partitions', $partitions === null ? [] : array_map(static function (TopicPartition $partition) : string { - return (string) $partition->getPartition(); - }, $partitions)); + $this->logger->debug('Assigning partitions', $partitions === null ? [] : $partitions); $kafka->assign($partitions); break; case RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS:

Escaped Mutant for Mutator "Ternary": --- Original +++ New @@ @@ $rebalanceCallback = function (RdKafkaConsumer $kafka, int $err, array|null $partitions = null) : void { switch ($err) { case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS: - $this->logger->debug('Assigning partitions', $partitions === null ? [] : array_map(static function (TopicPartition $partition) : string { + $this->logger->debug('Assigning partitions', $partitions === null ? array_map(static function (TopicPartition $partition) : string { return (string) $partition->getPartition(); - }, $partitions)); + }, $partitions) : []); $kafka->assign($partitions); break; case RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS:

Escaped Mutant for Mutator "MethodCallRemoval": --- Original +++ New @@ @@ $kafka->assign(); } }; - $config->getConf()->setRebalanceCb($rebalanceCallback); + parent::__construct($config->getConf()); } /**

Escaped Mutant for Mutator "NotIdentical": --- Original +++ New @@ @@ $consumerRecords = new ConsumerRecords(); $this->doStart($timeoutMs, function (Message $message) use($maxBatchSize, $timeoutMs, $batchTime, $processRecord, $onBatchProcessed, $consumerRecords) : void { $consumerRecords->add($message); - if ($processRecord !== null) { + if ($processRecord === null) { $processRecord($message); } if ($consumerRecords->count() === $maxBatchSize) {