Level23\Druid\Lookups\KafkaLookup

Complexity

Total Complexity

3

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	2
A	toArray()	0	8	1

<?php
declare(strict_types=1);

namespace Level23\Druid\Lookups;

/**
 * @see https://druid.apache.org/docs/latest/querying/kafka-extraction-namespace
 */
class KafkaLookup implements LookupInterface
{
    /**
     * @param string                   $kafkaTopic      The Kafka topic to read the data from
     * @param string|array<int,string> $servers
     * @param array<string,scalar>     $kafkaProperties Kafka consumer properties
     * @param int                      $connectTimeout  How long to wait for an initial connection
     * @param bool                     $isOneToOne      The map is a one-to-one (like injective)
     */
    public function __construct(
        protected string $kafkaTopic,
        protected string|array $servers,
        protected array $kafkaProperties = [],
        protected int $connectTimeout = 0,
        protected bool $isOneToOne = false
    ) {
        $this->kafkaProperties['bootstrap.servers'] =
            is_array($this->servers)
                ? implode(',', $this->servers)
                : $this->servers;
    }

    /**
     * @return array<string,string|array<string,scalar>|int|bool>
     */
    public function toArray(): array
    {
        return [
            'type'            => 'kafka',
            'kafkaTopic'      => $this->kafkaTopic,
            'kafkaProperties' => $this->kafkaProperties,
            'connectTimeout'  => $this->connectTimeout,
            'isOneToOne'      => $this->isOneToOne,
        ];
    }
}