tx7do / kratos-transport

kratos transport layer extension
MIT License
348 stars 95 forks source link

在kafka server中,如何指定kafka-go的reader的QueueCapacity参数 #36

Closed chazex closed 1 year ago

chazex commented 1 year ago

Hi, 我在kratos中,使用kafka的server,需要配置一下Borker的readerConfig的QueueCapacity。现在支持吗?

tx7do commented 1 year ago

更新到最新的版本,serverKafka.WithBrokerOptions(brokerKafka.WithQueueCapacity())注入。