java监听kafka_java实时监听日志写入kafka

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileReader;

import java.io.FileWriter;

import java.io.IOException;

import java.io.LineNumberReader;

import java.io.PrintWriter;

import java.io.RandomAccessFile;

import java.net.NoRouteToHostException;

import java.util.ArrayList;

import java.util.Collection;

import java.util.List;

import java.util.Properties;

import java.util.Random;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

import kafka.javaapi.producer.Producer;

import kafka.producer.KeyedMessage;

import kafka.producer.ProducerConfig;

/*

* 自己在源服务器写生产者往kafka插入数据，注意文件"producer.properties放在linux下该jar文件同一目录

* 监听某个目录下的文件数据然后写入kafka

* nohup java -jar portallog_producer.jar portallog /var/apache/logs portallog.position  >/home/sre/portalhandler/handler.log 2>&1 &

*

*

*/

public class PortalLogTail_Line {

private Producer inner;

java.util.Random ran = new Random()