idealo/php-rdkafka-ffi

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

Open

<?php

declare(strict_types=1);

namespace RdKafka\Admin;

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

Open

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

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    public function deleteTopics(array $topics, ?DeleteTopicsOptions $options = null): array
    {
        $this->assertArray($topics, 'topics', DeleteTopic::class);

        $queue = Queue::fromRdKafka($this->kafka);

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    public function alterConfigs(array $resources, ?AlterConfigsOptions $options = null): array
    {
        $this->assertArray($resources, 'resources', ConfigResource::class);

        $queue = Queue::fromRdKafka($this->kafka);

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    public function createTopics(array $topics, ?CreateTopicsOptions $options = null): array
    {
        $this->assertArray($topics, 'topics', NewTopic::class);

        $queue = Queue::fromRdKafka($this->kafka);

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    public function createPartitions(array $partitions, ?CreatePartitionsOptions $options = null): array
    {
        $this->assertArray($partitions, 'partitions', NewPartitions::class);

        $queue = Queue::fromRdKafka($this->kafka);

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    public function describeConfigs(array $resources, ?DescribeConfigsOptions $options = null): array
    {
        $this->assertArray($resources, 'resources', ConfigResource::class);

        $queue = Queue::fromRdKafka($this->kafka);

• Read up
  Read up