Examples of KafkaMetricsConfig

Examples of kafka.metrics.KafkaMetricsConfig

45
46
47
48
49
50
51
52
53
54
55
56
57
58
    synchronized public void init(VerifiableProperties props) {
        if (!initialized) {
            this.props = props;
            props.props().put("metadata.broker.list", String.format("%s:%d", "localhost", props.getInt("port")));

            final KafkaMetricsConfig metricsConfig = new KafkaMetricsConfig(props);

            this.underlying = new TopicReporter(Metrics.defaultRegistry(),
                    new ProducerConfig(props.props()),
                    "broker%s".format(props.getString("broker.id")));
            initialized = true;
            startReporter(metricsConfig.pollingIntervalSecs());
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.