kafka java process consuming way large memory specially thread called org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1

Question

org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1 consume large memory how to reduce it I'm using Kafka listener inside spring boot application

Code sample of my Kafka listener:-

 @KafkaListener(topics = "applicant", groupId = "applicant")
    public void subscribeApplicantTopic(String message,@Header(KafkaHeaders.CORRELATION_ID) String requestId) throws Exception {
        Gson gson = new Gson();
        ApplicantKafkaEvent kafkaEvent = gson.fromJson(message, ApplicantKafkaEvent.class);
        if (EventsEnum.APPLICANT_REGISTRATION.getValue().equals(kafkaEvent.getEventName()))
            userService.registerNewApplicantUser(kafkaEvent.getEventData());
        else if(EventsEnum.APPLICANT_EXPIRED.getValue().equals(kafkaEvent.getEventName()))
            userService.applicationExpire(kafkaEvent.getEventData());
    }

Answer 1

等待大神答复