Index

A C E G H I J K L M N O P R S T
All Classes and Interfaces|All Packages|Constant Field Values

A

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

AbstractKafkaHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.AbstractKafkaHandler

C

canEqual(Object) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

config - Variable in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.AbstractKafkaHandler

E

equals(Object) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

G

getBootstrapServers() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

bootstrap.servers: A list of host/port pairs to use for establishing the initial connection to the Kafka cluster.

getConfigPath() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getConsumers() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getDataFormat() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JsonLogHandler

getDataFormat() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.LogHandler

getGroupId() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

group.id: A unique string that identifies the consumer group this consumer belongs to.

getKafkaConsumerConfig() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

Kafka consumer config.

getKafkaHandlerThreadPoolQueueSize() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getKafkaHandlerThreadPoolSize() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getMm2SourceAlias() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getMm2SourceSeparator() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getNamespace() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getPartitions() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

The number of partitions for the topic being created.

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.AbstractKafkaHandler

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JsonLogHandler

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JVMMetricsHandler

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.LogHandler

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.MeterServiceHandler

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.ProfileTaskHandler

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.ServiceManagementHandler

getPlainTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.TraceSegmentHandler

getReplicationFactor() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

The replication factor for each partition in the topic being created.

getTopic() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.AbstractKafkaHandler

getTopic() - Method in interface org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.KafkaHandler

A topic of Kafka is handled.

getTopicNameOfJsonLogs() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getTopicNameOfLogs() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getTopicNameOfManagements() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getTopicNameOfMeters() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getTopicNameOfMetrics() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getTopicNameOfProfiling() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

getTopicNameOfTracingSegments() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

H

handle(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JVMMetricsHandler

handle(ConsumerRecord<String, Bytes>) - Method in interface org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.KafkaHandler

Deserialize and push it to downstream.

handle(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.LogHandler

handle(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.MeterServiceHandler

handle(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.ProfileTaskHandler

handle(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.ServiceManagementHandler

handle(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.TraceSegmentHandler

hashCode() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

I

isEnableNativeJsonLog() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

isEnableNativeProtoLog() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

J

JsonLogHandler - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

JsonLogHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JsonLogHandler

JVMMetricsHandler - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

A handler deserializes the message of JVM Metrics and pushes it to downstream.

JVMMetricsHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JVMMetricsHandler

K

KafkaFetcherConfig - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.module

KafkaFetcherConfig() - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

KafkaFetcherHandlerRegister - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka

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

KafkaFetcherHandlerRegister(KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.KafkaFetcherHandlerRegister

KafkaFetcherModule - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.module

KafkaFetcherModule() - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherModule

KafkaFetcherProvider - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider

KafkaFetcherProvider() - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

KafkaHandler - Interface in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

A Handler for dealing Message reported by agent.

L

LogHandler - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

LogHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.LogHandler

M

MeterServiceHandler - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

A handler deserializes the message of meter system data and pushes it to downstream.

MeterServiceHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.MeterServiceHandler

module() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

N

name() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

NAME - Static variable in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherModule

newConfigCreator() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

notifyAfterCompleted() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

O

org.apache.skywalking.oap.server.analyzer.agent.kafka - package org.apache.skywalking.oap.server.analyzer.agent.kafka

org.apache.skywalking.oap.server.analyzer.agent.kafka.module - package org.apache.skywalking.oap.server.analyzer.agent.kafka.module

org.apache.skywalking.oap.server.analyzer.agent.kafka.provider - package org.apache.skywalking.oap.server.analyzer.agent.kafka.provider

org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler - package org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

P

parseConsumerRecord(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JsonLogHandler

parseConsumerRecord(ConsumerRecord<String, Bytes>) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.LogHandler

prepare() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

ProfileTaskHandler - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

A handler deserializes the message of profiling snapshot and pushes it to downstream.

ProfileTaskHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.ProfileTaskHandler

R

register(KafkaHandler) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.KafkaFetcherHandlerRegister

requiredModules() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

S

ServiceManagementHandler - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

A handler deserializes the message of Service Management and pushes it to downstream.

ServiceManagementHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.ServiceManagementHandler

services() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherModule

setBootstrapServers(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

bootstrap.servers: A list of host/port pairs to use for establishing the initial connection to the Kafka cluster.

setConfigPath(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setConsumers(int) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setEnableNativeJsonLog(boolean) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setEnableNativeProtoLog(boolean) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setGroupId(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

group.id: A unique string that identifies the consumer group this consumer belongs to.

setKafkaConsumerConfig(Properties) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

Kafka consumer config.

setKafkaHandlerThreadPoolQueueSize(int) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setKafkaHandlerThreadPoolSize(int) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setMm2SourceAlias(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setMm2SourceSeparator(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setNamespace(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setPartitions(int) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

The number of partitions for the topic being created.

setReplicationFactor(int) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

The replication factor for each partition in the topic being created.

setTopicNameOfJsonLogs(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setTopicNameOfLogs(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setTopicNameOfManagements(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setTopicNameOfMeters(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setTopicNameOfMetrics(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setTopicNameOfProfiling(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

setTopicNameOfTracingSegments(String) - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

start() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.KafkaFetcherHandlerRegister

start() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.KafkaFetcherProvider

T

toString() - Method in class org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig

TraceSegmentHandler - Class in org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler

A handler deserializes the message of the trace segment data and pushes it to downstream.

TraceSegmentHandler(ModuleManager, KafkaFetcherConfig) - Constructor for class org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.TraceSegmentHandler

A C E G H I J K L M N O P R S T
All Classes and Interfaces|All Packages|Constant Field Values