KafkaReporter.java 文件源码

private KafkaReporter(MetricRegistry registry, String name,
        TimeUnit rateUnit, TimeUnit durationUnit, boolean showSamples, MetricFilter filter,
        String topic, ProducerConfig config, String prefix,
        String hostName, String ip) {
    super(registry, name, filter, rateUnit, durationUnit);
    this.topic = topic;
    this.config = config;
    this.prefix = prefix;
    this.hostName = hostName;
    this.ip = ip;

    this.mapper = new ObjectMapper().registerModule(new MetricsModule(rateUnit,
               durationUnit,
               showSamples));

    producer = new Producer<String, String>(config);

    kafkaExecutor = Executors
            .newSingleThreadExecutor(new ThreadFactoryBuilder()
                    .setNameFormat("kafka-producer-%d").build());
}