how to pause Kafka Consumer when I am using @KafkaListener Annotation -


i pulling data data base check if have available system resources process further messages coming kafkalistener. if condition not met want @kafkalistener pause , when condition met, want @kafkalistener resume. how achieve in spring kafka?

also there disadvantages of pausing consumer particular partition? ­­­­­­­­­­­­­­­­­­­­­­­­­­­

there no pause/resume control in current version. automatic framework, when detects slow listener.

in latest 2.0 have opposite situation: don't provide automatic pause/resume - no reason more, @ same time allow configure @kafkalistener method consumer argument, can perform desired logic there already.


Comments

Popular posts from this blog

node.js - Node js - Trying to send POST request, but it is not loading javascript content -

javascript - Replicate keyboard event with html button -

javascript - Web audio api 5.1 surround example not working in firefox -