reader

ConsumerHandler

RecordListener

rq

records

PersistenceWriter

rq

handler

run

ConsumerWriter