KAFKA-808 Migration tool internal queue between consumer and producer threads should be configurable; reviewed by Jun Rao