BUG FIX: topic name should respect appid from params instead of header
BUG FIX: topic name should respect appid from params instead of header

funkygao/gafka,funkygao/gafka,funkygao/gafka,funkygao/gafka,funkygao/gafka