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

Interface KafkaHandler

All Known Implementing Classes:
AbstractKafkaHandler, JsonLogHandler, JVMMetricsHandler, LogHandler, MeterServiceHandler, ProfileTaskHandler, ServiceManagementHandler, TraceSegmentHandler
public interface KafkaHandler
A Handler for dealing Message reported by agent. It is binding to a topic of Kafka, and deserialize.

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getTopic()
    A topic of Kafka is handled.
    void
    handle(org.apache.kafka.clients.consumer.ConsumerRecord<String,org.apache.kafka.common.utils.Bytes> record)
    Deserialize and push it to downstream.

  • Method Details

    • getTopic

      String getTopic()
      A topic of Kafka is handled.

    • handle

      void handle(org.apache.kafka.clients.consumer.ConsumerRecord<String,org.apache.kafka.common.utils.Bytes> record)
      Deserialize and push it to downstream.