Merge pull request #1105 from siyuanh/ukafkafix

Big kafka consumer change
Set corePoolSize for single metadata refresh thread.