spring+kafka实例

/* * Project: SpringKafkaDEMO * * File Created at 2016年12月8日 * * Copyright 2016 CMCC Corporation Limited. * All rights reserved. * * This software is the confidential and proprietary information of * ZYHY Company. ("Confidential Information"). You shall not * disclose such Confidential Information and shall use it only in * accordance with the terms of the license. */ package com.curiousby.baoy.cn.kafka; import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.integration.kafka.support.KafkaHeaders; import org.springframework.integration.support.MessageBuilder; import org.springframework.messaging.MessageChannel; import org.springframework.stereotype.Service; /** * @see com.curiousby.baoy.cn.kafka.KafkaProductorService * @Type KafkaConsumerService.java * @Desc * @author cmcc-B100036 * @date 2016年12月8日 下午4:09:29 * @version */ @Service public class KafkaProductorService { @Autowired @Qualifier("pChannel") private MessageChannel messageChannel; public void sendInfo(String topic, Object obj) { System.out.println("---Service:KafkaService------sendInfo------"); messageChannel.send(MessageBuilder.withPayload(obj).setHeader(KafkaHeaders.TOPIC,topic).build()); } } /** * Revision history * ------------------------------------------------------------------------- * * Date Author Note * ------------------------------------------------------------------------- * 2016年12月8日 cmcc-B100036 creat */