The Kafka Enqueue transport - This is an implementation of Queue Interop specification

Overview

Supporting Enqueue

Enqueue is an MIT-licensed open source project with its ongoing development made possible entirely by the support of community and our customers. If you'd like to join them, please consider:


RdKafka Transport

Gitter Build Status Total Downloads Latest Stable Version

This is an implementation of Queue Interop specification. It allows you to send and consume message via Kafka protocol.

Resources

Developed by Forma-Pro

Forma-Pro is a full stack development company which interests also spread to open source development. Being a team of strong professionals we have an aim an ability to help community by developing cutting edge solutions in the areas of e-commerce, docker & microservice oriented architecture where we have accumulated a huge many-years experience. Our main specialization is Symfony framework based solution, but we are always looking to the technologies that allow us to do our job the best way. We are committed to creating solutions that revolutionize the way how things are developed in aspects of architecture & scalability.

If you have any questions and inquires about our open source development, this product particularly or any other matter feel free to contact at [email protected]

License

It is released under the MIT License.

You might also like...
PHP Kafka client is used in PHP-FPM and Swoole. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.

longlang/phpkafka Introduction English | 简体中文 PHP Kafka client is used in PHP-FPM and Swoole. The communication protocol is based on the JSON file in

A PHP implementation of the GraphQL specification based on the JavaScript reference implementation

GraphQL This is a PHP implementation of the GraphQL specification based on the JavaScript reference implementation. Related projects DateTime scalar R

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro
Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

Supporting Enqueue Enqueue is an MIT-licensed open source project with its ongoing development made possible entirely by the support of community and

Standards either proposed or approved by the Framework Interop Group

PHP Framework Interoperability Group The idea behind the group is for project representatives to talk about the commonalities between our projects and

Messaging solutions for PHP - It contains advanced features build on top of a transport component

It contains advanced features build on top of a transport component. Client component kind of plug and play things or consumption component that simplify message processing a lot. Read more about it in documentation.

WordPress Interop Bundle

WordPress Interop Bundle Introduction This bundle integrates williarin/wordpress-interop with Symfony. Installation composer require williarin/wordpre

An HTTP Interop compatible middleware dispatcher in Equip

An HTTP Interop compatible middleware dispatcher in Equip. Attempts to be PSR-1, PSR-2, PSR-4, PSR-7, and PSR-15 compliant.

Laravel package for Mailjet API V3 and Laravel Mailjet Mail Transport

Laravel Mailjet Laravel package for handling Mailjet API v3 using this wrapper: https://github.com/mailjet/mailjet-apiv3-php It also provides a mailje

Powerful implementation of the Specification pattern in PHP

RulerZ The central idea of Specification is to separate the statement of how to match a candidate, from the candidate object that it is matched agains

A simple implementation of the api-problem specification. Includes PSR-15 support.

ApiProblem This library provides a simple and straightforward implementation of the IETF Problem Details for HTTP APIs, RFC 7807. RFC 7807 is a simple

This is an implementation of PSR specification. It allows you to send and consume message with Redis store as a broker.

This is an implementation of PSR specification. It allows you to send and consume message with Redis store as a broker.

Tukio is a complete and robust implementation of the PSR-14 Event Dispatcher specification

Tukio is a complete and robust implementation of the PSR-14 Event Dispatcher specification. It supports normal and debug Event Dispatchers, both runtime and compiled Providers, complex ordering of Listeners, and attribute-based registration on PHP 8.

Redis repository implementation for Laravel Queue Batch

Laravel RedisBatchRepository Replaces default Illuminate\Bus\DatabaseBatchRepository with implementation based on Redis. Requirements: php 8 laravel 8

Magento 2 Message Queue OS AMQP Broker Implementation

Magento 2 Message Queue AMQP Backend AMQP message queue backend implementation for Rcason_Mq. Installation Require the module via Composer $ composer

PHP client for Kafka

A library to allow people to communicate to Kafka using plain PHP, compatible with Kafka v0.11+ (due to the way the protocol works).

laravel-kafka
laravel-kafka

Laravel Kafka队列 安装 安装PHP依赖库 pecl install rdkafka 在PHP的初始化文件php.ini中添加以下一行语句以开启Kafka扩展。 extension=rdkafka.so b. 检车 rdkafka 是否安装成功 注意:如果你想在 php-fpm

