先说明kafka的版本信息kafka_2.10-0.10.0.1
接下来是在eclipse中进行测试的案例：
以上是在把kafka的目录下面的libs下面的依赖copy的新建的java project中。注意我这里是用的kafka_2.10-0.10.0.1版本、
下面给出log4j.propertied的配置信息
log4j.rootLogger = info,stdout,kafka
#kafka appender
log4j.appender.kafka = org.apache.kafka.log4jappender.KafkaLog4jAppender
log4j.appender.kafka.topic = kafka_log4j //对应kafka中的topic信息
log4j.appender.kafka.brokerList=mini08:9092 //对应kafka集群的broker地址和端口信息
log4j.appender.kafka.layout=org.apache.log4j.PatternLayout //日志输出格式
log4j.appender.kafka.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c] [%p] - %m%n
log4j.appender.stdout = org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target = System.out
log4j.appender.stdout.layout = org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern = [%-5p] %d{yyyy-MM-dd HH:mm:ss,SSS} method:%l%m%n
下面给出测试程序：