github.com/tx7do/kratos-transport/transport/kafka

kratos transport layer extension


Keywords
activemq, amqp, asynq, gin, golang, http3, iris, kafka, kratos, machinery, microservice, mqtt, nats, nsq, pulsar, rabbitmq, redis, rocketmq, stomp, websocket
License
MIT
Install
go get github.com/tx7do/kratos-transport/transport/kafka

Documentation

kratos-transport

把消息队列、任务队列,以及Websocket、HTTP3等网络协议实现为微服务框架 Kratostransport.Server

在使用的时候,可以调用kratos.Server()方法,将之注册成为一个Server

各种缝合,请叫我:缝合怪。

支持的服务(Server)

消息队列

RPC

任务队列

网络协议

支持的消息代理(Broker)

应用示例

以上示例在Kratos官方示例代码库中也可以找到。