Что это?
PicoMQ — это система потоковой передачи в реальном времени с долговременным хранением, которая держит данные в S3-совместимом объектном хранилище вместо локальных дисков и при этом понимает как собственный HTTP-протокол, так и сетевой протокол Kafka.
PicoMQ — это система потоковой передачи в реальном времени с долговременным хранением, которая держит данные в S3-совместимом объектном хранилище вместо локальных дисков и при этом понимает как собственный HTTP-протокол, так и сетевой протокол Kafka.Это клон Kafka или прокси перед S3?Это самостоятельный сервер со своим слоем метаданных и протокольными фронтендами (HTTP с нативным протоколом Pico и Durable Streams плюс Kafka-совместимый фронтенд), а запись лога в объектное хранилище выполняет отдельный движок s3stream.
Это самостоятельный сервер со своим слоем метаданных и протокольными фронтендами (HTTP с нативным протоколом Pico и Durable Streams плюс Kafka-совместимый фронтенд), а запись лога в объектное хранилище выполняет отдельный движок s3stream.Как его запустить?Установите pico CLI через cargo (бинарник pico попадёт в ~/.cargo/bin) или запустите на месте через 'cargo run -p picomq-cli --'; либо вообще пропустите установку и поднимите весь стек через Docker Compose.
Установите pico CLI через cargo (бинарник pico попадёт в ~/.cargo/bin) или запустите на месте через 'cargo run -p picomq-cli --'; либо вообще пропустите установку и поднимите весь стек через Docker Compose.Нужны ли мне собственные Postgres и S3-бакет для работы с ним?В комплектном варианте Docker Compose Postgres и объектное хранилище создаются за вас, но PicoMQ умеет работать и по схеме «принеси своё» — с существующей базой Postgres и объектным хранилищем, настроенными через файл .env.
В комплектном варианте Docker Compose Postgres и объектное хранилище создаются за вас, но PicoMQ умеет работать и по схеме «принеси своё» — с существующей базой Postgres и объектным хранилищем, настроенными через файл .env.Аутентификация включена по умолчанию?Нет, авторизация по умолчанию выключена. Если привязываете ноду к чему-то кроме loopback, нужно явно передать --auth required или --insecure-allow-remote.
Нет, авторизация по умолчанию выключена. Если привязываете ноду к чему-то кроме loopback, нужно явно передать --auth required или --insecure-allow-remote.Какие порты открывает конфигурация Docker Compose?Она открывает Pico-ноду (плюс :4438 для режима кластера), веб-панель на :9090 и Connectors API на :8081.
Она открывает Pico-ноду (плюс :4438 для режима кластера), веб-панель на :9090 и Connectors API на :8081.Как проверить, что нода в порядке?Каждая нода отдаёт эндпоинты /health и /ready на административном слушателе, который по умолчанию слушает 127.0.0.1:9090.
Каждая нода отдаёт эндпоинты /health и /ready на административном слушателе, который по умолчанию слушает 127.0.0.1:9090.Можно настроить ноду только переменными окружения?Да, у каждого флага CLI есть соответствующая переменная окружения с префиксом PICO_, так что ноды можно настраивать без передачи флагов.
Да, у каждого флага CLI есть соответствующая переменная окружения с префиксом PICO_, так что ноды можно настраивать без передачи флагов.Which topics is it in?message-broker, object-storage, message-queue, kafka, postgres, realtime, s3, distributed-systems, streaming, dashboard, rust, api
message-broker, object-storage, message-queue, kafka, postgres, realtime, s3, distributed-systems, streaming, dashboard, rust, api