Spring与Kafka整合

Spring版本：4.2.6.RELEASE

    org.springframework.kafka
    spring-kafka
    1.1.1.RELEASE

  
  
  
    
      
    
  

  
  
    
  

  
  

  
  
    
      
        

        test
      
    
    
    
    
  
  
  
  
  
    
    
  

在spring-context.xml文件中加入配置

@Slf4j
public class KafkaConsumerListener implements AcknowledgingMessageListener {

  @Override
  public void onMessage(ConsumerRecord data, Acknowledgment ack) {
    try {
      log.info("Kafka消费消息为：{}", data);
      ack.acknowledge();
    } catch (Exception e) {
      log.error("Kafka消息消费异常，错误原因为：{}", e.getMessage());
    } finally {
      ack.acknowledge();
    }
  }
}