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
Post a Comment