Данный проект представляет собой очередь сообщений для внутренней системной шины, которая не является FIFO (First In, First Out) и реализована на основе материализованной очереди PostgreSQL.
KafkaBridge — это открытый исходный код Kafka от 360. Он основан на librdkafka и по сравнению с ним включает в себя множество деталей использования, прост и удобен в применении, пользователю не нужно разбираться в тонкостях Kafka.
Go-stash — это эффективный инструмент для получения данных из Kafka, их обработки в соответствии с заданными правилами и последующей отправки в кластер ElasticSearch.
Dister (Distribution Cluster) — это легковесное и высокопроизводительное программное обеспечение для управления распределёнными кластерами. Оно реализует распространённые ключевые компоненты в архитектуре распределённых систем:
* центр управления конфиг...
Централизованный компонент управления конфигурацией. Этот проект был создан для решения проблемы несогласованности конфигураций в нескольких проектах и средах одной компании, а также для упрощения процесса внесения изменений.
TSeer — это решение для регистрации, обнаружения сервисов и обработки отказов, созданное командой разработчиков высокопроизводительного RPC-фреймворка Tars от компании Tencent. Оно представляет собой облегчённую версию функций именования сервисов Tars.
Это библиотека асинхронного MQTT-клиента на основе Swoole, которая может использоваться для получения и отправки сообщений по протоколу MQTT. Поддерживает QoS 0, QoS 1 и QoS 2. Совместима с версиями MQTT 3.1 и 3.1.1. См. workerman-mqtt.
