astream collector thrift to kafka