Как использовать Kafka и Redis в проекте Laravel? ⇐ Php

[Anonymous]

У меня возникла проблема при совместной настройке Kafka и Redis в Laravel.

Я могу запустить Redis для использования базы данных в памяти. Итак, Redis работает нормально.

Код: Выделить всё

$redis = app()->make('redis');
return $redis->get('name1'); // it runs fine returning value of "name1"

Я могу настроить Kafka в своей системе Windows, чтобы я мог создавать и использовать сообщения в терминалах.

Rdkafka успешно настроен как клиентская библиотека и расширения PHP.

В Laravel для Kafka я использую пакет «superbalist/laravel-pubsub»: «^3.0», "superbalist/php-pubsub-kafka": "^2.0"ССЫЛКА

Приведенный ниже код предназначен для подписки и использования сообщения

Код: Выделить всё

$pubsub = app('pubsub');
$pubsub->subscribe('test1', function ($message) {
var_dump($message); // the code just stuck here
});

Браузер просто продолжает загружаться и не останавливается. Я пытался изучить код поставщиков, но ответ непонятен.

Мой ENV в соответствии с запросом пакета

Код: Выделить всё

REDIS_HOST=localhost
REDIS_PASSWORD=null
REDIS_PORT=6379

PUBSUB_CONNECTION=redis

KAFKA_BROKERS=localhost

GOOGLE_CLOUD_PROJECT_ID=your-project-id-here
GOOGLE_CLOUD_KEY_FILE=path/to/your/gcloud-key.json

HTTP_PUBSUB_URI=null
HTTP_PUBSUB_SUBSCRIBE_CONNECTION=redis

Если локальный сервер Redis и клиентские терминалы закрыты, я получаю сообщение об ошибке.


Ошибка при чтении строки с сервера [tcp://localhost:9092]


Пожалуйста, дайте мне знать, если кто-то смог настройте их оба в laravel.

Подробнее здесь: https://stackoverflow.com/questions/538 ... el-project