Feature/added properties

[ytake]

Added LocalProperty

KSQL

streamsProperties (map) – Property overrides to run the statements with.

Example

<?php
declare(strict_types=1);

use Istyle\KsqlClient\StreamClient;
use Istyle\KsqlClient\Query\Stream;
use Istyle\KsqlClient\StreamConsumable;
use Istyle\KsqlClient\Entity\StreamedRow;
use Istyle\KsqlClient\Properties\LocalProperties;
use Istyle\KsqlClient\Properties\LocalPropertyValidator;

$client = new StreamClient(
    "http://localhost:8088"
);
$properties = new LocalProperties(["ksql.streams.auto.offset.reset" => "earliest"], new LocalPropertyValidator());

$result = $client->requestQuery(
    new Stream(
        'SELECT * FROM testing',
        new class() implements StreamConsumable
        {
            public function __invoke(StreamedRow $row)
            {
                // stream response consumer
            }
        }
    ),
    $properties
)->result();

[coveralls]

Pull Request Test Coverage Report for Build 28

• 63 of 63 (100.0%) changed or added relevant lines in 8 files are covered.
• No unchanged relevant lines lost coverage.
• Overall coverage increased (+2.4%) to 92.247%

---

Totals
Change from base Build 25:	2.4%
Covered Lines:	464
Relevant Lines:	503

---

💛 - Coveralls