Kafka读取本地文件做为生产者

package com.qf.utils; import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; import kafka.producer.ProducerConfig; import kafka.serializer.StringEncoder; import java.io.*; import

>>阅读原文<<