plum

default implement for async?

server how to close socket.io connection?

3

directly call Close()? When I directly call Close(), client will retry again. If I want to set code when server close socket.io connection, what should I do? THX!

[eventbus] Support Kafka clustering

7

Hi, When this project can support kafka cluster?

Can only use cqrs without es that is in the application for project without DDD?

1

Can only use cqrs without es that is in the application for project without DDD? Any examples? thx

consumer group can not consume

3

When producer did not produce msg to kafka for long time,after long time producer produces msg again, but consumer group does not consume msg, if not restart consumer. Why ?

能否将cqrs部分单独抽出来独立于DDD、ES及任何框架，单独作为一个tool使用呢？

心跳

1

客户端和服务端建立websocket连接后，客户端不需要定时给服务端发送心跳吗？

关于grpc超时控制，grpc client可以通过拦截器设置超时，grpc server如何在调用超时时结束当前流程，尝试通过如下形式实现，但是也不能保证超时后服务端立即结束当前调用 data := make(chan *pb.SimpleResponse, 1) go handle(ctx, req, data) select { case res :=

pkg/buffer可以直接用sync.Pool吧，为啥要自己实现一遍呢？

消息发送疑问

3

client-->comnet: tcp/ws长连接是用于客户端发送指令消息吗？ 业务消息是通过client-->logic的http请求? 谢谢！