You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Andreas Holmén (Jira)" <ji...@apache.org> on 2020/02/04 09:00:00 UTC
[jira] [Created] (KAFKA-9504) Memory leak in KafkaMetrics
registered to MBean
Andreas Holmén created KAFKA-9504:
-------------------------------------
Summary: Memory leak in KafkaMetrics registered to MBean
Key: KAFKA-9504
URL: https://issues.apache.org/jira/browse/KAFKA-9504
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 2.4.0
Reporter: Andreas Holmén
After close() called on a KafkaConsumer some registered MBeans are not unregistered causing leak.
{code:java}
import static org.apache.kafka.clients.consumer.ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG;
import java.lang.management.ManagementFactory;
import java.util.HashMap;
import java.util.Map;
import javax.management.MBeanServer;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.serialization.ByteArrayDeserializer;
public class Leaker {
private static String bootstrapServers = "hostname:9092";
public static void main(String[] args) throws InterruptedException {
MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
Map<String, Object> props = new HashMap<>();
props.put(BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
int beans = mBeanServer.getMBeanCount();
for (int i = 0; i < 100; i++) {
KafkaConsumer<byte[], byte[]> consumer = new KafkaConsumer<>(props, new ByteArrayDeserializer(), new ByteArrayDeserializer());
consumer.close();
}
int newBeans = mBeanServer.getMBeanCount();
System.out.println("\nbeans delta: " + (newBeans - beans));
}
}
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)