fix kafka producer bug