当前位置: 首页 > news >正文

做一个网站需要多长时间艾滋病阻断药有哪些

做一个网站需要多长时间,艾滋病阻断药有哪些,个人网站创建平台要多少钱,会展设计专业发展前景前言 log4j2 在 2.11.0 之后的版本,已经内置了 KafkaAppender 支持可以将打印的日志直接发送到 kafka 中,在这之前如果想要集中收集应用的日志,就需要自定义一个 Layout 来实现,相对来说还是比较麻烦的。 官网文档:L…

前言

log4j2 在 2.11.0 之后的版本,已经内置了 KafkaAppender 支持可以将打印的日志直接发送到 kafka 中,在这之前如果想要集中收集应用的日志,就需要自定义一个 Layout 来实现,相对来说还是比较麻烦的。

官网文档:Log4j – Log4j 2 Appenders

依赖

				<!-- kafka client --><dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.0.0</version></dependency><!-- 支持 scala --><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-api-scala_2.12</artifactId><version>11.0</version></dependency><!-- 核心依赖 --><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-api</artifactId><version>2.20.0</version></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId><version>2.20.0</version></dependency>

配置

注意这里有个 syncSend 控制着是否异步发送,false 使用异步发送也就是会攒小批发送,拥有更高的吞吐量,但相对来说延迟也会增加,建议生产环境开启,本地环境关闭,否则可能会出现程序结束了直接退出,导致 kafka 的批攒的数据没有来得及发送,自然也会导致数据丢失。

此外,如果不想每个类的日志都采集到 kafaka 里面,我们可以定义个类,通过这个类发送的日志才收集到 kafka 里面,可以参考下面的配置例子。

<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="INFO"><Properties><Property name="kafkaServers">localhost:9092</Property></Properties><Appenders><!-- 定义 Kafka Appender --><Kafka name="KafkaAppender" syncSend="false" topic="recomm-system-log"><PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n" /><!-- 在此处配置 Kafka 的连接信息 --><Property name="bootstrap.servers">${kafkaServers}</Property></Kafka><Console name="ConsoleAppender" target="SYSTEM_OUT"><PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n" /></Console></Appenders><Loggers><Root level="info"><!-- 将日志记录到控制台 Appender --><AppenderRef ref="ConsoleAppender" /></Root><Logger name="log2kafka.KafkaSender$"><Appender-ref ref="KafkaAppender"/></Logger></Loggers>
</Configuration>

例子

这里用的是 scala,如果是 java 基本大同小异

package log2kafka
import org.apache.logging.log4j.scala.Loggingobject KafkaSender extends Logging {def  send(msg:Any): Unit ={logger.info(msg.toString)}def main(args: Array[String]): Unit = {logger.info("print msg to kafka")}}

kafka 命令行查看数据:

(base) ➜  temp kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testlog
2023-08-30 19:42:05 INFO  KafkaSender$:12 - print msg to kafka
http://www.tj-hxxt.cn/news/115803.html

相关文章:

  • 报告网站开发环境百度搜索软件
  • 更合高明网站建设进入百度首页官网
  • 站长之家ppt模板百度快照在哪里找
  • 做网站后端用户用什么写百度指数是干嘛的
  • 无锡做食品网站的公司哪家好百度竞价点击价格公式
  • 在线兼容测试网站做网站需要什么技术
  • 无锡网站制作公司哪家好如何建立免费个人网站
  • 上海进博会?最好的网站优化公司
  • 陕西省交通建设公司网站安卓手机优化
  • 购物网站首页分成几个模块广告主广告商对接平台
  • 做网站建设的销售怎么样seo黑帽是什么
  • 企业网站上的工资表怎么做百度订单售后电话
  • 淘宝网站模板是什么做的推广app赚佣金平台有哪些
  • 娄底网站建设方案营销活动策划
  • 教育机构网站的通用顶级域名是沈阳网站seo排名公司
  • 12个优秀平面设计素材网站数据交换平台
  • 个性定制网站网络营销的概述
  • 做直通车任务的网站短视频seo代理
  • iis网站属性没有asp.net中国关键词网站
  • 《基层建设》官方网站哈尔滨百度公司地址
  • asp网站没有数据库灰色关键词排名技术
  • 江西建设厅网站财务部网络违法犯罪举报网站
  • 自己做网站上传视频软文素材网站
  • 政府网站建设哪家好百度信息流推广教程
  • 南京营销网站开发制作报价上海百度分公司电话
  • 企业首页html源码新塘网站seo优化
  • 中国勘察设计行业信息化建设网站关键词优化价格表
  • 怎么做网站文件app拉新怎么做
  • 网站建设行业衰落网络营销策划书范文
  • 视觉设计网站uc浏览器关键词排名优化