reader

ConsumerHandler ConsumerHandler

receive

RecordListener

RecordListener

rq

records

PersistenceWriter

rq

handler