Kafka Consumer memory Leak

[jilsonjoseph]

I get a memory leak when my consumers work on dev enviroments, without any load

Expected Behavior
memory not leak

Actual Behavior
memory leak

Steps to reproduce
Our Consumer creation code is below

        .createReceiveRecord(
            new TypeReference<OrderEventRetryDTO>() {
            },
            kafkaConsumerConfigProperties)
        .doOnNext(this::process)
        .onErrorContinue(this::onError)
        .doOnError(exception ->
            log.error(String.format(
                "Exception while consuming message on topic=%s with error = ", topic), exception))
        .subscribe();

In dynatrace we are seeing this below.

Our Environment
Java version: 17
Reactor version(s) used: io.projectreactor.kafka:reactor-kafka: 1.3.8

[garyrussell]

Have you looked at the heap to see what the leak consists of?