|  | @@ -153,7 +153,7 @@ public class RecommendLoghubAppender<E> extends UnsynchronizedAppenderBase<E> {
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |              try {
 | 
	
		
			
				|  |  |                  this.producer.send(this.projectConfig.getProject(), this.logStore, this.topic, this.source, logItems,
 | 
	
		
			
				|  |  | -                        new com.tzld.piaoquan.recommend.server.common.RecommendLoghubAppenderCallback(this, this.projectConfig.getProject(), this.logStore,
 | 
	
		
			
				|  |  | +                        new RecommendLoghubAppenderCallback(this, this.projectConfig.getProject(), this.logStore,
 | 
	
		
			
				|  |  |                                  this.topic, this.source, logItems));
 | 
	
		
			
				|  |  |              } catch (Exception var9) {
 | 
	
		
			
				|  |  |                  this.addError("Failed to send log, project=" + this.project + ", logStore=" + this.logStore + ", topic=" + this.topic + ", source=" + this.source + ", logItem=" + logItems, var9);
 |