我正在使用wrk对一个用Go编写的简单网络服务器进行基准测试。服务器在具有4GBRAM的机器上运行。在测试开始时，代码服务高达2000个请求/秒，性能非常好。但随着时间的推移，进程使用的内存逐渐增加，一旦达到85%(我正在使用top进行检查)，吞吐量就会下降到约100个请求/秒。一旦我重新启动服务器，吞吐量再次增加到最佳数量。性能下降是内存问题吗？为什么Go不释放这段内存？我的Go服务器看起来像这样:funcmain(){deferfunc(){//Waitforallmessagestodrainoutbeforeclosingtheproducerp.Flush(1000)p.Cl

我有一个消费者worker应用程序，它在内部启动X个线程，每个线程都生成它的KafkaCosnumer。Cosnumers具有相同的groupId并且订阅了相同的主题。因此，每个消费者都能公平地分配分区。处理的本质是我不能丢失消息，也不能允许重复。我运行的kafka版本是0.10.2.1。这是我面临的问题:消费者线程1开始消费消息，并且在poll()上获取了一批消息。我还实现了ConsumerRebalanceListener，这样每次成功处理消息时，它都会被添加到offsets映射中。(见下面的代码。)因此，一旦重新平衡发生，我可以在我的分区重新分配给其他消费者之前提交我的偏移量。有