package com.sitech.kafka;

import java.util.Properties;


import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;

/**
 * KafkaProducerTest.java
 *
 * ���� �ܡ�����һ�仰�������ļ���ʲô
 * ���� ������KafkaProducerTest
 *
 * �������������
 *  
 *    ����            �汾                ����                   ������� 
 * -------------------------------------------               
 *  2015-3-18   v1.0     dongyj            �¹�����   
 *
 *
 *
 * ���� Ȩ����
 *  Copyright (c) 2015  : ~SI-TECH~.
 *  
 */
public class KafkaProducerTest {

	private static KafkaConfig kafkaConfig = new KafkaConfig();
	private static kafka.javaapi.producer.Producer<Integer, String> producer;
    private static Properties props;
    
    public static void main(String args[]){
    	try {
			props = kafkaConfig.createProducerConfig();
			producer = new kafka.javaapi.producer.Producer<Integer, String>(new ProducerConfig(props));
//			UserInfo info = new UserInfo();
//			info.setUsername("dongyj12");
//			info.setPassword("dongyj2015");
//			info.setAge("27");
//			info.setContent("afes asdkj aidiwdnfe23");
//			String messageStr = JacksonUtil.toJson(info);
			String messageStr = new String("Message1234_dyj");
			producer.send(new KeyedMessage<Integer, String>(kafkaConfig.getPerfTopic(), messageStr));
		} catch (Exception e) {
			System.out.println("异常..");
			e.printStackTrace();
		} finally{
			producer.close();
		}
		
    }
	
	
	
}