Package org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

Class AbstractKafkaHandler

java.lang.Object

org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.AbstractKafkaHandler

All Implemented Interfaces:

KafkaHandler

Direct Known Subclasses:

JVMMetricsHandler, LogHandler, MeterServiceHandler, ProfileTaskHandler, ServiceManagementHandler, TraceSegmentHandler

public abstract class AbstractKafkaHandler
extends Object
implements KafkaHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected KafkaFetcherConfig	config

Constructor Summary

Constructors

Constructor	Description
AbstractKafkaHandler(org.apache.skywalking.oap.server.library.module.ModuleManager manager, KafkaFetcherConfig config)

Method Summary

Modifier and Type	Method	Description
protected abstract String	getPlainTopic()
String	getTopic()	A topic of Kafka is handled.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.KafkaHandler

handle

Field Details

config

protected KafkaFetcherConfig config

Constructor Details

AbstractKafkaHandler

public AbstractKafkaHandler(org.apache.skywalking.oap.server.library.module.ModuleManager manager,
 KafkaFetcherConfig config)

Method Details

getTopic

public String getTopic()

Description copied from interface: KafkaHandler

A topic of Kafka is handled.

Specified by:

getTopic in interface KafkaHandler

getPlainTopic

protected abstract String getPlainTopic()