Use Kafka Producers and Consumers in your laravel app with ease!
Use Kafka Producers and Consumers in your laravel app with ease!

Laravel Kafka Do you use Kafka in your laravel packages? All packages I've seen until today, including some built by myself, does not provide a nice s

Symfony kafka bundle to produce and consume messages.
Symfony kafka bundle to produce and consume messages.

Technology stack Quick start Example project Basic Configuration Consuming messages Retrying failed messages Handling offsets Decoders Denormalizers V

kafka php client
kafka php client

Kafka-php 中文文档 Kafka-php is a pure PHP kafka client that currently supports greater than 0.8.x version of Kafka, this project v0.2.x and v0.1.x are in

Comments
  • Replace composer-modifying for testing with --ignore-platform-req argument

    Replace composer-modifying for testing with --ignore-platform-req argument

    I wish I didn't need to override the RD_KAFKA_VERSION const from kafka-stubs but I didn't feel like it was worth creating a new version of kafka-stubs. Let me know what you think, even (especially?) when you reject this PR.

    opened by maartenderie 3
  • Catch Local: Broker transport failure and continue consuming

    Catch Local: Broker transport failure and continue consuming

    Catch the Kafka Local: Broker transport failure (error -195) error when consuming, this happens sometimes when consuming messages. When we restart the consumer everything is just OK.

    Settings for connection with Kafka:

    enqueue:
        kafka:
            transport:
                global:
                    group.id: XXX
                    metadata.broker.list: XXX
                    enable.auto.offset.store: 'false'
                    socket.keepalive.enable: 'true'
    

    @makasim

    opened by rdotter 2
Owner
Enqueue
Message Queue, Broadcasting, WebSockets interop packages for PHP, Symfony, Laravel, Magento
Enqueue
Production-ready, stable Kafka client for PHP

PHP Kafka client - php-rdkafka PHP-rdkafka is a stable, production-ready, long term support, and fast Kafka client for PHP based on librdkafka. It sup

Arnaud Le Blanc 1.9k Dec 26, 2022
Job Queue Public API PHP Client

Job Queue API PHP Client PHP client for the Job Queue API (API docs). Usage composer require keboola/job-queue-api-php-client use Keboola\JobQueueClie

Keboola 0 Dec 20, 2021
A PHP implementation of the Unleash protocol aka Feature Flags in GitLab

A PHP implementation of the Unleash protocol aka Feature Flags in GitLab. You may also be interested in the Symfony Bundle for this package. This impl

Unleash 38 Dec 25, 2022
Implementation of hopper logic for pushing, pulling and picking up items for PocketMine-MP.

VanillaHopper In pm4, hopper blocks were implemented to have an inventory. But the logic for pushing, pulling and picking up items was missing nonethe

Colin 14 Dec 14, 2022
PHP JSON-RPC 2.0 Server/Client Implementation with Automatic Client Class Generation via SMD

PHP JSON-RPC 2.0 Server/Client Implementation with Automatic Client Class Generation via SMD

Sergey Bykov 63 Feb 14, 2022
PHP Implementation of the all new Basecamp API

Basecamp SDK for PHP The Basecamp SDK for PHP enables PHP developers to easily integrate 37signals Basecamp all new API into their applications. NOTE:

Netvlies Internetdiensten 38 Feb 14, 2022
Implementation of a library to process SISP vinti4 payment in a easy way.

Implementation of a library to process SISP vinti4 payment in a easy way.

Faxi 6 Nov 3, 2022
PHP library with ready-to-use Yunbi API implementation.

yunbi-client-php A simple PHP client for Crypto Trade Site Yunbi.com Quick example <?php require_once('lib/yunbi-client.php'); try { $client = new

null 6 Dec 2, 2019
Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

Laravel queue package You can use all transports built on top of queue-interop including all supported by Enqueue. It also supports extended AMQP feat

Enqueue 204 Dec 22, 2022
[READ-ONLY] The Pheanstalk Enqueue transport.

Supporting Enqueue Enqueue is an MIT-licensed open source project with its ongoing development made possible entirely by the support of community and

Enqueue 7 Jun 24, 2021