{"repo":"seanmorris/ksqlc","free":true,"listed":false,"github":"https://github.com/seanmorris/ksqlc","clone":"git clone https://github.com/seanmorris/ksqlc.git","description":"The Asynchronous PHP KSQL Connector","language":"PHP","stars":13,"topics":["kafka","php","ksql","ksqldb","async","streaming","php7","php8"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"SeanMorris/Ksqlc / keɪ ɛs kyu ɛl si / • The Asynchronous PHP KSQL Connector Ksqlc provides a PHP interface to Confluent KSQL & Apache Kafka. Ksqlc is free for distribution, modification, and use under the Apache-2.0 license. Docs Github Packagist Supports PHP 7.0 - PHP 8.5! Installation Install via the composer cli: ... or add seanmorris/ksqlc to your composer.json : Development Install dependencies before running the test suite: The full test suite runs against the Docker-backed Kafka, KSQL, schema registry, and Kafka REST stack. Use the Makefile targets, which default to Docker Compose v2: Replace 8.5 with any supported runtime from PHP 7.0 through PHP 8.5. Direct vendor/bin/phpunit runs require equivalent ksql-server and krest-server hostnames, so the Docker workflow is the expected path for functional tests. Usage Open a connection Grab the URL to your KSQL server's REST endpoint, and use it to create a new Ksqlc object to begin: Ksqlc::stream() - Stream Queries Asynchronously KSQLDB will push query results to you asynchronously when you're using Ksqlc::stream() . Ksqlc will return streaming queries as generators. These can be iterated with foreach . Results will stream in until a limit is reached or the programmer breaks the loop and destroys the reference. Ksqlc::multiplex() - Stream Mutliple Queries You can loop over multiple queries at once with Ksqlc::multiplex() . Each parameter to this method represents either a string query or a list of parameters to send to Ksqlc","default_branch":null,"files":null,"tree":[],"storefront":"/r/seanmorris","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/seanmorris/ksqlc/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}