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

Class KafkaFetcherConfig

java.lang.Object
org.apache.skywalking.oap.server.library.module.ModuleConfig
org.apache.skywalking.oap.server.analyzer.agent.kafka.module.KafkaFetcherConfig
public class KafkaFetcherConfig extends org.apache.skywalking.oap.server.library.module.ModuleConfig

  • Constructor Details

    • KafkaFetcherConfig

      public KafkaFetcherConfig()

  • Method Details

    • getKafkaConsumerConfig

      public Properties getKafkaConsumerConfig()
      Kafka consumer config.

    • getBootstrapServers

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

    • getGroupId

      public String getGroupId()
      group.id: A unique string that identifies the consumer group this consumer belongs to.

    • getPartitions

      public int getPartitions()
      The number of partitions for the topic being created.

    • getReplicationFactor

      public int getReplicationFactor()
      The replication factor for each partition in the topic being created.

    • isEnableNativeProtoLog

      public boolean isEnableNativeProtoLog()

    • isEnableNativeJsonLog

      public boolean isEnableNativeJsonLog()

    • getConfigPath

      public String getConfigPath()

    • getTopicNameOfMetrics

      public String getTopicNameOfMetrics()

    • getTopicNameOfProfiling

      public String getTopicNameOfProfiling()

    • getTopicNameOfTracingSegments

      public String getTopicNameOfTracingSegments()

    • getTopicNameOfManagements

      public String getTopicNameOfManagements()

    • getTopicNameOfMeters

      public String getTopicNameOfMeters()

    • getTopicNameOfLogs

      public String getTopicNameOfLogs()

    • getTopicNameOfJsonLogs

      public String getTopicNameOfJsonLogs()

    • getKafkaHandlerThreadPoolSize

      public int getKafkaHandlerThreadPoolSize()

    • getKafkaHandlerThreadPoolQueueSize

      public int getKafkaHandlerThreadPoolQueueSize()

    • getNamespace

      public String getNamespace()

    • getMm2SourceAlias

      public String getMm2SourceAlias()

    • getMm2SourceSeparator

      public String getMm2SourceSeparator()

    • getConsumers

      public int getConsumers()

    • setKafkaConsumerConfig

      public void setKafkaConsumerConfig(Properties kafkaConsumerConfig)
      Kafka consumer config.

    • setBootstrapServers

      public void setBootstrapServers(String bootstrapServers)
      bootstrap.servers: A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. A list of host/port pairs to use for establishing the initial connection to the Kafka cluster.

    • setGroupId

      public void setGroupId(String groupId)
      group.id: A unique string that identifies the consumer group this consumer belongs to.

    • setPartitions

      public void setPartitions(int partitions)
      The number of partitions for the topic being created.

    • setReplicationFactor

      public void setReplicationFactor(int replicationFactor)
      The replication factor for each partition in the topic being created.

    • setEnableNativeProtoLog

      public void setEnableNativeProtoLog(boolean enableNativeProtoLog)

    • setEnableNativeJsonLog

      public void setEnableNativeJsonLog(boolean enableNativeJsonLog)

    • setConfigPath

      public void setConfigPath(String configPath)

    • setTopicNameOfMetrics

      public void setTopicNameOfMetrics(String topicNameOfMetrics)

    • setTopicNameOfProfiling

      public void setTopicNameOfProfiling(String topicNameOfProfiling)

    • setTopicNameOfTracingSegments

      public void setTopicNameOfTracingSegments(String topicNameOfTracingSegments)

    • setTopicNameOfManagements

      public void setTopicNameOfManagements(String topicNameOfManagements)

    • setTopicNameOfMeters

      public void setTopicNameOfMeters(String topicNameOfMeters)

    • setTopicNameOfLogs

      public void setTopicNameOfLogs(String topicNameOfLogs)

    • setTopicNameOfJsonLogs

      public void setTopicNameOfJsonLogs(String topicNameOfJsonLogs)

    • setKafkaHandlerThreadPoolSize

      public void setKafkaHandlerThreadPoolSize(int kafkaHandlerThreadPoolSize)

    • setKafkaHandlerThreadPoolQueueSize

      public void setKafkaHandlerThreadPoolQueueSize(int kafkaHandlerThreadPoolQueueSize)

    • setNamespace

      public void setNamespace(String namespace)

    • setMm2SourceAlias

      public void setMm2SourceAlias(String mm2SourceAlias)

    • setMm2SourceSeparator

      public void setMm2SourceSeparator(String mm2SourceSeparator)

    • setConsumers

      public void setConsumers(int consumers)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • canEqual

      protected boolean canEqual(Object other)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object