Function enrich has a Cognitive Complexity of 37 (exceeds 5 allowed). Consider refactoring.

Open

    public function enrich($element): void
    {
        foreach ($this->documentedElements as $documentedElement) {
            if (preg_match('/\b' . $element->getName() . '\b/', $documentedElement['name'])) {
                $element->getDocBlock()->addTag(

• Read up
  Read up

File Client.php has 309 lines of code (exceeds 250 allowed). Consider refactoring.

Open

<?php

declare(strict_types=1);

namespace RdKafka\Admin;

Method extract has 79 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function extract(): void
    {
        echo 'Download and prepare librdkafka documentation ...';

        $html = file_get_contents($this->url);

Function generateConstantsFiles has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    private function generateConstantsFiles(): void
    {
        $versionRelatedConstants = [];
        $overAllConstants = [];
        /** @var Constant[] $constants */

• Read up
  Read up

Client has 24 functions (exceeds 20 allowed). Consider refactoring.

Open

class Client
{
    private RdKafka $kafka;
    private int $waitForResultEventTimeoutMs = 50;

Method prepareFileContent has 64 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private function prepareFileContent(string $file, string $content, string $version): string
    {
        if (strpos($file, 'rdkafka.h') !== false) {
            // prefilter header file content - not supported by cparser
            $content = preg_replace_callback(

Method producev has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function producev(
        int $partition,
        int $msgflags,
        ?string $payload = null,
        ?string $key = null,

Method enrich has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function enrich($element): void
    {
        foreach ($this->documentedElements as $documentedElement) {
            if (preg_match('/\b' . $element->getName() . '\b/', $documentedElement['name'])) {
                $element->getDocBlock()->addTag(

Method parseHeaders has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private function parseHeaders(CData $nativeMessage): array
    {
        $headers = [];

        if ($nativeMessage->err !== RD_KAFKA_RESP_ERR_NO_ERROR) {

Method generateConstantsFiles has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private function generateConstantsFiles(): void
    {
        $versionRelatedConstants = [];
        $overAllConstants = [];
        /** @var Constant[] $constants */

Method loadSupportedVersions has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private function loadSupportedVersions(): array
    {
        echo 'Load librdkafka releases ...';

        $content = file_get_contents(

Method __construct has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function __construct(CData $nativeMessage)
    {
        $timestampType = Library::new('rd_kafka_timestamp_type_t');
        $this->timestamp = (int) Library::rd_kafka_message_timestamp($nativeMessage, FFI::addr($timestampType));
        $this->timestampType = (int) $timestampType->cdata;

Method setPartitioner has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function setPartitioner(int $partitioner): void
    {
        switch ($partitioner) {
            case RD_KAFKA_MSG_PARTITIONER_RANDOM:
                $partitionerMethod = 'rd_kafka_msg_partitioner_random';

Method setReplicaAssignment has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function setReplicaAssignment(int $new_partition_id, array $broker_ids): void
    {
        if (empty($broker_ids) === true) {
            throw new \InvalidArgumentException('broker_ids array must not be empty');
        }

Method setReplicaAssignment has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function setReplicaAssignment(int $partition_id, array $broker_ids): void
    {
        if (empty($broker_ids) === true) {
            throw new \InvalidArgumentException('broker_ids array must not be empty');
        }

Function parseHeaders has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    private function parseHeaders(CData $nativeMessage): array
    {
        $headers = [];

        if ($nativeMessage->err !== RD_KAFKA_RESP_ERR_NO_ERROR) {

• Read up
  Read up

Method benchProduce100MessagesWithLogAndDrMsgCallbacksWithOpaque has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function benchProduce100MessagesWithLogAndDrMsgCallbacksWithOpaque(): void
    {
        $counter = new stdClass();
        $counter->count = 0;

Method parse has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private function parse(string $version): void
    {
        echo '  Parse ...' . PHP_EOL;
        $parser = new Parser($this->config);

Method benchConsume100MessagesWithLogCallback has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function benchConsume100MessagesWithLogCallback(): void
    {
        $conf = new Conf();
        $conf->set('metadata.broker.list', 'kafka:9092');
        $conf->set('auto.offset.reset', 'earliest');

Function setPartitioner has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    public function setPartitioner(int $partitioner): void
    {
        switch ($partitioner) {
            case RD_KAFKA_MSG_PARTITIONER_RANDOM:
                $partitionerMethod = 'rd_kafka_msg_partitioner_random';

• Read up
  Read up