Tag: kafka consumer api

卡夫卡消费者启动延迟融合了dotnet

在启动汇合点网络消费者时，在调用订阅和后续轮询之后，似乎需要很长时间才能从服务器接收“分配已分配”事件，因此消息（大约10-15秒）。 起初我认为有一个自动主题创建开销，但无论消费者的主题/消费者群体是否已经存在，时间都是相同的。 我使用此配置启动我的使用者，其余代码与汇合的高级消费者示例中的相同： var kafkaConfig = new Dictionary { {“group.id”, config.ConsumerGroup}, {“statistics.interval.ms”, 60000}, {“fetch.wait.max.ms”, 10}, {“bootstrap.servers”, config.BrokerList}, {“enable.auto.commit”, config.AutoCommit}, {“socket.blocking.max.ms”,1}, {“fetch.error.backoff.ms”,1 }, {“socket.nagle.disable”,true }, {“auto.commit.interval.ms”, 5000}, { “default.topic.config”, new Dictionary() { {“auto.offset.reset”, “smallest”} } } }; kafka群集由具有默认设置的远程数据中心中的3台中低端规格机器组成。 是否有可以调整的代理或客户端设置以降低启动时间？ 编辑：在启动时间约为2秒的情况下，自己使用Assign而不是Subscribe结果分配分区