小编JJ1*_*15k的帖子

启动融合的dotnet使用者时，在调用订阅和随后的轮询之后，似乎需要很长时间才能从服务器接收到“分配的分区”事件，并因此收到消息（大约10-15秒）。

起初我以为会有自动创建主题的开销，但是无论消费者的主题/消费者组是否已经存在，时间都是相同的。

我从此配置开始使用我的使用者，其余代码与合并的高级使用者示例相同：

            var kafkaConfig = new Dictionary<string, object>
        {
            {"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<string, object>()
                {
                    {"auto.offset.reset", "smallest"}
                }
            }
        };

kafka集群由具有默认设置的远程数据中心中的3台中低端规格机器组成。是否可以调整代理或客户端设置以减少启动时间？

编辑：使用“分配”而不是“订阅”自己分配分区，导致启动时间约为2秒