PHPackages                             beta/bx.kafka.agent - 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. [Utility & Helpers](/categories/utility)
4. /
5. beta/bx.kafka.agent

ActiveBitrix-module[Utility & Helpers](/categories/utility)

beta/bx.kafka.agent
===================

Kafka agent

1.2.0(1y ago)0154MITPHP

Since Feb 1Pushed 1y ago2 watchersCompare

[ Source](https://github.com/beta-eto-code/bx.kafka.agent)[ Packagist](https://packagist.org/packages/beta/bx.kafka.agent)[ RSS](/packages/beta-bxkafkaagent/feed)WikiDiscussions master Synced today

READMEChangelogDependencies (1)Versions (4)Used By (0)

Bitrix Kafaka agent
===================

[](#bitrix-kafaka-agent)

Установка
---------

[](#установка)

```
composer require beta/bx.kafka.agent
```

Далее устанавливаем модуль (bx.kafka.agent) через админку - /bitrix/admin/partner\_modules.php?lang=ru

После установки в корне проекта появится 2 файла:

- kfagent - скрипт для запуска проекта
- kfagent.service - сервис для подсистемы systemd

Далее переносим сервис для запуска:

```
mv kfagent.service /etc/systemd/system/
```

Перезапускаем конфигурацию systemd:

```
sudo systemctl daemon-reload
```

Активируем сервис:

```
sudo systemctl enable kfagent
```

И запускаем его:

```
sudo systemctl start kfagent
```

Пример регистрации через bitrix обработчики:
--------------------------------------------

[](#пример-регистрации-через-bitrix-обработчики)

```
use Bx\Kafka\Agent\Manager;

// через init.php
Manager::getInstance()->addEventHandler(
    'employee', // название топика
    'my.module',
    'SomeNamespace\\MyClass',
    'someStaticMethod'
);

// через миграцию
Manager::getInstance()->registerEventHandler(
    'employee', // название топика
    'my.module',
    'SomeNamespace\\MyClass',
    'someStaticMethod'
);
```

Пример регистрации через SPL (Наблюдатель):
-------------------------------------------

[](#пример-регистрации-через-spl-наблюдатель)

```
use Bx\Kafka\Agent\Manager;
use Bx\Kafka\Agent\NewMessageSubject;

class MyNewEmployeeObserver implements SplObserver
{
    public function update(SplSubject $subject): void
    {
        if (!($subject instanceof NewMessageSubject)) {
            return;
        }

        $subject->getMessage()->getData(); // получаем данные из брокера
    }
}

Manager::getInstance()->addObserver(
    'employee', // название топика
    new MyNewEmployeeObserver() // экземпляр наблюдателя
);
```

###  Health Score

28

—

LowBetter than 52% of packages

Maintenance39

Infrequent updates — may be unmaintained

Popularity14

Limited adoption so far

Community8

Small or concentrated contributor base

Maturity44

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

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 ~179 days

Total

3

Last Release

526d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/c75fd54c926c6b835a6b6cd92514d60d55a285d35847b9f22aefcc7ad5ef9ae7?d=identicon)[nnagornyy](/maintainers/nnagornyy)

---

Top Contributors

[![alex19pov31](https://avatars.githubusercontent.com/u/786683?v=4)](https://github.com/alex19pov31 "alex19pov31 (4 commits)")

### Embed Badge

![Health badge](/badges/beta-bxkafkaagent/health.svg)

```
[![Health](https://phpackages.com/badges/beta-bxkafkaagent/health.svg)](https://phpackages.com/packages/beta-bxkafkaagent)
```

###  Alternatives

[whatthejeff/nyancat-scoreboard

Nyan Cat Scoreboard

20996.8k4](/packages/whatthejeff-nyancat-scoreboard)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)