{"repo":"go-god/broker","free":true,"listed":false,"github":"https://github.com/go-god/broker","clone":"git clone https://github.com/go-god/broker.git","description":"go broker interface,you can use kafka,redis,pulsar etc.","language":"Go","stars":12,"topics":["broker","kafka-broker","pulsar","redis-broker","go-broker","pulsar-broker","kafka","redis"],"license":"MIT","category":"databases-storage","readme_excerpt":"broker go-god/broker 是一个统一的 Go 消息队列抽象层，业务代码只需面向 broker.Broker 接口编程，即可在 Kafka、Pulsar、Redis 等不同消息中间件之间切换。 架构设计 接口定义 核心实现 实现 依赖 文档 ------ ------ ------ gkafka IBM/sarama gkafka/readme.md gpulsar apache/pulsar-client-go gpulsar/readme.md gredis redis/go-redis 参考 gredis 测试用例 快速开始 切换 Pulsar 只需要替换实现： 通用 Option Option 说明 -------- ------ WithBrokerAddress broker 地址列表 WithUser 用户名（Kafka SASL） WithPassword 密码（Kafka SASL） WithLogger 日志接口 WithOperationTimeout 操作超时 WithConnectionTimeout 连接超时 WithGracefulWait 优雅关闭等待时间 各实现还有自己专属的 Option，详见对应实现文档。 Pulsar in docker https://pulsar.apache.org/docs/2.11.x/getting-started-docker/ 注意事项 - Kafka 消费者组要求 Kafka 版本 = V0 10 2 0 ，低于该版本请使用 go-god/broker v1.1.2 - 具体使用方式请参考 gkafka / gpulsar / gredis 下的测试用例与专属文档","default_branch":null,"files":null,"tree":[],"storefront":"/r/go-god","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/go-god/broker/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}