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

Class KafkaFetcherHandlerRegister

java.lang.Object

org.apache.skywalking.oap.server.analyzer.agent.kafka.KafkaFetcherHandlerRegister

public class KafkaFetcherHandlerRegister
extends Object

Configuring and initializing a KafkaConsumer client as a dispatcher to delivery Kafka Message to registered handler by topic.

Constructor Summary

Constructors

Constructor	Description
KafkaFetcherHandlerRegister(KafkaFetcherConfig config)

Method Summary

Modifier and Type	Method	Description
void	register(KafkaHandler handler)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaFetcherHandlerRegister

public KafkaFetcherHandlerRegister(KafkaFetcherConfig config)

Method Details

register

public void register(KafkaHandler handler)

start

public void start()
           throws org.apache.skywalking.oap.server.library.module.ModuleStartException

Throws:

org.apache.skywalking.oap.server.library.module.ModuleStartException