Add skeleton for kafka producer on intake.