FR: `kafka.Server` 添加一个 option 进来，传入 `broker.Broker`

[fzdwx]

示例代码:

func WithBroker(b broker.Broker) ServerOption {
    return func(s *Server) {
        s.Broker = b
    }
}

func NewServer(opts ...ServerOption) *Server {
    srv := &Server{
        ...
    }

    srv.doInjectOptions(opts...)

    if srv.Broker == nil {
        srv.Broker = kafka.NewBroker(srv.brokerOpts...)
    }

    return srv
}

原因：

一个服务可能同时生产消息与消费消息，复用同一个 broker。

[tx7do]

怎么能这样呢？

[fzdwx]

怎么不能呢？ 😭

[tx7do]

https://github.com/tx7do/kratos-uba

我这里应该有相关的应用。你看看。