PHPackages kaliop/queueingbundle-kinesis - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. kaliop/queueingbundle-kinesis ActiveLibrary kaliop/queueingbundle-kinesis ============================= Kaliop Queueing Bundle - Kinesis plugin v0.2.1(6y ago)0201GPL-2.0PHPCI failing Since Sep 10Pushed 5y ago2 watchersCompare [ Source](https://github.com/kaliop-uk/kueueingbundle-kinesis)[ Packagist](https://packagist.org/packages/kaliop/queueingbundle-kinesis)[ RSS](/packages/kaliop-queueingbundle-kinesis/feed)WikiDiscussions master Synced 1mo ago READMEChangelog (2)Dependencies (7)Versions (4)Used By (0) Kaliop Queueing Bundle - Kinesis plugin ======================================= [](#kaliop-queueing-bundle---kinesis-plugin) Adds support for AWS Kinesis to the Kaliop Queueing Bundle See: and respectively. It has been given its own bundle because it has higher requirements than the base Queueing Bundle Installation ------------ [](#installation) 1. Install the bundle via Composer. 2. Enable the KaliopQueueingPluginsKinesisBundle bundle in your kernel class registerBundles(). Also enable the DoctrineCacheBundle. 3. Clear all caches if not on a dev environment Usage ----- [](#usage) 4. If you do not have an AWS account, sign up for one at NB: note that there is no free tier for Kinesis. Pricing is described at: 5. Create a Kinesis stream, using the web interface: 6. Set up configuration according to your AWS account - edit parameters.yml in this bundle - copy/include kinesis\_sample.yml in your app config, and edit it if needed 7. check that you can list the stream, and the shards in it: ``` php app/console kaliop_queueing:managequeue list -bkinesis php app/console kaliop_queueing:managequeue info -bkinesis ``` 8. push a message to the stream ``` php app/console kaliop_queueing:queuemessage -bkinesis -r ``` 9. receive messages from the stream ``` php app/console kaliop_queueing:consumer -bkinesis -r ``` Notes ----- [](#notes) - Kinesis groups messages in streams, which are divided into one or more shards each. Each message is pushed onto a shard, and has to be pulled from it. In kaliop-queueing, the following mapping applies: - stream => queue - shard => routing key - Kinesis by default does not remove messages from its shards when they are consumed. This means that the consumer has to keep an internal pointer to the last consumed message. A service is used to handle the local storage of this value - the default one provided in this bundle is based on the Doctrine-Cache bundle, and has to be configured to be enabled (see point 7 above). Note that since it uses the cache directory to store the data, on any cache clear the pointer will be reset, and old messages downloaded. To change this behaviour, see the option kaliop\_queueing\_kinesis.default.missing\_sequence\_number\_strategy in parameters.yml - When running the kaliop\_queueing:queuemessage, usage of the -r option to specify a shard partition key is mandatory. NB: the value used is *not* the id of the shard, rather it is hashed and a shard is picked according to the hash value - When running the kaliop\_queueing:messageconsumer, usage of the -r option to specify a shard Id is mandatory. If you do not know the Shard Id, use the `kaliop_queueing:managequeue info ` command to see it [![License](https://camo.githubusercontent.com/2ae959d1b78116ccd219dd28f27529bec9a3ed110a2099732ac857e467ff9604/68747470733a2f2f706f7365722e707567782e6f72672f6b616c696f702f7175657565696e6762756e646c652d6b696e657369732f6c6963656e7365)](https://packagist.org/packages/kaliop/queueingbundle-kinesis)[![Latest Stable Version](https://camo.githubusercontent.com/827d04b73b9463fcb9ae17b59a01320fbfd9cbc8aaa2af4563be71cf562b7649/68747470733a2f2f706f7365722e707567782e6f72672f6b616c696f702f7175657565696e6762756e646c652d6b696e657369732f762f737461626c65)](https://packagist.org/packages/kaliop/queueingbundle-kinesis)[![Total Downloads](https://camo.githubusercontent.com/d539283bc5d790f49715163eabb4653dfb468649285139cdc0c0e2e5fec4935c/68747470733a2f2f706f7365722e707567782e6f72672f6b616c696f702f7175657565696e6762756e646c652d6b696e657369732f646f776e6c6f616473)](https://packagist.org/packages/kaliop/queueingbundle-kinesis) [![Build Status](https://camo.githubusercontent.com/49d9d57965d7a62319b4a0360645df34e90ea1707e003126ff0cc902b5dc4736/68747470733a2f2f7472617669732d63692e6f72672f6b616c696f702d756b2f6b75657565696e6762756e646c652d6b696e657369732e7376673f6272616e63683d6d6173746572)](https://travis-ci.org/kaliop-uk/queueingbundle-kinesis)[![Scrutinizer Code Quality](https://camo.githubusercontent.com/93512d80ab7173b88c0d8e0e87af9c15a9991ad61c932db6c9ee35eb12c95df9/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f6b616c696f702d756b2f6b75657565696e6762756e646c652d6b696e657369732f6261646765732f7175616c6974792d73636f72652e706e673f623d6d6173746572)](https://scrutinizer-ci.com/g/kaliop-uk/kueueingbundle-kinesis/?branch=master)[![SensioLabsInsight](https://camo.githubusercontent.com/ac2b841c605e13c3272125a424e11e85047d69bdd0840a5a2b612ad50a9eed22/68747470733a2f2f696e73696768742e73656e73696f6c6162732e636f6d2f70726f6a656374732f63626165666533332d353166342d346237652d613432332d6330383739376637333539622f6d696e692e706e67)](https://insight.sensiolabs.com/projects/cbaefe33-51f4-4b7e-a423-c08797f7359b) ### Health Score 24 — LowBetter than 32% of packages Maintenance20 Infrequent updates — may be unmaintained Popularity7 Limited adoption so far Community5 Small or concentrated contributor base Maturity55 Maturing project, gaining track record How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~572 days Total 3 Last Release 2394d ago ### Community Maintainers ![](https://www.gravatar.com/avatar/f641f7d6edabf83c56f6c4998b04e6c59a00b46bf51ca6699c31b09f9c948677?d=identicon)[gggeek](/maintainers/gggeek) ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/kaliop-queueingbundle-kinesis/health.svg) ``` [![Health](https://phpackages.com/badges/kaliop-queueingbundle-kinesis/health.svg)](https://phpackages.com/packages/kaliop-queueingbundle-kinesis) ``` ### Alternatives [symfony/security-bundle Provides a tight integration of the Security component into the Symfony full-stack framework 2.5k172.9M1.8k](/packages/symfony-security-bundle)[sonata-project/entity-audit-bundle Audit for Doctrine Entities 644989.8k1](/packages/sonata-project-entity-audit-bundle) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)