JVM сталкивается с проблемой кучи памяти при переключении на кластер кафки SSL с использованием apache верблюда - PullRequest
Новая
       36

JVM сталкивается с проблемой кучи памяти при переключении на кластер кафки SSL с использованием apache верблюда

0 голосов
/ 01 апреля 2020

Я использую apache Camel Spring DSL для подключения к темам kafka. При использовании кластера без SSL-кафки все работает нормально, но как только я переключаю его на SSL-кластер, куча JVM будет продолжать увеличиваться и через некоторое время убьет службу. Однако я могу успешно отправлять и принимать сообщения, но из-за проблем с кучей служба часто отключается. Я попытался увеличить память с 1 ГБ до 2 ГБ и 3 ГБ, но процесс будет занимать все доступное пространство. Запрос о помощи для решения этой проблемы.

Дополнительная информация: 

Apache Camel Version: 2.19.0, 
Kafka Client: 0.10.1.1, 
Spring Version: 4.3.7.RELEASE, 
Connecting through spring DSL:



<camel:to uri = "kafka:[[kafka.zookeeper]]?securityProtocol=SSL
&sslProtocol=TLSv1.2&topic=[[kafka.topic]]&groupId=[[kafka.consumer.group.id]]
&brokers=[[kafka.brokers]]&sslTruststoreLocation=path/truststore.jks
&sslTruststorePassword=password&sslKeystoreLocation=path/keystore.jks
&sslKeystorePassword=password&sslKeyPassword=password" />

Ошибка, которую я получаю из журналов. 

**Uncaught exception in kafka-producer-network-thread | producer-8:
java.lang.OutOfMemoryError: Java heap space
        at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) ~[na:1.8.0_25]
        at java.nio.ByteBuffer.allocate(ByteBuffer.java:335) ~[na:1.8.0_25]
        at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:93) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.common.network.Selector.poll(Selector.java:291) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:236) ~[kafka-clients-0.10.1.1.jar:na]
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135) ~[kafka-clients-0.10.1.1.jar:na]
        at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_25]
2020-03-31 07:12:00,013--INFO Class:: org.apache.camel.util.CamelLogger Method :: log :159
...