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": @@ @@ 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": @@ @@ 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": @@ @@ { $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": @@ @@ $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": @@ @@ $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": @@ @@ $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": @@ @@ $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": @@ @@ $kafka->assign(); } }; - $config->getConf()->setRebalanceCb($rebalanceCallback); + parent::__construct($config->getConf()); } /**

Escaped Mutant for Mutator "NotIdentical": @@ @@ $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) {