文件名称：Log-Streamer-Kafka-Java:使用 kafka 从简单的 log4j 日志生成中实时流式传输日志
文件大小：12.38MB
文件格式：ZIP
更新时间：2024-07-19 07:33:13
Java
Log-Streamer-Kafka-Java 使用 kafka 从简单的 log4j 日志生成中实时流式传输日志 先决条件 基于zookeeper集群的运行kafka服务器 日志生成器 使用log4j构建简单的日志，实时生成并每0.5秒保存到日志文件中 Log Streamer（在 kafka 中称为生产者） 重复读取日志文件，一旦将新日志添加到日志文件中， 开始将新添加的日志流式传输到 kafka 服务器，以便 kafka 消费者可以 消耗新添加的日志
【文件预览】：
Log-Streamer-Kafka-Java-master
----conf()
--------log4j.properties(387B)
--------logRecord.txt(4B)
----kafkaProducer.iml(496B)
----src()
--------logStreamer.java(3KB)
--------logConsumer.java(71B)
--------SimplePartitioner.java(542B)
--------logGenerator.java(1KB)
----lib()
--------zkclient-0.3.jar(63KB)
--------snappy-java-1.0.5.jar(1.19MB)
--------kafka_2.8.0-0.8.1.1-javadoc.jar(37KB)
--------metrics-core-2.2.0.jar(80KB)
--------scala-library-2.8.0.jar(5.88MB)
--------zookeeper-3.3.4.jar(590KB)
--------slf4j-api-1.7.2.jar(25KB)
--------log4j-1.2.15.jar(383KB)
--------kafka_2.8.0-0.8.1.1-scaladoc.jar(2.05MB)
--------jopt-simple-3.2.jar(52KB)
--------slf4j-nop-1.7.10.jar(4KB)
--------kafka_2.8.0-0.8.1.1.jar(3.13MB)
--------kafka_2.8.0-0.8.1.1-sources.jar(4KB)
----.idea()
--------libraries()
--------misc.xml(8KB)
--------compiler.xml(709B)
--------uiDesigner.xml(9KB)
--------dataSources.xml(845B)
--------dictionaries()
--------.name(13B)
--------encodings.xml(164B)
--------modules.xml(266B)
--------scopes()
--------copyright()
--------vcs.xml(219B)
----README.md(513B)
----data()
--------log.txt(3KB)