zoukankan      html  css  js  c++  java
  • 058 kafka与log4j集成

    1.首先在resources下面写log4j.properties

      主要是因为kafka.producer.KafkaLog4jAppender类的存在。

     1 log4j.rootLogger=INFO,console,KAFKA
     2 
     3 ## appender KAFKA
     4 log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender
     5 ## topic must exitss
     6 log4j.appender.KAFKA.topic=beifeng
     7 log4j.appender.KAFKA.brokerList=linux-hadoop01.ibeifeng.com:9092,linux-hadoop01.ibeifeng.com:9093
     8 log4j.appender.KAFKA.compressionType=none
     9 log4j.appender.KAFKA.syncSend=false
    10 log4j.appender.KAFKA.layout=org.apache.log4j.PatternLayout
    11 log4j.appender.KAFKA.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L %% - %m
    12 
    13 ## appender console
    14 log4j.appender.console=org.apache.log4j.ConsoleAppender
    15 log4j.appender.console.layout=org.apache.log4j.PatternLayout
    16 log4j.appender.console.layout.ConversionPattern=%d (%t) [%p - %l] %m%n

    2.测试类

     1 package com.jun.it;
     2 
     3 
     4 import org.apache.log4j.Logger;
     5 
     6 public class KafkaLoggerTest {
     7     public static final Logger logger = Logger.getLogger(KafkaLoggerTest.class);
     8 
     9     public static void main(String[] args) throws InterruptedException {
    10         for(int i=0;i<50;i++) {
    11             logger.debug("debug_" + i);
    12             logger.info("info_" + i);
    13             logger.warn("warn_" + i);
    14             logger.error("error_" + i);
    15             logger.fatal("fatal_" + i);
    16         }
    17 
    18         // 如果不sleep,会出现什么情况?怎么解决
    19         Thread.sleep(10000);
    20     }
    21 }

    3.开启9092端口的消费者服务

      bin/kafka-console-consumer.sh --topic beifeng --zookeeper linux-hadoop01.ibeifeng.com:2181/kafka

    4.效果

      

  • 相关阅读:
    C#线程优先级浅析
    Android常用组件
    Android 内存监测工具 DDMS --> Heap
    Android 十个非常漂亮的常用组件
    RelativeLayout 相对布局 常用属性
    Android 关于横竖屏
    (转)Android 之 StrictMode 介绍
    Android如何获取SIM卡信息
    Android 读SIM卡信息
    Android Camera 使用小结
  • 原文地址:https://www.cnblogs.com/juncaoit/p/9426403.html
Copyright © 2011-2022 走看看