Tony.Chen
Tony.Chen
应该是broker.id和host.name没配置
这个是kafka的配置没配对,需要加上host.name={ip},建议看看kafka相关的部署
可以在GOPATH看看有没有github.com/gogo/protobuf/gogoproto目录不呢
可以把gogoproto clone到$GOPATH/src/github.com/gogo/protobuf/gogoproto/,或者直接使用kratos tool protoc api.proto
现在服务发现使用了discovery,并没使用到zk,目前kafka倒是用到了。可以考虑支持etcd的适配。
最近因为对公司收购的项目进行重构迁移,更新估计会邂逅一些,希望大家可以多提mr~
这种属于广播设计,比如百万级房间在线是很容易承载的 如果要处理这个问题,也可以在job定时拉一份rooms回来过虑的,其实广播一份如果量不大也不会有太大问题
可以看公司消息队列进行选择的,其实这里应该做成interface进行init配置会比较合适
nats好像出2.0了,看着还挺不错的
那个 grpc.WithTimeout 官方已经废弃了,DialContext 进行指定连接超时,kratos timeout 主要是保护客户端请求超时,或者服务端超时。比如发起了几个请求,然后总耗时为5s,其中有一个请求进行降级都是用户通过timeout控制。